why or how we lose few messages when i restart my kafka broker?...

Producer#initTransactions doesn't work with KafkaContainer...

How do producers and consumers usually work when sending a video file?...

We are using Spring Cloud Stream for Kafka and we are looking for Exactly Once Semantics with consum...

WSO2 SP - Kafka source with JSON attributes...

What does Broker do when multiple Producers write the same message to Broker? And one more related q...

Force consumer to read only those messages that came in topic after consumer came to life...

How Kafka identifies consumer in a group once it is restarted after crash...

Kafka independent consumers...

Handling Large Messages with Kafka...

Scala : Unable to send message to Kafka (hosted on remote server)...

Kafka - Simple consumer/producer setup doesn't work on different machines, but works locally...

Spark: How to use custom partitionner when writing data to Kafka...

Apache Kafka Producer 'request.timeout.ms' property...

Apache Kafka - How to wait for subscription to finish...

How to send data to multiple Kafka topic partitions in Node JS...

Vert.x EventLoop Thread Block Inet6AddressImpl.lookupAllHostAddr...

Specify default partitions and replication factor for regex based topics in kafka...

Kafka Streams does not increment offset by 1 when producing to topic...

Do all Kafka broker IPs have to be specified when producing a message...

How does librdkafka producer learn about new topic partitions in Kafka...

Bypass Zookeeper in producer/consumer clients?...

Kafka mirror maker putting all messages without a partitioning key together randomly in the target c...

How to fix 'Failed to update metadata after xxx ms' in spring-kafka when send record in call...

No exception is coming while sending message when kafka is down...

How to detect duplicate messages in a kafka topic?...

Kafka throttle producer based on consumer lag...

How does Kafka internally order the messages within a partition? Does it store them as it received f...

Kafka Producer, Consumer, Broker in same host?...

Distributing data socket among kafka cluster nodes...