Skip to content

Issues: confluentinc/parallel-consumer

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

61 Open 161 Closed
61 Open 161 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

ParallelConsumer would run for a while and then exit due to InternalRuntimeException(Timeout)
#833 opened Sep 16, 2024 by dumontxiong
[OOM]Offset map reached to 75% pc-broker-poll thread would keep polling records lead to OOM
#832 opened Sep 12, 2024 by dumontxiong
2
PC keeps retrying in loop on InvalidPidMappingException: The producer attempted to use a producer id which is not currently assigned to its transactional id
#830 opened Sep 9, 2024 by mikhelef
3
Message Loss Detected with frequent close and rebalancing
#826 opened Sep 2, 2024 by sangreal
14
checkAutoCommitIsDisabled fails with kafka-clients < 3.7.0 when using consumer inherited from KafkaConsumer
#825 opened Aug 30, 2024 by ddqof
A possible memory leak in ShardManager.retryQueue ?
#817 opened Jul 25, 2024 by jgodoniuk
8
Sporadic timeouts from ConsumerOffsetCommitter.CommitRequest
#809 opened Jun 25, 2024 by tedcaozoom
1
22
Transactional Producer instance gets timeout getting commit lock while second instance starts verified bug Something isn't working
#803 opened Jun 12, 2024 by PatrickChauveau
3
Seeking to a specific offset for a partition enhancement New feature or request
#782 opened May 30, 2024 by ebrockman1
5
Handling Partition Revocation in Parallel-Consumer Leading to Duplicate Event Processing enhancement New feature or request
#777 opened May 30, 2024 by ajax-levashov-m
2
Missing feature to terminate processing enhancement New feature or request
#718 opened Feb 11, 2024 by Zordid
6
Add explanation of close modes to documentation documentation Improvements or additions to documentation
#642 opened Sep 11, 2023 by rkolesnev
Error log to verbose in AbstractParallelEoSStreamProcessor enhancement New feature or request good first issue Good for newcomers
#640 opened Sep 8, 2023 by bmaggi
Warning log to verbose in RemovedPartitionState good first issue Good for newcomers
#631 opened Sep 1, 2023 by bmaggi
Missing topic and offset infos when login error in ConsumerOffsetCommitter good first issue Good for newcomers
#629 opened Aug 29, 2023 by bmaggi
Wrong multiplier value in retry delay function example good first issue Good for newcomers
#622 opened Aug 8, 2023 by zerda
When parallel consumer does not close kafka consumer if commmit fails during close
#597 opened Jul 6, 2023 by BartoszSta
5
Feature suggestion: Minimum batch size + batch max wait time
#560 opened Feb 24, 2023 by Ehud-Lev-Forter
6
Batching not working as expected
#551 opened Feb 20, 2023 by dixitsingla
4
Is There Any Exception Handler?
#550 opened Feb 20, 2023 by 10000-ki
4
Truncating state
#546 opened Feb 9, 2023 by lennehendrickx
22
Why use of Scheduler if the processing has been proven NON blocking please?
#543 opened Jan 30, 2023 by patpatpat123
Apply backpressure per partition instead of the entire assignment enhancement New feature or request
#540 opened Jan 26, 2023 by gabrielgiussi
6
Move LongPollingMockConsumer to main artefact
#526 opened Dec 21, 2022 by astubbs
1
major: Safe User API exposure of ALL Consumer APIs (seek, end offsets etc)
#520 opened Dec 20, 2022 by astubbs
@astubbs
ProTip! Add no:assignee to see everything that’s not assigned.