Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

How to read data using key in Kafka Consumer API?

Connect to Kafka inside VirtualBox

How does Kafka handle a consumer which is running slower than other consumers?

Spark Streaming - Batch Interval vs Processing time

kafka upgrade to .9 with new consumer api

Producing and Consuming Avro messages from Kafka without Confluent components

Is it possible to obtain specific message offset in Kafka+SparkStreaming?

Kafka consumer startup delay confluent dotnet

Kafka pattern subscription. Rebalancing is not being triggered on new topic

Kafka Partitions Reassignment Performance Impact

kafka-node start consume from last offset

Zookeeper communication protocol

What happens if offset specified by kafka consumer is not present in Broker?

Is it possible to read from multiple partitions using Kafka Simple Consumer?

How to programmatically check if Kafka Broker is up and running in Python

How to close kafka consumer once all messages are consumed?

Kafka: How to Display Offsets

Difference in kafka 0.8 with kafka 0.10

Don't print the kafka-console-consumer warnings

Kafka: Single consumer group in multiple instances