Use for questions related to the Apache Kafka consumer API
Is it possible to limit the size of the batches returned by the Kafka consumer for Spark Streaming? I am …
apache-spark apache-kafka spark-streaming kafka-consumer-apiI installed fresh zookeeper & kafka both. I started them both. Then when I want to see the list of …
apache-kafka apache-zookeeper kafka-consumer-api kafka-producer-apiI am trying to check the kafka consumer by consuming the data from a topic on a remote Kafka cluster. …
apache-kafka kafka-consumer-apiI am using Kafka 0.8.2 to receive data from AdExchange then I use Spark Streaming 1.4.1 to store data to MongoDB. My …
apache-spark apache-kafka spark-streaming kafka-consumer-apiI have a use case where i consume certain logs from a queue and hit some third party API's with …
apache-kafka kafka-consumer-api kafka-producer-apiI'm trying to build an application with kafka-python where a consumer reads data from a range of topics. It is …
python-3.x apache-kafka offset kafka-consumer-api kafka-pythonI am fairly new to kafka so forgive me if this question is trivial. I have a very simple setup …
apache-kafka kafka-consumer-api kafka-producer-api kafka-pythonI am using Kafka 0.8.1 and Kafka python-0.9.0. In my setup, I have 2 kafka brokers setup. When I run my kafka …
python apache-kafka kafka-consumer-api kafka-pythonWith Kafka client Java library, consuming logs has worked for some time but with the following errors it doesn't work …
java apache-kafka kafka-consumer-apiI am using Spring Kafka consumer which fetches messages from a topic and persist them into a db. If a …
spring-boot apache-kafka kafka-consumer-api spring-kafka