pykafka
pykafka copied to clipboard
dsully
Python API for the Kafka Message Queue
Hi, I am running Tail2kafka but I get Flush message's and when I see the server I Got the below Error: ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)...
Hi, I am running Tail2kafka but I get Flush message's and when I see the server I Got the below Error: ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)...
Kafka uses a new messaging format in the most recent versions. This is denoted by the magic byte being set to 1 and is followed by some message attributes which...
Kafka 0.8 includes a breaking update to the protocol. Should there be a development branch of pykafka targeting the new protocol?
To reproduce: 1. Set the log.retention.hours = 1 in config/server.properties on a test kafka server 2. Add a batch of messages using the Producer into a new topic 3. Consume...
Hi, may be I can't found it but a very insteresting feature of kafka is use zookeeper as coordinator and discovery engine, perhaps an interesting feature to add to Python...
