confluentinc/parallel-consumer issues and pull requests

#847 - Support for this feature in python with confluent-kafka

Issue - State: open - Opened by anupsingh3292 2 months ago - 1 comment

#846 - Update maven site plugin versionm15

Pull Request - State: closed - Opened by johnbyrnejb 2 months ago

#845 - docs: updated release instructions

Pull Request - State: closed - Opened by rkolesnev 2 months ago - 1 comment

#844 - Can we do dynamic rewind in setting offset to earlier point on the fly?

Issue - State: closed - Opened by hothero 3 months ago - 1 comment

#843 - Record being picked up by multiple threads simultaneously

Issue - State: open - Opened by singhsaurabh2409 3 months ago - 5 comments
Labels: wait for info

#842 - CommitMode: Individual message commit mode?

Issue - State: closed - Opened by shreeramkulkarni 3 months ago - 2 comments

#841 - Support Kafka-clients 3.9.0

Pull Request - State: closed - Opened by youribonnaffe 3 months ago - 4 comments

#840 - Support Kafka-clients:3.9.0

Issue - State: closed - Opened by youribonnaffe 3 months ago

#839 - fixes #830: Close PC when InvalidPidMappingException

Pull Request - State: closed - Opened by mikhelef 4 months ago - 4 comments

#836 - Fix buffer size include in flight messages in backpressure calculation logic

Pull Request - State: closed - Opened by rkolesnev 4 months ago - 1 comment

#835 - Number of containers in the worker thread pool queue should be taken into account for throttling polls.

Issue - State: closed - Opened by rkolesnev 4 months ago - 1 comment
Labels: verified bug

#834 - Fix retry queue implementation to prevent unbounded growth

Pull Request - State: closed - Opened by rkolesnev 4 months ago - 1 comment

#833 - ParallelConsumer would run for a while and then exit due to InternalRuntimeException(Timeout)

Issue - State: open - Opened by dumontxiong 5 months ago - 8 comments

#832 - [OOM]Offset map reached to 75% pc-broker-poll thread would keep polling records lead to OOM

Issue - State: closed - Opened by dumontxiong 5 months ago - 10 comments
Labels: verified bug

#831 - Can metaPayloadLength reach to OffsetMapCodecManager.DefaultMaxMetadataSize (4KB)?

Issue - State: closed - Opened by dumontxiong 5 months ago - 2 comments

#830 - PC keeps retrying in loop on InvalidPidMappingException: The producer attempted to use a producer id which is not currently assigned to its transactional id

Issue - State: closed - Opened by mikhelef 5 months ago - 7 comments
Labels: good first issue

#828 - Revert release 0.5.3.1 and update Sonatype creds to use token

Pull Request - State: closed - Opened by skl83 6 months ago

#827 - fix for message loss for issue 826

Pull Request - State: closed - Opened by sangreal 6 months ago - 7 comments

#826 - Message Loss Detected with frequent close and rebalancing

Issue - State: closed - Opened by sangreal 6 months ago - 16 comments

#825 - `checkAutoCommitIsDisabled` fails with kafka-clients < 3.7.0 when using consumer inherited from `KafkaConsumer`

Issue - State: open - Opened by ddqof 6 months ago

#824 - Update README for release

Pull Request - State: closed - Opened by skl83 6 months ago - 1 comment

#823 - Update changelog for release

Pull Request - State: closed - Opened by skl83 6 months ago - 1 comment

#822 - switch retryQueue to ConcurrentSkipListSet to avoid ConcurrentModific…

Pull Request - State: closed - Opened by sangreal 6 months ago - 6 comments

#821 - ConcurrentModificationException Happened while high load and draining

Issue - State: closed - Opened by sangreal 6 months ago - 1 comment

#819 - Improved offset commit retry. Add support for SaslAuthenticationException retry timeout

Pull Request - State: closed - Opened by wushilin 6 months ago - 8 comments

#818 - fix: safely completing doClose()

Pull Request - State: closed - Opened by gtassone 7 months ago - 2 comments

#817 - A possible memory leak in ShardManager.retryQueue ?

Issue - State: closed - Opened by jgodoniuk 7 months ago - 12 comments
Labels: verified bug

#816 - Prevent commitSync to bubble up exception to control thread where no exception is caught.

Pull Request - State: closed - Opened by wushilin 7 months ago - 2 comments

#814 - Test issue.

Issue - State: closed - Opened by skl83 7 months ago

#813 - chore: update repo by service bot

Pull Request - State: closed - Opened by ConfluentJenkins 7 months ago - 2 comments

#812 - simplify partition and fix typo

Pull Request - State: closed - Opened by sangreal 8 months ago - 3 comments

#811 - Kafka topic partitions not distributed evenly to PC instances

Issue - State: closed - Opened by agascon 8 months ago - 1 comment