Kafka offsets_for_times not working with Beats because of a Sarama bug
Open
needs_team
- Dominant language
- Go
- Stars
- 12.7k
- Forks
- 5k
- Avg merge
- 2d 2h
- Merged PRs (30d)
- 364
Description
Because of a [bug](https://github.com/IBM/sarama/pull/3108) 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:
```shell
$ kcat -C -o s@timestamp
```
or in python
```python
consumer.offsets_for_times(partitions)
```
The fix has been released in Sarama https://github.com/IBM/sarama/releases/tag/v1.45.1
Contributor guide
Assessment
This issue has not been assessed yet.