Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-producer-api

How to determine API version of Kafka?

Transactional Producer vs Just Idempotent Producer Java (Exception OutOfOrderSequenceException)

Python librdkafka producer perform against the native Apache Kafka Producer

How to fix kafka.common.errors.TimeoutException: Expiring 1 record(s) xxx ms has passed since batch creation plus linger time

What happens if I don't close the kafka producer

Kafka producer send blocks indefinitely when kafka servers are down

Guidelines to handle Timeout exception for Kafka Producer?

What's the best way to design message key in Kafka?

KafkaProducer not successfully sending message into the queue

Uneven Distribution of messages in Kafka Partitions

Java consumer group missing?

How to add consumer group to message in java?

Get Kafka compressed message size

Kafka: Sarama, idempotence and transactional.id

Error reading field 'topic_metadata' in Kafka

Guaranteed delivery of multiple messages to Kafka cluster

Kafka 0.10 Java Client TimeoutException: Batch containing 1 record(s) expired

Can single Kafka producer produce messages to multiple topics and how?

How to get back Kafka producer and consumer configuration (Java API)?

Can talk to Zookeeper but not to the message brokers