This repository was archived by the owner on Mar 24, 2021. It is now read-only.

Description
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'