Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Is there a way to start/stop Kafka consumer in a Spring app manually?

How to get Kafka header's value to Spark Dataset as a single column?

Kafka: What do the numbers in controller_epoch and leader_epoch mean?

apache-kafka

How do we map multiple collections to multiple topics in the mongodb-sink-connector?

How to produce a json object message into kafka topic using java(spring)?

scale spring-kafka consumers app horizontally

Kafka Producer: Disconnect after sending message vs keeping connection open

apache-kafka kafkajs

How to recover kafka messages?

apache-kafka recovery

Conditional logic on a Reactor Flux

Kafka Connect failing to read from Kafka topics over SSL

Kafka - How to skip a bad message in an offset and consume the rest

java apache-kafka

Kafka compare consecutive values for a key

Flink Tumble Window Trigger time

Kafka topic no longer exists after restart

How to create multiple kafka consumer groups in same topic

apache-kafka consumer

Why does kafka producer have client.id?

Re-assignment of Partition gets infinitely stuck in "Still in progress" state

Write a csv file to a kafka topic

Kafka repartitioning ( for group by based on key)

Confluent Kafka: Consumer does not read from beginning for all partitions in a topic