Skip to content

Kafka offsets_for_times not working with Beats because of a Sarama bug #43824

Open
@fboismenu

Description

@fboismenu

Because of a bug in Sarama library, when producing messages to Kafka, client cannot start consuming from a point in time based on a timestamp.

Example of clients which are affected:

$ kcat -C -o s@timestamp

or in python

consumer.offsets_for_times(partitions)

The fix has been released in Sarama https://github.com/IBM/sarama/releases/tag/v1.45.1

Metadata

Metadata

Assignees

No one assigned

    Labels

    needs_teamIndicates that the issue/PR needs a Team:* label

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions