You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Python documentation incorrectly states that the timestamp field should use microseconds. If we take a look at rdkafka.h however we can see that the expected unit is actually Milliseconds
Description
Python documentation incorrectly states that the timestamp field should use microseconds. If we take a look at rdkafka.h however we can see that the expected unit is actually Milliseconds
Python Docs
https://docs.confluent.io/current/clients/confluent-kafka-python/#confluent_kafka.Producer.produce
rdkafka.h
https://github.com/edenhill/librdkafka/blob/13befa7053c43593fd6f2effdffbd83c3ea52eb7/src/rdkafka.h#L804
This will ultimately cause issues from Kafka as the broker will actually record this timestamp which will break things
https://issues.apache.org/jira/browse/KAFKA-6939
How to reproduce
produce a message with a timestamp with microsecond granularity.
Checklist
Please provide the following information:
confluent_kafka.version()
andconfluent_kafka.libversion()
):{...}
'debug': '..'
as necessary)The text was updated successfully, but these errors were encountered: