search

zalando / nakadi

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
https://nakadi.io
MIT License
952 stars 292 forks source link

Use begin/end offsets API in Kafka consumer #1522

Closed a1exsh closed 1 year ago

a1exsh commented 1 year ago

This is to avoid assign/seek call, which might be relevant to the Kafka OldGen garbage issue we are currently addressing.

adyach commented 1 year ago

minor things otherwise lgtm

a1exsh commented 1 year ago

There is no difference (form Kafka GC standpoint) compared to when using assign/seek for the same purpose.