Kafka-Python provides low-level protocol support for Apache Kafka as well as high-level consumer and producer classes.
Using kafka-python-1.0.2. If I have a topic with 10 partitions, how do I go about committing a particular partition, while looping …
python kafka-consumer-api kafka-pythonI have used Kafka Streams in Java. I could not find similar API in python. Do Apache Kafka support stream …
python apache-kafka apache-kafka-streams confluent-platform kafka-pythonI am having trouble with KafaConsumer to make it read from the beginning, or from any other explicit offset. Running …
python apache-kafka kafka-consumer-api kafka-pythonI have a very strange problem when trying to connect locally to Kafka 0.10.0.0 using Python client on CentOS. My connection …
apache-kafka kafka-pythonI have an application for downloading specific web-content, from a stream of URL's generated from 1 Kafka-producer. I've created a topic …
apache-kafka kafka-pythonI'm trying to write a simple pyspark job, which would receive data from a kafka broker topic, did some transformation …
python-2.7 pyspark spark-streaming kafka-pythonI have problems with polling messages from Kafka in a Consumer Group. My Consumer Object assigns to a given partition …
python apache-kafka consumer kafka-pythonI am doing Python Kafka consumer (trying to use kafka.consumer.SimpleConsumer or kafka.consumer.simple.SimpleConsumer in http://kafka-python.…
python apache-kafka kafka-consumer-api kafka-pythonI have an application which uses Kafka 1.0 as a queue. The Kafka topic has 80 partitions and 80 consumers running. (Kafka-python consumers). …
python apache-kafka kafka-consumer-api kafka-pythonI'm trying to create kafka producer with ssl. I need information on how to set SSL parameters in the constructor, …
kafka-python