Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Why is Kafka consumer ignoring my "earliest" directive in the auto.offset.reset parameter and thus not reading my topic from the absolute first event?

Uneven Distribution of messages in Kafka Partitions

How can I retry failure messages from kafka?

Java consumer group missing?

What makes Kafka high in throughput?

apache-kafka

How Kafka Nodes and zookeeper will communicate with each other?

Rails: How to listen to / pull from service or queue?

Using Kafka Connect HOWTO "commit offsets" as soon as a "put" is completed in SinkTask

How does Kafka guarantee sequential disk access?

apache-kafka

Kafka consumer group offset retention

Kafka Error connecting to node ubuntukafka:9092 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient) java.net.UnknownHostException:

Kafka Producer cannot validate record wihout PK and return InvalidRecordException

Fail to create SparkContext

Azure Event Hub vs Kafka as a Service Broker

SBT cannot import Kafka encoder/decoder classes

kafka consumer to dynamically detect topics added

Kafka Console consumer with kerberos authentication

If i set 'compression.type' at topic level and producer level, which takes precedence

apache-kafka

Spring Boot Kafka: Commit cannot be completed since the group has already rebalanced

How to write to Kafka from Python logging module?

python apache-kafka