Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / confluentinc/parallel-consumer issues and pull requests

#516 - build(deps): bump versions-maven-plugin from 2.13.0 to 2.14.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#515 - build(deps): bump reactor-core from 3.5.0 to 3.5.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#513 - build(deps): bump slf4j-api from 2.0.3 to 2.0.6

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#511 - build(deps): bump maven-install-plugin from 3.0.1 to 3.1.0

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#509 - build(deps): bump vertx.version from 4.3.5 to 4.3.6

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 1 comment
Labels: dependencies

#508 - docs: "Back Pressure" notes and various Javadoc

Pull Request - State: closed - Opened by astubbs about 2 years ago - 1 comment
Labels: documentation, wait for info

#506 - minor: docs: Fix chart links

Pull Request - State: open - Opened by astubbs about 2 years ago

#496 - tests: Implement the empty tests

Pull Request - State: open - Opened by astubbs about 2 years ago

#494 - tests: Reenable disabled legacy tests in ParallelEoSStreamProcessorTest

Pull Request - State: closed - Opened by astubbs about 2 years ago - 2 comments

#492 - tests: Fixes incorrect assumption in main PC unit test

Pull Request - State: closed - Opened by astubbs about 2 years ago - 1 comment

#490 - Question: Is maxUncommittedMessagesToHandle infinitely growable?

Issue - State: closed - Opened by ang-zeyu about 2 years ago - 8 comments
Labels: question

#488 - major: Refactor God class to components

Pull Request - State: closed - Opened by astubbs about 2 years ago - 1 comment

#485 - Feature/health metrics micrometer [WIP]

Pull Request - State: closed - Opened by nachomdo about 2 years ago - 12 comments

#482 - fixes #327: Improve error message when Kafka Streams magic number found

Pull Request - State: closed - Opened by nachomdo about 2 years ago - 2 comments

#473 - Feature: Producer sends to least loaded broker

Pull Request - State: closed - Opened by astubbs over 2 years ago - 2 comments

#464 - fixes #71: Feature: Health check and metrics

Pull Request - State: open - Opened by astubbs over 2 years ago - 4 comments

#459 - Error on closing Parallel Consumer

Issue - State: closed - Opened by jatindersthind over 2 years ago - 9 comments

#443 - feature: Python Support

Pull Request - State: open - Opened by Robbie-Palmer over 2 years ago - 2 comments

#442 - build: Setup mvnw

Pull Request - State: open - Opened by astubbs over 2 years ago - 1 comment

#441 - feature #50: Features/queue priority

Pull Request - State: closed - Opened by astubbs over 2 years ago - 2 comments

#408 - feature: Add new encoding runlength v3 using Longs instead of Integers

Pull Request - State: open - Opened by astubbs over 2 years ago - 1 comment

#405 - refactor: Remove static state

Pull Request - State: closed - Opened by astubbs over 2 years ago - 1 comment

#402 - Max loading factor steps reached: 100/100

Issue - State: open - Opened by bartman64 over 2 years ago - 19 comments

#373 - batchSize(100) but only getting from 1 to 3 messages at a time in my callback method

Issue - State: closed - Opened by mbieser over 2 years ago - 4 comments
Labels: not-a-bug

#366 - Dead letter queue (DLQ) as option for retry expiration

Pull Request - State: closed - Opened by astubbs over 2 years ago - 1 comment

#346 - feature #520: Thread safe User API exposure of ALL Consumer APIs

Pull Request - State: closed - Opened by astubbs over 2 years ago - 1 comment

#345 - fixes #203: Broker disconnect testing and ChaosBroker

Pull Request - State: open - Opened by astubbs over 2 years ago

#327 - When unexpected magic bytes occur, improve the feedback in the error shown to the user

Issue - State: closed - Opened by astubbs over 2 years ago - 1 comment
Labels: good first issue

#326 - Error in onPartitionsAssigned in parallel consumer

Issue - State: open - Opened by milansanjeev over 2 years ago - 14 comments
Labels: not-a-bug

#325 - major: New IPC system using lightweight Lambda actor queue

Pull Request - State: open - Opened by astubbs over 2 years ago

#319 - Error during shutdown - ConcurrentModificationException

Issue - State: closed - Opened by JorgenRingen over 2 years ago - 1 comment
Labels: low

#303 - major: Extend Consumer and Function for more cohesive API

Pull Request - State: open - Opened by astubbs almost 3 years ago - 1 comment

#300 - POC: 299: START: Loom POC

Pull Request - State: open - Opened by astubbs almost 3 years ago

#291 - feature: #242 Explicit terminal and retry exceptions for cleaner logging and poison pills

Pull Request - State: closed - Opened by astubbs almost 3 years ago - 7 comments

#271 - Major refactor: Package restructure

Pull Request - State: open - Opened by astubbs almost 3 years ago

#270 - major: #200 Shared nothing architecture - Partition Events

Pull Request - State: open - Opened by astubbs almost 3 years ago

#267 - docs: Comparison to Spring Cloud Stream Kafka binder

Issue - State: closed - Opened by astubbs almost 3 years ago - 3 comments
Labels: help wanted, wontfix, low, not-a-bug

#266 - feature: Option for batch to only contain messages of the same key

Issue - State: open - Opened by astubbs almost 3 years ago - 8 comments
Labels: good first issue

#246 - Consider turning on code sorting in the formatter

Issue - State: closed - Opened by astubbs almost 3 years ago - 1 comment
Labels: low, needs-investigation, not-a-bug

#220 - Docker naming, fixes and improvements

Pull Request - State: open - Opened by astubbs almost 3 years ago

#205 - vert.x: Run user funtions in a Vertical instead of Java thread pool

Issue - State: closed - Opened by astubbs almost 3 years ago - 1 comment
Labels: low

#203 - Bug: ConsumerOffsetCommitter goes into failure state after broker downtime

Issue - State: closed - Opened by nioertel almost 3 years ago - 4 comments
Labels: wait for info, needs-investigation, cannot-reproduce

#199 - Dynamic reason support for failfast in awaitility

Issue - State: closed - Opened by astubbs almost 3 years ago - 1 comment
Labels: low

#191 - Need ability to seek to the beginning of a partition

Issue - State: closed - Opened by fowlerp-qlik about 3 years ago - 5 comments
Labels: enhancement, good first issue, low, workaround-exists

#187 - Enable changing of topic subscription before or after PC has started

Issue - State: closed - Opened by astubbs about 3 years ago - 1 comment
Labels: ver:1.0

#183 - Feature: Allow unordered processing of messages without a key in 'KEY' ordering mode

Issue - State: closed - Opened by rjoly-qlik about 3 years ago - 1 comment
Labels: enhancement, needs-investigation, ver:1.0

#181 - api: Add convenience methods for Vertx calls

Pull Request - State: open - Opened by astubbs about 3 years ago

#179 - POC for scatter-gather parallel webservice requests

Pull Request - State: open - Opened by astubbs over 3 years ago - 1 comment

#175 - Ability use different consume and produce types for the key and value

Issue - State: closed - Opened by BDeus over 3 years ago - 6 comments
Labels: enhancement, high, needs-investigation

#172 - Release train for 1.0

Issue - State: open - Opened by astubbs over 3 years ago - 9 comments
Labels: high

#154 - Integrate into a Proxy so can support any language and a server side queue implementation

Issue - State: closed - Opened by astubbs over 3 years ago - 1 comment
Labels: enhancement

#144 - ProducerManager should handle different types of transaction failures appropriately

Issue - State: closed - Opened by astubbs over 3 years ago - 3 comments
Labels: enhancement, good first issue, help wanted, low, needs-investigation, ver:0.3.2.0

#143 - Parallel tests in CI

Pull Request - State: closed - Opened by astubbs over 3 years ago - 1 comment

#119 - Integration with Kafka Connect

Issue - State: closed - Opened by kondamudikarthik over 3 years ago - 5 comments
Labels: enhancement, wontfix, low

#81 - Parallel join technique documentation

Pull Request - State: open - Opened by astubbs almost 4 years ago - 1 comment

#65 - Enhanced retry epic

Issue - State: closed - Opened by astubbs about 4 years ago - 6 comments
Labels: enhancement, high

#57 - Reduce debug log output

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: ver:0.3.1

#53 - Exact continuous offset encoding for precise offset payload size back pressure

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: medium, draft-available

#50 - Feature: When subscribing to multiple topics, have the ability to priorities topics over others

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: enhancement

#49 - Feature: Run mode where transition to plain offset committing (no encoded offsets needed)

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: enhancement, low

#48 - Support scheduled message processing (scheduled retry)

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: enhancement, ver:0.3.1, medium

#41 - Performance: FindCompletedEligibleOffsetsAndRemove method try replacing with cache of incomplete offsets

Issue - State: closed - Opened by astubbs about 4 years ago - 2 comments
Labels: low, draft-available

#40 - Feature: Transactional mode for individual consume producer loop instead of periodic batch

Issue - State: closed - Opened by astubbs about 4 years ago - 1 comment
Labels: enhancement, low

#34 - Monitor for progress and optionally shutdown (leave consumer group), skip message or send to DLQ

Issue - State: closed - Opened by astubbs about 4 years ago - 2 comments
Labels: enhancement, ver:0.3.1, medium

#29 - performance: Support asynchronous sending of result messages

Issue - State: closed - Opened by astubbs over 4 years ago - 1 comment
Labels: enhancement, medium

#28 - Opentracing support

Issue - State: closed - Opened by astubbs over 4 years ago - 1 comment
Labels: enhancement, low

#24 - Add distributed rate limiting support

Issue - State: closed - Opened by astubbs over 4 years ago - 2 comments
Labels: enhancement, medium

#22 - WIP: Fixes #21 - Dynamic concurrency control

Pull Request - State: closed - Opened by astubbs over 4 years ago
Labels: enhancement

#21 - Dynamic concurrency control with flow control or tcp congestion control theory

Issue - State: closed - Opened by astubbs over 4 years ago - 1 comment
Labels: enhancement, medium, draft-available