Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

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

Kafka Connect JDBC sink connector not working

How to pass topics dynamically to a kafka listener?

ERROR org.apache.kafka.common.utils.KafkaThread - Uncaught exception in thread 'kafka-producer-network-thread

java.lang.ClassCastException:xx cannot be cast to org.apache.avro.generic.IndexedRecord

What should I use: Kafka Stream or Kafka consumer api or Kafka connect

Kafka: How to get last modified time for a topic i.e. last message added to any partition of the topic