Use for questions related to the Apache Kafka consumer API
I'm facing some serious problems trying to implement a solution for my needs, regarding KafkaConsumer (>=0.9). Let's imagine I have …
apache-kafka kafka-consumer-apiI'm receiving exception when start Kafka consumer. org.apache.kafka.clients.consumer.OffsetOutOfRangeException: Offsets out of range with no configured …
java apache-kafka kafka-consumer-apiI am using Kafka Server 0.9 with consumer kafka-client version 0.9 and kafka-producer 0.8.2. Every thing is working great except i am getting …
apache-kafka kafka-consumer-apiI'm currently working with Kafka and Flink, I have kafka running in my local PC and I created a topic …
apache-kafka kafka-consumer-apiI am using apache kafka to produce and consume a file 5GB in size. I want to know if there …
apache-kafka kafka-consumer-apiI am using the Python high level consumer for Kafka and want to know the latest offsets for each partition …
python apache-kafka kafka-consumer-api kafka-pythonI am new to Kafka,and I don't really understand the meaning of Kafka configuration, can anyone explain more understandable …
apache-kafka kafka-consumer-apiI am trying to create a kafka topic via AdminCommand using below code Source ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.…
java scala apache-kafka kafka-consumer-apiproducer sends messages 1, 2, 3, 4 consumer receives messages 1, 2, 3, 4 consumer crashes/disconnects producer sends messages 5, 6, 7 consumer comes back up and should receive messages …
apache-kafka kafka-consumer-apiI'm working with Apache Kafka and its Java client and I see that messages are load balanced across different Kafka …
apache-kafka kafka-consumer-api