Kafka producer always sends messages to the same partition (Kafka + Python)...

How to automatically generate partition keys for messages (Kafka + Python)?...

Kafka Consumers on different partitions under same group are still consuming same messages intermitt...

confluent-kafka-python library: read offset per topic per consumer_group...

Write a csv file to a kafka topic...

Cant send message by using pykafka...

Not able to communicate from a remote machine to Kafka cluster...

TypeError: produce() got an unexpected keyword argument 'linger_ms'...

Kafka and Pyspark Integration...

PyKafka client connecting wrong broker...

How to consume kafka topic and parse/serve over http?...

PyKafka metadata in bytes instead of strings...

Can I call get_delivery_report from a Kafka produce once after a batch of messages is produced?...

How to use pykafka group consumer with gevent?...

How to select starting offset in Pykafka simpleconsumer?...

pykafka topics return None...

What's the reason for TypeError: unhashable type: 'TopicAndPartition' when KafkaUtils.cr...

How to make kafka-python or pykafka work as an async producer with uwsgi and gevent?...