decaton icon indicating copy to clipboard operation
decaton copied to clipboard

Published 20 hours ago • verified publisher icon line

Use poll(Duration)

Open ocadaruma opened this issue 2 years ago • 0 comments

Summary

  • 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 avatar Jul 14 '21 02:07 ocadaruma