Use poll(Duration) - Githubissues

line / decaton

High throughput asynchronous task processing on Apache Kafka

Apache License 2.0

336 stars 51 forks source link

Closed ocadaruma closed 2 years ago

ocadaruma commented 3 years ago

Currently, Decaton uses KafkaConsumer#poll(long) which could block indefinitely and already marked as deprecated
- https://github.com/line/decaton/blob/v3.0.1/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/ConsumeManager.java#L165
We should migrate to poll(Duration) overload

ocadaruma commented 2 years ago

closed by #174