confluentinc / confluentinc/parallel-consumer

Question: Does Parallel-consumer have state that we can read from?

Open
#484 11 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Java
Stars
299
Forks
172
PR merge metrics
No merged PRs in 30d

Description

Hi, We have noticed that during high load, one of the consumers can get stuck, meaning it will report the same lag, but will not process anything, we were not able to reproduce it locally, but we are afraid that it will happen again. 

In our kafka-stream process we supervise [state](https://github.com/apache/kafka/blob/c8a228d122b32d9df9f56b43fe55a27a07ee6a12/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java#L360) to monitor the process, if we see an error or problem, we restart the process. Does ParallelConsumer have something similar?

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.