Skip to content

Timestamps are not added when producing #95

@fuyar

Description

@fuyar

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

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions