Parsely / pykafka

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
http://pykafka.readthedocs.org/
Apache License 2.0
1.12k stars 232 forks source link

message consumed by pykafka simpleconsumer has timestamp value 0 #990

Open ipavlyshyn opened 4 years ago

ipavlyshyn commented 4 years ago

PyKafka version: 2.8.0 Kafka version: kafka_2.12-2.2.0.jar Message has LogAppendTime on kafka server but after consuming it by pykafka simpleconsumer message timestamp = 0

Output from kafka-console-consumer

kafka:~$ ~/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic http --from-beginning --property "print.timestamp=true" --property 'print.key=true' LogAppendTime:1579164671511 ypohtzfvrn.net:1:1 "test"

Output from pykafka client

(Pdb++) consumer <pykafka.simpleconsumer.SimpleConsumer at 0x7f79c0260860 (consumer_group=None)> (Pdb++) msg <pykafka.protocol.message.Message object at 0x7f79c0cf1318> (Pdb++) msg.timestamp 0 (Pdb++) msg.value.decode("utf-8") '"test" (Pdb++) consumer.topic.name.decode("utf8") 'http'