confluentinc / confluentinc/parallel-consumer
Question: Does Parallel-consumer have state that we can read from?
- 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.