forked from confluentinc/parallel-consumer
-
Notifications
You must be signed in to change notification settings - Fork 8
All issues
Issue creation is restricted in this repository
- #52 · renatojava opened
on Jul 18, 2026 8
Issues
is:issue state:open
is:issue state:open
Search results
core: a record becomes selectable before its offset is in incompleteOffsets
area/internalsInternal structure and refactoringInternal structure and refactoringarea/reliabilityCorrectness under rebalance, commit and shutdownCorrectness under rebalance, commit and shutdownbugSomething isn't workingSomething isn't workingStatus: Open.#370 In astubbs/parallel-consumer;feat(core): a commit-failure seam, so the application decides instead of PC always terminating
featureNew capability or improvement to an existing oneNew capability or improvement to an existing oneStatus: Open.#317 In astubbs/parallel-consumer;Batching requests a full extra in-flight target of work, and batchSize is unvalidated
0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 releasearea/batching-orderingArea: batching-orderingArea: batching-orderingbugSomething isn't workingSomething isn't workingverified bugConfirmed as a real defect on the upstream trackerConfirmed as a real defect on the upstream trackerStatus: Open.#311 In astubbs/parallel-consumer;- Status: Open.#300 In astubbs/parallel-consumer;
Kafka Streams: give a Streams topology PC's per-key parallelism
0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 releasearea/internalsInternal structure and refactoringInternal structure and refactoringarea/performanceArea: performanceArea: performancefeatureNew capability or improvement to an existing oneNew capability or improvement to an existing onepr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstreamStatus: Open.#255 In astubbs/parallel-consumer;confluentinc#372: Have processing functions attached to topics instead of a global one for all subscribed topics
area/apiArea: apiArea: apifeatureNew capability or improvement to an existing oneNew capability or improvement to an existing onepr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstreamupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#254 In astubbs/parallel-consumer;confluentinc#320: Extend parallel consumer to be able to include multiple consumers/producers of different clusters
area/modulesArea: modulesArea: modulesfeatureNew capability or improvement to an existing oneNew capability or improvement to an existing oneupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#253 In astubbs/parallel-consumer;confluentinc#267: docs: Comparison to Spring Cloud Stream Kafka binder
area/docsArea: docsArea: docsdocumentationImprovements or additions to documentationImprovements or additions to documentationhelp wantedExtra attention is neededExtra attention is neededupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#251 In astubbs/parallel-consumer;confluentinc#246: Consider turning on code sorting in the formatter
area/build-testArea: build-testArea: build-testchoreMaintenance work, no user-visible behaviour changeMaintenance work, no user-visible behaviour changenot-a-bugJudged not a defect on the upstream trackerJudged not a defect on the upstream trackerupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#250 In astubbs/parallel-consumer;confluentinc#205: vert.x: Run user funtions in a Vertical instead of Java thread pool
area/modulesArea: modulesArea: modulesfeatureNew capability or improvement to an existing oneNew capability or improvement to an existing onepr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstreamupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#249 In astubbs/parallel-consumer;confluentinc#203: Bug: ConsumerOffsetCommitter goes into failure state after broker downtime
area/reliabilityCorrectness under rebalance, commit and shutdownCorrectness under rebalance, commit and shutdownbugSomething isn't workingSomething isn't workingupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerwait for infoAwaiting information from the reporterAwaiting information from the reporterStatus: Open.#248 In astubbs/parallel-consumer;confluentinc#199: Dynamic reason support for failfast in awaitility
area/build-testArea: build-testArea: build-testchoreMaintenance work, no user-visible behaviour changeMaintenance work, no user-visible behaviour changeupstream-admin-closedClosed upstream by the 2023 administrative sweep, not by a fix or a decisionClosed upstream by the 2023 administrative sweep, not by a fix or a decisionupstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc trackerStatus: Open.#247 In astubbs/parallel-consumer;