-
Notifications
You must be signed in to change notification settings - Fork 103
Closed
Description
Hello,
When producing with kt, record timestamps (available since Kafka 0.10) are not specified.
Here's an example with what kafkacat is producing.
{"partition": 0,"offset": 0, "timestamp": -1, "key": test, "value": NULL}
echo 'test:' | kafkacat -P -b dbpoc-03 -t test_timestamp -K: -Z -p -1
{"partition": 4,"offset": 0, "timestamp": 1544028030676, "key": test, "value": NULL}
Also kt is not using the default partitioner (the one from Kafka) ?
Metadata
Metadata
Assignees
Labels
No labels