Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-python

Kafka partition Lag increasing

Encoding / formatting issues with python kafka library

pip install confluent-kafka gives error in mac

reading only specific messages from kafka topic

Write a csv file to a kafka topic

Not able to send large messages to Kafka

Getting latest message timestamp in my Kafka queue

kafka consumer seek is not working: AssertionError: Unassigned partition

How to force a consumer to read a specific partition in kafka

apache-kafka kafka-python

kafka-python read from last produced message after a consumer restart

Kafka not receiving messages when indicating group_id in Python

How to implement request-reply (synchronous) messaging paradigm in Kafka?

How to add a failure callback for kafka-python kafka.KafkaProducer#send()?

kafka-python

Kafka 10 - Python Client with Authentication and Authorization

For AvroProducer to Kafka, where are avro schema for "key" and "value"?

Sending Large CSV to Kafka using python Spark