diff options
Diffstat (limited to 'kafka/producer/future.py')
| -rw-r--r-- | kafka/producer/future.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/kafka/producer/future.py b/kafka/producer/future.py index bc50d0d..e39a0a9 100644 --- a/kafka/producer/future.py +++ b/kafka/producer/future.py @@ -44,7 +44,9 @@ class FutureRecordMetadata(Future): (relative_offset, timestamp_ms, checksum, serialized_key_size, serialized_value_size) = self.args - if produce_timestamp_ms is not None: + # None is when Broker does not support the API (<0.10) and + # -1 is when the broker is configured for CREATE_TIME timestamps + if produce_timestamp_ms is not None and produce_timestamp_ms != -1: timestamp_ms = produce_timestamp_ms if offset != -1 and relative_offset is not None: offset += relative_offset |