René's URL Explorer Experiment


Title: GitHub - astubbs/parallel-consumer: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing. · GitHub

Open Graph Title: GitHub - astubbs/parallel-consumer: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

X Title: GitHub - astubbs/parallel-consumer: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Description: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing. - astubbs/parallel-consumer

Open Graph Description: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing. - astubbs/parallel-consumer

X Description: Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing. - astubbs/parallel-consumer

Opengraph URL: https://github.com/astubbs/parallel-consumer

X: @github

direct link

Domain: github.com

route-pattern/:user_id/:repository
route-controllerfiles
route-actiondisambiguate
fetch-noncev2:8e870d75-0c11-4b87-e1f4-0221d64744c9
current-catalog-service-hashf3abb0cc802f3d7b95fc8762b94bdcb13bf39634c40c357301c4aa1d67a256fb
request-idE04A:305FD:9DEB:C85B:6A4C102C
html-safe-nonceee8efb0d94c9a7d9ad5fc0ca4ebdb1a1f3990c54cb928eeecedd0d1017f57ece
visitor-payloadeyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJFMDRBOjMwNUZEOjlERUI6Qzg1Qjo2QTRDMTAyQyIsInZpc2l0b3JfaWQiOiI0MTYwMzM5ODg1NzM3OTA2MjIwIiwicmVnaW9uX2VkZ2UiOiJpYWQiLCJyZWdpb25fcmVuZGVyIjoiaWFkIn0=
visitor-hmac7a69861657bcdfbe02c751c877a697ce1c773f416049db595ea1ebd01dce775e
hovercard-subject-tagrepository:312013516
github-keyboard-shortcutsrepository,copilot
google-site-verificationApib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I
octolytics-urlhttps://collector.github.com/github/collect
analytics-location//
fb:app_id1401488693436528
apple-itunes-appapp-id=1477376905, app-argument=https://github.com/astubbs/parallel-consumer
twitter:imagehttps://opengraph.githubassets.com/fd123da3b87682e9ccfb07ab2c1b1f0262688373df563dba23bfb7c736e96466/astubbs/parallel-consumer
twitter:cardsummary_large_image
og:imagehttps://opengraph.githubassets.com/fd123da3b87682e9ccfb07ab2c1b1f0262688373df563dba23bfb7c736e96466/astubbs/parallel-consumer
og:image:altParallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing. - astubbs/parallel-consumer
og:image:width1200
og:image:height600
og:site_nameGitHub
og:typeobject
hostnamegithub.com
expected-hostnamegithub.com
None0ccfc9e5281bfe12e38a4d632dc422843e4d5b6757917f7efda2f6567d72fea9
turbo-cache-controlno-cache
go-importgithub.com/astubbs/parallel-consumer git https://github.com/astubbs/parallel-consumer.git
octolytics-dimension-user_id3414
octolytics-dimension-user_loginastubbs
octolytics-dimension-repository_id312013516
octolytics-dimension-repository_nwoastubbs/parallel-consumer
octolytics-dimension-repository_publictrue
octolytics-dimension-repository_is_forktrue
octolytics-dimension-repository_parent_id269083827
octolytics-dimension-repository_parent_nwoconfluentinc/parallel-consumer
octolytics-dimension-repository_network_root_id269083827
octolytics-dimension-repository_network_root_nwoconfluentinc/parallel-consumer
turbo-body-classeslogged-out env-production page-responsive
disable-turbofalse
browser-stats-urlhttps://api.github.com/_private/browser/stats
browser-errors-urlhttps://api.github.com/_private/browser/errors
release18812876666a23a0912556e224383baa4c84cf8e
ui-targetfull
theme-color#1e2327
color-schemelight dark

Links:

Skip to contenthttps://github.com/astubbs/parallel-consumer#start-of-content
https://github.com/
Sign in https://github.com/login?return_to=https%3A%2F%2Fgithub.com%2Fastubbs%2Fparallel-consumer
GitHub CopilotWrite better code with AIhttps://github.com/features/copilot
GitHub Copilot appDirect agents from issue to mergehttps://github.com/features/ai/github-app
MCP RegistryNewIntegrate external toolshttps://github.com/mcp
ActionsAutomate any workflowhttps://github.com/features/actions
CodespacesInstant dev environmentshttps://github.com/features/codespaces
IssuesPlan and track workhttps://github.com/features/issues
Code ReviewManage code changeshttps://github.com/features/code-review
GitHub Advanced SecurityFind and fix vulnerabilitieshttps://github.com/security/advanced-security
Code securitySecure your code as you buildhttps://github.com/security/advanced-security/code-security
Secret protectionStop leaks before they starthttps://github.com/security/advanced-security/secret-protection
Why GitHubhttps://github.com/why-github
Documentationhttps://docs.github.com
Bloghttps://github.blog
Changeloghttps://github.blog/changelog
Marketplacehttps://github.com/marketplace
View all featureshttps://github.com/features
Enterpriseshttps://github.com/enterprise
Small and medium teamshttps://github.com/team
Startupshttps://github.com/enterprise/startups
Nonprofitshttps://github.com/solutions/industry/nonprofits
App Modernizationhttps://github.com/solutions/use-case/app-modernization
DevSecOpshttps://github.com/solutions/use-case/devsecops
DevOpshttps://github.com/solutions/use-case/devops
CI/CDhttps://github.com/solutions/use-case/ci-cd
View all use caseshttps://github.com/solutions/use-case
Healthcarehttps://github.com/solutions/industry/healthcare
Financial serviceshttps://github.com/solutions/industry/financial-services
Manufacturinghttps://github.com/solutions/industry/manufacturing
Governmenthttps://github.com/solutions/industry/government
View all industrieshttps://github.com/solutions/industry
View all solutionshttps://github.com/solutions
AIhttps://github.com/resources/articles?topic=ai
Software Developmenthttps://github.com/resources/articles?topic=software-development
DevOpshttps://github.com/resources/articles?topic=devops
Securityhttps://github.com/resources/articles?topic=security
View all topicshttps://github.com/resources/articles
Customer storieshttps://github.com/customer-stories
Events & webinarshttps://github.com/resources/events
Ebooks & reportshttps://github.com/resources/whitepapers
Business insightshttps://github.com/solutions/executive-insights
GitHub Skillshttps://skills.github.com
Documentationhttps://docs.github.com
Customer supporthttps://support.github.com
Community forumhttps://github.com/orgs/community/discussions
Trust centerhttps://github.com/trust-center
Partnershttps://github.com/partners
View all resourceshttps://github.com/resources
GitHub SponsorsFund open source developershttps://github.com/sponsors
Security Labhttps://securitylab.github.com
Maintainer Communityhttps://maintainers.github.com
Acceleratorhttps://github.com/accelerator
GitHub Starshttps://stars.github.com
Archive Programhttps://archiveprogram.github.com
Topicshttps://github.com/topics
Trendinghttps://github.com/trending
Collectionshttps://github.com/collections
Enterprise platformAI-powered developer platformhttps://github.com/enterprise
GitHub Advanced SecurityEnterprise-grade security featureshttps://github.com/security/advanced-security
Copilot for BusinessEnterprise-grade AI featureshttps://github.com/features/copilot/copilot-business
Premium SupportEnterprise-grade 24/7 supporthttps://github.com/premium-support
Pricinghttps://github.com/pricing
Search syntax tipshttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
documentationhttps://docs.github.com/search-github/github-code-search/understanding-github-code-search-syntax
Sign in https://github.com/login?return_to=https%3A%2F%2Fgithub.com%2Fastubbs%2Fparallel-consumer
Sign up https://github.com/signup?ref_cta=Sign+up&ref_loc=header+logged+out&ref_page=%2F%3Cuser-name%3E%2F%3Crepo-name%3E&source=header-repo&source_repo=astubbs%2Fparallel-consumer
Reloadhttps://github.com/astubbs/parallel-consumer
Reloadhttps://github.com/astubbs/parallel-consumer
Reloadhttps://github.com/astubbs/parallel-consumer
astubbs https://github.com/astubbs
parallel-consumerhttps://github.com/astubbs/parallel-consumer
confluentinc/parallel-consumerhttps://github.com/confluentinc/parallel-consumer
Notifications https://github.com/login?return_to=%2Fastubbs%2Fparallel-consumer
Fork 3 https://github.com/login?return_to=%2Fastubbs%2Fparallel-consumer
Star 11 https://github.com/login?return_to=%2Fastubbs%2Fparallel-consumer
Code https://github.com/astubbs/parallel-consumer
Issues 3 https://github.com/astubbs/parallel-consumer/issues
Pull requests 12 https://github.com/astubbs/parallel-consumer/pulls
Actions https://github.com/astubbs/parallel-consumer/actions
Projects https://github.com/astubbs/parallel-consumer/projects
Models https://github.com/astubbs/parallel-consumer/models
Security and quality 0 https://github.com/astubbs/parallel-consumer/security
Insights https://github.com/astubbs/parallel-consumer/pulse
Code https://github.com/astubbs/parallel-consumer
Issues https://github.com/astubbs/parallel-consumer/issues
Pull requests https://github.com/astubbs/parallel-consumer/pulls
Actions https://github.com/astubbs/parallel-consumer/actions
Projects https://github.com/astubbs/parallel-consumer/projects
Models https://github.com/astubbs/parallel-consumer/models
Security and quality https://github.com/astubbs/parallel-consumer/security
Insights https://github.com/astubbs/parallel-consumer/pulse
https://github.com/astubbs/parallel-consumer
Brancheshttps://github.com/astubbs/parallel-consumer/branches
Tagshttps://github.com/astubbs/parallel-consumer/tags
https://github.com/astubbs/parallel-consumer/branches
https://github.com/astubbs/parallel-consumer/tags
605 Commitshttps://github.com/astubbs/parallel-consumer/commits/master/
https://github.com/astubbs/parallel-consumer/commits/master/
.githubhttps://github.com/astubbs/parallel-consumer/tree/master/.github
.githubhttps://github.com/astubbs/parallel-consumer/tree/master/.github
.ideahttps://github.com/astubbs/parallel-consumer/tree/master/.idea
.ideahttps://github.com/astubbs/parallel-consumer/tree/master/.idea
.mvnhttps://github.com/astubbs/parallel-consumer/tree/master/.mvn
.mvnhttps://github.com/astubbs/parallel-consumer/tree/master/.mvn
.semaphorehttps://github.com/astubbs/parallel-consumer/tree/master/.semaphore
.semaphorehttps://github.com/astubbs/parallel-consumer/tree/master/.semaphore
binhttps://github.com/astubbs/parallel-consumer/tree/master/bin
binhttps://github.com/astubbs/parallel-consumer/tree/master/bin
docs/solutionshttps://github.com/astubbs/parallel-consumer/tree/master/docs/solutions
docs/solutionshttps://github.com/astubbs/parallel-consumer/tree/master/docs/solutions
parallel-consumer-corehttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-core
parallel-consumer-corehttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-core
parallel-consumer-exampleshttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-examples
parallel-consumer-exampleshttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-examples
parallel-consumer-mutinyhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-mutiny
parallel-consumer-mutinyhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-mutiny
parallel-consumer-reactorhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-reactor
parallel-consumer-reactorhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-reactor
parallel-consumer-vertxhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-vertx
parallel-consumer-vertxhttps://github.com/astubbs/parallel-consumer/tree/master/parallel-consumer-vertx
src/docshttps://github.com/astubbs/parallel-consumer/tree/master/src/docs
src/docshttps://github.com/astubbs/parallel-consumer/tree/master/src/docs
.editorconfighttps://github.com/astubbs/parallel-consumer/blob/master/.editorconfig
.editorconfighttps://github.com/astubbs/parallel-consumer/blob/master/.editorconfig
.gitignorehttps://github.com/astubbs/parallel-consumer/blob/master/.gitignore
.gitignorehttps://github.com/astubbs/parallel-consumer/blob/master/.gitignore
.travis-archived.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/.travis-archived.yml
.travis-archived.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/.travis-archived.yml
AGENTS.mdhttps://github.com/astubbs/parallel-consumer/blob/master/AGENTS.md
AGENTS.mdhttps://github.com/astubbs/parallel-consumer/blob/master/AGENTS.md
CHANGELOG.adochttps://github.com/astubbs/parallel-consumer/blob/master/CHANGELOG.adoc
CHANGELOG.adochttps://github.com/astubbs/parallel-consumer/blob/master/CHANGELOG.adoc
Default.xmlhttps://github.com/astubbs/parallel-consumer/blob/master/Default.xml
Default.xmlhttps://github.com/astubbs/parallel-consumer/blob/master/Default.xml
LICENSEhttps://github.com/astubbs/parallel-consumer/blob/master/LICENSE
LICENSEhttps://github.com/astubbs/parallel-consumer/blob/master/LICENSE
NOTICEhttps://github.com/astubbs/parallel-consumer/blob/master/NOTICE
NOTICEhttps://github.com/astubbs/parallel-consumer/blob/master/NOTICE
README.adochttps://github.com/astubbs/parallel-consumer/blob/master/README.adoc
README.adochttps://github.com/astubbs/parallel-consumer/blob/master/README.adoc
bisect.shhttps://github.com/astubbs/parallel-consumer/blob/master/bisect.sh
bisect.shhttps://github.com/astubbs/parallel-consumer/blob/master/bisect.sh
checkcompile.shhttps://github.com/astubbs/parallel-consumer/blob/master/checkcompile.sh
checkcompile.shhttps://github.com/astubbs/parallel-consumer/blob/master/checkcompile.sh
codecov.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/codecov.yml
codecov.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/codecov.yml
mvnwhttps://github.com/astubbs/parallel-consumer/blob/master/mvnw
mvnwhttps://github.com/astubbs/parallel-consumer/blob/master/mvnw
mvnw.cmdhttps://github.com/astubbs/parallel-consumer/blob/master/mvnw.cmd
mvnw.cmdhttps://github.com/astubbs/parallel-consumer/blob/master/mvnw.cmd
pom.xmlhttps://github.com/astubbs/parallel-consumer/blob/master/pom.xml
pom.xmlhttps://github.com/astubbs/parallel-consumer/blob/master/pom.xml
service.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/service.yml
service.ymlhttps://github.com/astubbs/parallel-consumer/blob/master/service.yml
READMEhttps://github.com/astubbs/parallel-consumer
Apache-2.0 licensehttps://github.com/astubbs/parallel-consumer
https://github.com/astubbs/parallel-consumer#kafka-parallel-consumer
https://mvnrepository.com/artifact/io.github.astubbs.parallelconsumer/parallel-consumer-parent
https://github.com/astubbs/parallel-consumer/actions/workflows/maven.yml
confluentinc/parallel-consumerhttps://github.com/confluentinc/parallel-consumer
product page for the original project is herehttps://www.confluent.io/confluent-accelerators/#parallel-consumer
Support and Issueshttps://github.com/astubbs/parallel-consumer#support-and-issues
1. When to use this library (vs KIP-932 Share Groups)https://github.com/astubbs/parallel-consumer#when-to-use
https://github.com/astubbs/parallel-consumer#1-when-to-use-this-library-vs-kip-932-share-groups
bloghttps://www.confluent.io/blog/
Introducing the Confluent Parallel Consumerhttps://www.confluent.io/blog/introducing-confluent-parallel-message-processing-client/
2. Demohttps://github.com/astubbs/parallel-consumer#demo
https://github.com/astubbs/parallel-consumer#2-demo
https://asciinema.org/a/404299
Asciinema.org playerhttps://asciinema.org/a/404299
3. Video Overviewhttps://github.com/astubbs/parallel-consumer#talk
https://github.com/astubbs/parallel-consumer#3-video-overview
https://www.confluent.io/en-gb/events/kafka-summit-europe-2021/introducing-confluent-labs-parallel-consumer-client/
from the Kafka Summit Europe 2021https://www.confluent.io/en-gb/events/kafka-summit-europe-2021/introducing-confluent-labs-parallel-consumer-client/
1. When to use this library (vs KIP-932 Share Groups)https://github.com/astubbs/parallel-consumer#when-to-use
2. Demohttps://github.com/astubbs/parallel-consumer#demo
3. Video Overviewhttps://github.com/astubbs/parallel-consumer#talk
4. Motivationhttps://github.com/astubbs/parallel-consumer#motivation
4.1. Why would I need this?https://github.com/astubbs/parallel-consumer#why-would-i-need-this
4.1.1. Beforehttps://github.com/astubbs/parallel-consumer#before
4.1.2. Afterhttps://github.com/astubbs/parallel-consumer#after
4.2. Backgroundhttps://github.com/astubbs/parallel-consumer#background
4.3. FAQhttps://github.com/astubbs/parallel-consumer#faq
4.4. Scenarioshttps://github.com/astubbs/parallel-consumer#scenarios
5. Features Listhttps://github.com/astubbs/parallel-consumer#features-list
6. Performancehttps://github.com/astubbs/parallel-consumer#performance
6.1. Illustrative Performance Examplehttps://github.com/astubbs/parallel-consumer#illustrative-performance-example
7. Support and Issueshttps://github.com/astubbs/parallel-consumer#support-and-issues
8. Licensehttps://github.com/astubbs/parallel-consumer#license
9. Usagehttps://github.com/astubbs/parallel-consumer#usage
9.1. Mavenhttps://github.com/astubbs/parallel-consumer#maven
9.2. Common Preparationhttps://github.com/astubbs/parallel-consumer#common_preparation
9.3. Corehttps://github.com/astubbs/parallel-consumer#core
9.3.1. Simple Message Processhttps://github.com/astubbs/parallel-consumer#simple-message-process
9.3.2. Process and Produce a Response Messagehttps://github.com/astubbs/parallel-consumer#process-and-produce-a-response-message
9.3.3. Callbacks vs Streamshttps://github.com/astubbs/parallel-consumer#callbacks-vs-streams
9.4. Batchinghttps://github.com/astubbs/parallel-consumer#batching
9.4.1. Usagehttps://github.com/astubbs/parallel-consumer#usage-1
9.4.2. Restrictionshttps://github.com/astubbs/parallel-consumer#restrictions
9.5. HTTP with the Vert.x Modulehttps://github.com/astubbs/parallel-consumer#http-with-vertx
9.6. Project Reactorhttps://github.com/astubbs/parallel-consumer#project-reactor
9.7. Kafka Streams Concurrent Processinghttps://github.com/astubbs/parallel-consumer#streams-usage-code
10. Upgradinghttps://github.com/astubbs/parallel-consumer#upgrading
10.1. From 0.4 to 0.5https://github.com/astubbs/parallel-consumer#from-0-4-to-0-5
11. Ordering Guaranteeshttps://github.com/astubbs/parallel-consumer#ordering-guarantees
11.1. Vanilla Kafka Consumer Operationhttps://github.com/astubbs/parallel-consumer#vanilla-kafka-consumer-operation
11.2. Unorderedhttps://github.com/astubbs/parallel-consumer#unordered
11.3. Ordered by Partitionhttps://github.com/astubbs/parallel-consumer#ordered-by-partition
11.4. Ordered by Keyhttps://github.com/astubbs/parallel-consumer#ordered-by-key
11.5. Retries and Orderinghttps://github.com/astubbs/parallel-consumer#retries-and-ordering
12. Retrieshttps://github.com/astubbs/parallel-consumer#retries
12.1. Retry Delay Functionhttps://github.com/astubbs/parallel-consumer#retry-delay-function
12.2. Skipping Recordshttps://github.com/astubbs/parallel-consumer#skipping-records
12.3. Circuit Breaker Patternhttps://github.com/astubbs/parallel-consumer#circuit-breaker-pattern
12.4. Head of Line Blockinghttps://github.com/astubbs/parallel-consumer#head-of-line-blocking
12.5. Future Workhttps://github.com/astubbs/parallel-consumer#future-work
13. Result Modelshttps://github.com/astubbs/parallel-consumer#result-models
14. Commit Modehttps://github.com/astubbs/parallel-consumer#commit-mode
14.1. Apache Kafka EoS Transaction Model in BULKhttps://github.com/astubbs/parallel-consumer#transaction-system
15. Using with Kafka Streamshttps://github.com/astubbs/parallel-consumer#streams-usage
16. Metricshttps://github.com/astubbs/parallel-consumer#mertics
16.1. Metershttps://github.com/astubbs/parallel-consumer#meters
16.1.1. Partition Managerhttps://github.com/astubbs/parallel-consumer#partition-manager
16.1.2. Processorhttps://github.com/astubbs/parallel-consumer#processor
16.1.3. Shard Managerhttps://github.com/astubbs/parallel-consumer#shard-manager
16.1.4. Work Managerhttps://github.com/astubbs/parallel-consumer#work-manager
16.1.5. Broker Pollerhttps://github.com/astubbs/parallel-consumer#broker-poller
16.1.6. Offset Encoderhttps://github.com/astubbs/parallel-consumer#offset-encoder
16.2. Example Metrics setup stepshttps://github.com/astubbs/parallel-consumer#example-metrics-setup-steps
17. Roadmaphttps://github.com/astubbs/parallel-consumer#roadmap
18. Usage Requirementshttps://github.com/astubbs/parallel-consumer#usage-requirements
19. Development Informationhttps://github.com/astubbs/parallel-consumer#development-information
19.1. Requirementshttps://github.com/astubbs/parallel-consumer#requirements
19.2. Noteshttps://github.com/astubbs/parallel-consumer#notes
19.3. Recommended IDEA Pluginshttps://github.com/astubbs/parallel-consumer#recommended-idea-plugins
19.4. Readmehttps://github.com/astubbs/parallel-consumer#readme
19.5. Maven targetshttps://github.com/astubbs/parallel-consumer#maven-targets
19.6. Build Scriptshttps://github.com/astubbs/parallel-consumer#build-scripts
19.7. Releasinghttps://github.com/astubbs/parallel-consumer#releasing
19.8. Testinghttps://github.com/astubbs/parallel-consumer#testing
19.8.1. Integration Testing with TestContainershttps://github.com/astubbs/parallel-consumer#integration-testing-with-testcontainers
20. Implementation Detailshttps://github.com/astubbs/parallel-consumer#implementation-details
20.1. Core Architecturehttps://github.com/astubbs/parallel-consumer#core-architecture
20.2. Vert.x Architecturehttps://github.com/astubbs/parallel-consumer#vert-x-architecture
20.3. Transactional System Architecturehttps://github.com/astubbs/parallel-consumer#transactional-system-architecture
20.4. Offset Maphttps://github.com/astubbs/parallel-consumer#offset_map
20.4.1. Storage Noteshttps://github.com/astubbs/parallel-consumer#storage-notes
21. Attributionhttps://github.com/astubbs/parallel-consumer#attribution
22. Toolshttps://github.com/astubbs/parallel-consumer#tools
23. Change Loghttps://github.com/astubbs/parallel-consumer#change-log
23.1. 0.6.0.0https://github.com/astubbs/parallel-consumer#0-6-0-0
23.1.1. Breakinghttps://github.com/astubbs/parallel-consumer#breaking
23.1.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes
23.1.3. Improvementshttps://github.com/astubbs/parallel-consumer#improvements
23.2. 0.5.3.4https://github.com/astubbs/parallel-consumer#0-5-3-4
23.2.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-1
23.3. 0.5.3.3https://github.com/astubbs/parallel-consumer#0-5-3-3
23.3.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-2
23.4. 0.5.3.2https://github.com/astubbs/parallel-consumer#0-5-3-2
23.4.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-3
23.4.2. Notehttps://github.com/astubbs/parallel-consumer#note
23.5. 0.5.3.1https://github.com/astubbs/parallel-consumer#0-5-3-1
23.5.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-4
23.6. 0.5.3.0https://github.com/astubbs/parallel-consumer#0-5-3-0
23.6.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-5
23.6.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-1
23.6.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies
23.7. 0.5.2.8https://github.com/astubbs/parallel-consumer#0-5-2-8
23.7.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-6
23.7.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-2
23.8. 0.5.2.7https://github.com/astubbs/parallel-consumer#0-5-2-7
23.8.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-7
23.8.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-3
23.9. 0.5.2.6https://github.com/astubbs/parallel-consumer#0-5-2-6
23.9.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-4
23.9.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-8
23.9.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies-1
23.10. 0.5.2.5https://github.com/astubbs/parallel-consumer#0-5-2-5
23.10.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-9
23.10.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-5
23.11. 0.5.2.4https://github.com/astubbs/parallel-consumer#0-5-2-4
23.11.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-6
23.11.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-10
23.12. 0.5.2.3https://github.com/astubbs/parallel-consumer#0-5-2-3
23.12.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-7
23.12.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-11
23.13. v0.5.2.2https://github.com/astubbs/parallel-consumer#v0-5-2-2
23.13.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-12
23.14. v0.5.2.1https://github.com/astubbs/parallel-consumer#v0-5-2-1
23.14.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-13
23.15. v0.5.2.0https://github.com/astubbs/parallel-consumer#v0-5-2-0
23.15.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements
23.15.2. Buildhttps://github.com/astubbs/parallel-consumer#build
23.15.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies-2
23.15.4. Linked issueshttps://github.com/astubbs/parallel-consumer#linked-issues
23.16. v0.5.1.0https://github.com/astubbs/parallel-consumer#v0-5-1-0
23.16.1. Featureshttps://github.com/astubbs/parallel-consumer#features
23.16.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-1
23.17. v0.5.0.0https://github.com/astubbs/parallel-consumer#v0-5-0-0
23.17.1. Featureshttps://github.com/astubbs/parallel-consumer#features-1
23.17.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-2
23.17.3. Buildhttps://github.com/astubbs/parallel-consumer#build-1
23.18. v0.4.0.1https://github.com/astubbs/parallel-consumer#v0-4-0-1
23.18.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-8
23.18.2. Docshttps://github.com/astubbs/parallel-consumer#docs
23.19. v0.4.0.0https://github.com/astubbs/parallel-consumer#v0-4-0-0
23.19.1. Featureshttps://github.com/astubbs/parallel-consumer#features-2
23.19.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-3
23.20. v0.3.2.0https://github.com/astubbs/parallel-consumer#v0-3-2-0
23.20.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-4
23.21. v0.3.1.0https://github.com/astubbs/parallel-consumer#v0-3-1-0
23.21.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-5
23.22. v0.3.0.3https://github.com/astubbs/parallel-consumer#v0-3-0-3
23.22.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-6
23.23. v0.3.0.2https://github.com/astubbs/parallel-consumer#v0-3-0-2
23.23.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-7
23.24. v0.3.0.1https://github.com/astubbs/parallel-consumer#v0-3-0-1
23.25. v0.3.0.0https://github.com/astubbs/parallel-consumer#v0-3-0-0
23.25.1. Featureshttps://github.com/astubbs/parallel-consumer#features-3
23.25.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-9
23.25.3. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-14
23.26. v0.2.0.3https://github.com/astubbs/parallel-consumer#v0-2-0-3
23.26.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-15
23.27. v0.2.0.2https://github.com/astubbs/parallel-consumer#v0-2-0-2
23.27.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-16
23.28. v0.2.0.1 DO NOT USE - has critical bughttps://github.com/astubbs/parallel-consumer#v0-2-0-1-do-not-use-has-critical-bug
23.28.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-17
23.29. v0.2.0.0https://github.com/astubbs/parallel-consumer#v0-2-0-0
23.29.1. Featureshttps://github.com/astubbs/parallel-consumer#features-4
23.29.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-10
23.29.3. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-18
23.30. v0.1https://github.com/astubbs/parallel-consumer#v0-1
23.30.1. Features:https://github.com/astubbs/parallel-consumer#features-5
4. Motivationhttps://github.com/astubbs/parallel-consumer#motivation
https://github.com/astubbs/parallel-consumer#4-motivation
4.1. Why would I need this?https://github.com/astubbs/parallel-consumer#why-would-i-need-this
https://github.com/astubbs/parallel-consumer#41-why-would-i-need-this
4.1.1. Beforehttps://github.com/astubbs/parallel-consumer#before
https://github.com/astubbs/parallel-consumer#411-before
https://camo.githubusercontent.com/73bd3dd6f283e93d4a2f9f0af0fff9b920552de0952f3a6f238cf1ae84169363/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f39386164323030662d393762322d343739622d393330632d3238303534393162326365372f696d6167652e706e67
4.1.2. Afterhttps://github.com/astubbs/parallel-consumer#after
https://github.com/astubbs/parallel-consumer#412-after
https://camo.githubusercontent.com/264c100cfc135743eab0b163ae43ecf35da3724dfe2c54077ddad6e756b417a7/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f32636233623765322d626664662d346537382d383234372d3232656333393464653936352f696d6167652e706e67
4.2. Backgroundhttps://github.com/astubbs/parallel-consumer#background
https://github.com/astubbs/parallel-consumer#42-background
log orderinghttps://github.com/astubbs/parallel-consumer#ordering-guarantees
Vert.x extensionhttps://github.com/astubbs/parallel-consumer#http-with-vertx
module forhttps://github.com/astubbs/parallel-consumer#project-reactor
Project Reactor.iohttps://projectreactor.io
4.3. FAQhttps://github.com/astubbs/parallel-consumer#faq
https://github.com/astubbs/parallel-consumer#43-faq
4.4. Scenarioshttps://github.com/astubbs/parallel-consumer#scenarios
https://github.com/astubbs/parallel-consumer#44-scenarios
5. Features Listhttps://github.com/astubbs/parallel-consumer#features-list
https://github.com/astubbs/parallel-consumer#5-features-list
Offset Maphttps://github.com/astubbs/parallel-consumer#offset_map
"head of line"https://en.wikipedia.org/wiki/Head-of-line_blocking
Apache Kafka EoS Transaction Model in BULKhttps://github.com/astubbs/parallel-consumer#transaction-system
circuit breakerhttps://en.wikipedia.org/wiki/Circuit_breaker_design_pattern
PR #291 Explicit terminal and retriable exceptionshttps://github.com/confluentinc/parallel-consumer/pull/291
to comehttps://github.com/astubbs/parallel-consumer#roadmap
6. Performancehttps://github.com/astubbs/parallel-consumer#performance
https://github.com/astubbs/parallel-consumer#6-performance
6.1. Illustrative Performance Examplehttps://github.com/astubbs/parallel-consumer#illustrative-performance-example
https://github.com/astubbs/parallel-consumer#61-illustrative-performance-example
VeryLargeMessageVolumeTest.javahttps://github.com/astubbs/parallel-consumer/blob/master/parallel-consumer-core/src/test-integration/java/io/confluent/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java
https://camo.githubusercontent.com/d54b88c639d71d9103d2c82b7c1783340ee935fc52bf797c6341d44d34f134dd/68747470733a2f2f646f63732e676f6f676c652e636f6d2f7370726561647368656574732f642f652f32504143582d31765166666b4146472d5f427a482d4c4b664743566e7974647a414869434e497269784d3658327646386371773259567a364b7957334c425854422d6c56617a4d414a78573055447546494c4b76744b2f70756263686172743f6f69643d3136393134373430383226666f726d61743d696d616765
https://camo.githubusercontent.com/3e1e8070da0f4478a38937ad8f046134ce8a5afe62f51ead8b2299feda59331d/68747470733a2f2f646f63732e676f6f676c652e636f6d2f7370726561647368656574732f642f652f32504143582d31765166666b4146472d5f427a482d4c4b664743566e7974647a414869434e497269784d3658327646386371773259567a364b7957334c425854422d6c56617a4d414a78573055447546494c4b76744b2f70756263686172743f6f69643d39333834393331353826666f726d61743d696d616765
https://camo.githubusercontent.com/07174a9748b8c585d2e47cdcf5de50c3287ae68d2a96935e6e5fcdedd7277fd3/68747470733a2f2f646f63732e676f6f676c652e636f6d2f7370726561647368656574732f642f652f32504143582d31765166666b4146472d5f427a482d4c4b664743566e7974647a414869434e497269784d3658327646386371773259567a364b7957334c425854422d6c56617a4d414a78573055447546494c4b76744b2f70756263686172743f6f69643d3131363133363333383526666f726d61743d696d616765
7. Support and Issueshttps://github.com/astubbs/parallel-consumer#support-and-issues
https://github.com/astubbs/parallel-consumer#7-support-and-issues
fork issue trackerhttps://github.com/astubbs/parallel-consumer/issues
issuehttps://github.com/astubbs/parallel-consumer/issues
8. Licensehttps://github.com/astubbs/parallel-consumer#license
https://github.com/astubbs/parallel-consumer#8-license
9. Usagehttps://github.com/astubbs/parallel-consumer#usage
https://github.com/astubbs/parallel-consumer#9-usage
9.1. Mavenhttps://github.com/astubbs/parallel-consumer#maven
https://github.com/astubbs/parallel-consumer#91-maven
repo1https://repo1.maven.org/maven2/io/github/astubbs/parallelconsumer/
herehttps://search.maven.org/artifact/io.github.astubbs.parallelconsumer/parallel-consumer-core
https://mvnrepository.com/artifact/io.github.astubbs.parallelconsumer/parallel-consumer-parent
9.2. Common Preparationhttps://github.com/astubbs/parallel-consumer#common_preparation
https://github.com/astubbs/parallel-consumer#92-common-preparation
issue #12https://github.com/confluentinc/parallel-consumer/issues/12
9.3. Corehttps://github.com/astubbs/parallel-consumer#core
https://github.com/astubbs/parallel-consumer#93-core
9.3.1. Simple Message Processhttps://github.com/astubbs/parallel-consumer#simple-message-process
https://github.com/astubbs/parallel-consumer#931-simple-message-process
core examplehttps://github.com/astubbs/parallel-consumer/blob/master/parallel-consumer-examples/parallel-consumer-example-core/src/main/java/io/confluent/parallelconsumer/examples/core/CoreApp.java
9.3.2. Process and Produce a Response Messagehttps://github.com/astubbs/parallel-consumer#process-and-produce-a-response-message
https://github.com/astubbs/parallel-consumer#932-process-and-produce-a-response-message
9.3.3. Callbacks vs Streamshttps://github.com/astubbs/parallel-consumer#callbacks-vs-streams
https://github.com/astubbs/parallel-consumer#933-callbacks-vs-streams
RxJavahttps://github.com/ReactiveX/RxJava
9.4. Batchinghttps://github.com/astubbs/parallel-consumer#batching
https://github.com/astubbs/parallel-consumer#94-batching
9.4.1. Usagehttps://github.com/astubbs/parallel-consumer#usage-1
https://github.com/astubbs/parallel-consumer#941-usage
9.4.2. Restrictionshttps://github.com/astubbs/parallel-consumer#restrictions
https://github.com/astubbs/parallel-consumer#942-restrictions
9.5. HTTP with the Vert.x Modulehttps://github.com/astubbs/parallel-consumer#http-with-vertx
https://github.com/astubbs/parallel-consumer#95-http-with-the-vertx-module
Vert.x examplehttps://github.com/astubbs/parallel-consumer/blob/master/parallel-consumer-examples/parallel-consumer-example-vertx/src/main/java/io/confluent/parallelconsumer/examples/vertx/VertxApp.java
9.6. Project Reactorhttps://github.com/astubbs/parallel-consumer#project-reactor
https://github.com/astubbs/parallel-consumer#96-project-reactor
Reactor examplehttps://github.com/astubbs/parallel-consumer/blob/master/parallel-consumer-examples/parallel-consumer-example-reactor/src/main/java/io/confluent/parallelconsumer/examples/reactor/ReactorApp.java
9.7. Kafka Streams Concurrent Processinghttps://github.com/astubbs/parallel-consumer#streams-usage-code
https://github.com/astubbs/parallel-consumer#97-kafka-streams-concurrent-processing
https://camo.githubusercontent.com/aeae060f1dc8b38416b80f9a8ab5f54bb82315b4934fd97ede233b84d68e51a4/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f34336632373430632d326137662d346237662d393039652d3433346135626265336662662f696d6167652e706e67
Kafka Streams examplehttps://github.com/astubbs/parallel-consumer/blob/master/parallel-consumer-examples/parallel-consumer-example-streams/src/main/java/io/confluent/parallelconsumer/examples/streams/StreamsApp.java
10. Upgradinghttps://github.com/astubbs/parallel-consumer#upgrading
https://github.com/astubbs/parallel-consumer#10-upgrading
10.1. From 0.4 to 0.5https://github.com/astubbs/parallel-consumer#from-0-4-to-0-5
https://github.com/astubbs/parallel-consumer#101-from-04-to-05
11. Ordering Guaranteeshttps://github.com/astubbs/parallel-consumer#ordering-guarantees
https://github.com/astubbs/parallel-consumer#11-ordering-guarantees
11.1. Vanilla Kafka Consumer Operationhttps://github.com/astubbs/parallel-consumer#vanilla-kafka-consumer-operation
https://github.com/astubbs/parallel-consumer#111-vanilla-kafka-consumer-operation
https://camo.githubusercontent.com/f0f106b0bdf85e82e9b2cea5e78dc1d7d9fb96ff3727540f2d9e0588ef1a2505/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f33376431333338322d333036372d346339332d623532312d3765343366323239356666662f696d6167652e706e67
https://camo.githubusercontent.com/90a6041dd869d9b24b9dff2e6b3f2256ab3b7c882b6b0c11129500d3c3d38824/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f30333635383930642d653866662d346130362d623234612d3837343131373564616363332f696d6167652e706e67
11.2. Unorderedhttps://github.com/astubbs/parallel-consumer#unordered
https://github.com/astubbs/parallel-consumer#112-unordered
https://camo.githubusercontent.com/da954df9f11cb82cd36ea8073d5d94d34b6f8b25342e87aa3d7a35c8c1e3facc/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f61616235643734332d646530352d343664302d386331652d3036343664376432393436662f696d6167652e706e67
11.3. Ordered by Partitionhttps://github.com/astubbs/parallel-consumer#ordered-by-partition
https://github.com/astubbs/parallel-consumer#113-ordered-by-partition
https://camo.githubusercontent.com/53f7177c11effb55e7321e992b0776d5882a7580f72893af6cba7df3802020d4/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f33306164383633322d653866652d346530352d386166642d6132623662336261623330392f696d6167652e706e67
11.4. Ordered by Keyhttps://github.com/astubbs/parallel-consumer#ordered-by-key
https://github.com/astubbs/parallel-consumer#114-ordered-by-key
https://camo.githubusercontent.com/356b075a2e0958f6c96043d524fbf4c57036f6bc70521bb4f2b3bcc98136c4d9/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f66376130356539392d323465362d346561332d623364302d3937386533303661613536382f696d6167652e706e67
11.5. Retries and Orderinghttps://github.com/astubbs/parallel-consumer#retries-and-ordering
https://github.com/astubbs/parallel-consumer#115-retries-and-ordering
12. Retrieshttps://github.com/astubbs/parallel-consumer#retries
https://github.com/astubbs/parallel-consumer#12-retries
Skipping Recordshttps://github.com/astubbs/parallel-consumer#skipping-records
Commit Modehttps://github.com/astubbs/parallel-consumer#commit-mode
Offset Maphttps://github.com/astubbs/parallel-consumer#offset_map
12.1. Retry Delay Functionhttps://github.com/astubbs/parallel-consumer#retry-delay-function
https://github.com/astubbs/parallel-consumer#121-retry-delay-function
enhanced retry epichttps://github.com/confluentinc/parallel-consumer/issues/65
dynamically determine the retry delayhttps://github.com/confluentinc/parallel-consumer/issues/82
12.2. Skipping Recordshttps://github.com/astubbs/parallel-consumer#skipping-records
https://github.com/astubbs/parallel-consumer#122-skipping-records
max retries featurehttps://github.com/confluentinc/parallel-consumer/issues/196
12.3. Circuit Breaker Patternhttps://github.com/astubbs/parallel-consumer#circuit-breaker-pattern
https://github.com/astubbs/parallel-consumer#123-circuit-breaker-pattern
explicit circuit breaker pattern featurehttps://github.com/confluentinc/parallel-consumer/issues/110
12.4. Head of Line Blockinghttps://github.com/astubbs/parallel-consumer#head-of-line-blocking
https://github.com/astubbs/parallel-consumer#124-head-of-line-blocking
12.5. Future Workhttps://github.com/astubbs/parallel-consumer#future-work
https://github.com/astubbs/parallel-consumer#125-future-work
Enhanced retry epic #65https://github.com/confluentinc/parallel-consumer/issues/65
Support scheduled message processing (scheduled retry)https://github.com/confluentinc/parallel-consumer/issues/48
Provide option for max retires, and a call back when reached (potential DLQ) #196https://github.com/confluentinc/parallel-consumer/issues/196
Monitor for progress and optionally shutdown (leave consumer group), skip message or send to DLQ #34https://github.com/confluentinc/parallel-consumer/issues/34
13. Result Modelshttps://github.com/astubbs/parallel-consumer#result-models
https://github.com/astubbs/parallel-consumer#13-result-models
14. Commit Modehttps://github.com/astubbs/parallel-consumer#commit-mode
https://github.com/astubbs/parallel-consumer#14-commit-mode
14.1. Apache Kafka EoS Transaction Model in BULKhttps://github.com/astubbs/parallel-consumer#transaction-system
https://github.com/astubbs/parallel-consumer#141-apache-kafka-eos-transaction-model-in-bulk
Transactional System Architecturehttps://github.com/astubbs/parallel-consumer#transactional-system-architecture
15. Using with Kafka Streamshttps://github.com/astubbs/parallel-consumer#streams-usage
https://github.com/astubbs/parallel-consumer#15-using-with-kafka-streams
KIP-311https://cwiki.apache.org/confluence/display/KAFKA/KIP-311%3A+Async+processing+with+dynamic+scheduling+in+Kafka+Streams
KIP-408https://cwiki.apache.org/confluence/display/KAFKA/KIP-408%3A+Add+Asynchronous+Processing+To+Kafka+Streams
Kafka Streams Concurrent Processinghttps://github.com/astubbs/parallel-consumer#streams-usage-code
https://camo.githubusercontent.com/aeae060f1dc8b38416b80f9a8ab5f54bb82315b4934fd97ede233b84d68e51a4/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f34336632373430632d326137662d346237662d393039652d3433346135626265336662662f696d6167652e706e67
16. Metricshttps://github.com/astubbs/parallel-consumer#mertics
https://github.com/astubbs/parallel-consumer#16-metrics
16.1. Metershttps://github.com/astubbs/parallel-consumer#meters
https://github.com/astubbs/parallel-consumer#161-meters
16.1.1. Partition Managerhttps://github.com/astubbs/parallel-consumer#partition-manager
https://github.com/astubbs/parallel-consumer#1611-partition-manager
16.1.2. Processorhttps://github.com/astubbs/parallel-consumer#processor
https://github.com/astubbs/parallel-consumer#1612-processor
16.1.3. Shard Managerhttps://github.com/astubbs/parallel-consumer#shard-manager
https://github.com/astubbs/parallel-consumer#1613-shard-manager
16.1.4. Work Managerhttps://github.com/astubbs/parallel-consumer#work-manager
https://github.com/astubbs/parallel-consumer#1614-work-manager
16.1.5. Broker Pollerhttps://github.com/astubbs/parallel-consumer#broker-poller
https://github.com/astubbs/parallel-consumer#1615-broker-poller
16.1.6. Offset Encoderhttps://github.com/astubbs/parallel-consumer#offset-encoder
https://github.com/astubbs/parallel-consumer#1616-offset-encoder
16.2. Example Metrics setup stepshttps://github.com/astubbs/parallel-consumer#example-metrics-setup-steps
https://github.com/astubbs/parallel-consumer#162-example-metrics-setup-steps
17. Roadmaphttps://github.com/astubbs/parallel-consumer#roadmap
https://github.com/astubbs/parallel-consumer#17-roadmap
CHANGELOGhttps://github.com/astubbs/parallel-consumer/blob/master/CHANGELOG.adoc
GitHub issueshttps://github.com/confluentinc/parallel-consumer/issues
Antony’s forkhttps://github.com/astubbs/parallel-consumer
18. Usage Requirementshttps://github.com/astubbs/parallel-consumer#usage-requirements
https://github.com/astubbs/parallel-consumer#18-usage-requirements
Using with Kafka Streamshttps://github.com/astubbs/parallel-consumer#streams-usage
19. Development Informationhttps://github.com/astubbs/parallel-consumer#development-information
https://github.com/astubbs/parallel-consumer#19-development-information
19.1. Requirementshttps://github.com/astubbs/parallel-consumer#requirements
https://github.com/astubbs/parallel-consumer#191-requirements
Lombokhttps://projectlombok.org/setup/intellij
pluginhttps://plugins.jetbrains.com/plugin/6317-lombok
running locally accessible Docker hosthttps://docs.docker.com/docker-for-mac/
19.2. Noteshttps://github.com/astubbs/parallel-consumer#notes
https://github.com/astubbs/parallel-consumer#192-notes
19.3. Recommended IDEA Pluginshttps://github.com/astubbs/parallel-consumer#recommended-idea-plugins
https://github.com/astubbs/parallel-consumer#193-recommended-idea-plugins
19.4. Readmehttps://github.com/astubbs/parallel-consumer#readme
https://github.com/astubbs/parallel-consumer#194-readme
custom maven processor pluginhttps://github.com/whelk-io/asciidoc-template-maven-plugin/pull/25
doesn’t properly support the include directivehttps://github.com/github/markup/issues/1095
.//src/docs/README_TEMPLATE.adochttps://github.com/astubbs/parallel-consumer/blob/master/src/docs/README_TEMPLATE.adoc
19.5. Maven targetshttps://github.com/astubbs/parallel-consumer#maven-targets
https://github.com/astubbs/parallel-consumer#195-maven-targets
issue #162https://github.com/confluentinc/parallel-consumer/issues/162
Stack Overflow questionhttps://stackoverflow.com/questions/4786881/why-is-test-jar-dependency-required-for-mvn-compile
19.6. Build Scriptshttps://github.com/astubbs/parallel-consumer#build-scripts
https://github.com/astubbs/parallel-consumer#196-build-scripts
19.7. Releasinghttps://github.com/astubbs/parallel-consumer#releasing
https://github.com/astubbs/parallel-consumer#197-releasing
19.8. Testinghttps://github.com/astubbs/parallel-consumer#testing
https://github.com/astubbs/parallel-consumer#198-testing
19.8.1. Integration Testing with TestContainershttps://github.com/astubbs/parallel-consumer#integration-testing-with-testcontainers
https://github.com/astubbs/parallel-consumer#1981-integration-testing-with-testcontainers
Testcontainershttps://testcontainers.org
~/.testcontainers.properties filehttps://www.testcontainers.org/features/configuration/
singleton container patternhttps://www.testcontainers.org/test_framework_integration/manual_lifecycle_control/#singleton-containers
this testcontainers PRhttps://github.com/testcontainers/testcontainers-java/pull/1781
20. Implementation Detailshttps://github.com/astubbs/parallel-consumer#implementation-details
https://github.com/astubbs/parallel-consumer#20-implementation-details
20.1. Core Architecturehttps://github.com/astubbs/parallel-consumer#core-architecture
https://github.com/astubbs/parallel-consumer#201-core-architecture
https://camo.githubusercontent.com/afa406588ced3498e758346fa22c9b795db6d8acd02e7b2041cd69fd4b01be39/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f33323064393234612d363531372d346335342d613732652d6231633462323265353965642f696d6167652e706e67
20.2. Vert.x Architecturehttps://github.com/astubbs/parallel-consumer#vert-x-architecture
https://github.com/astubbs/parallel-consumer#202-vertx-architecture
verticleshttps://vertx.io/docs/vertx-core/java/#_verticles
https://camo.githubusercontent.com/9604b22ed6b13142a9b39fd39d1dfadfb8eda811ff5c2c165e9e714cb8764d96/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f35303964663431302d353939372d343662652d393865372d6163376632343137383062342f696d6167652e706e67
20.3. Transactional System Architecturehttps://github.com/astubbs/parallel-consumer#transactional-system-architecture
https://github.com/astubbs/parallel-consumer#203-transactional-system-architecture
https://camo.githubusercontent.com/3beb2c9c47178924a99b67abe948e6e0ba75127afefe2b5bd8d56e7d6f123ae1/68747470733a2f2f6c756369642e6170702f7075626c69635365676d656e74732f766965772f37343830643934382d656437642d343337302d613330382d3865633132653662343533622f696d6167652e706e67
20.4. Offset Maphttps://github.com/astubbs/parallel-consumer#offset_map
https://github.com/astubbs/parallel-consumer#204-offset-map
ordering modehttps://github.com/astubbs/parallel-consumer#ordering-guarantees
20.4.1. Storage Noteshttps://github.com/astubbs/parallel-consumer#storage-notes
https://github.com/astubbs/parallel-consumer#2041-storage-notes
Exact continuous offset encoding for precise offset payload size back pressurehttps://github.com/confluentinc/parallel-consumer/issues/53
FAQhttps://github.com/astubbs/parallel-consumer#faq-1
https://github.com/astubbs/parallel-consumer#faq
#415https://github.com/confluentinc/parallel-consumer/issues/415#issuecomment-1256022394
#415https://github.com/confluentinc/parallel-consumer/issues/415#issuecomment-1256022394
21. Attributionhttps://github.com/astubbs/parallel-consumer#attribution
https://github.com/astubbs/parallel-consumer#21-attribution
Apache®http://www.apache.org/
Apache Kafkahttp://kafka.apache.org/
Kafka®http://kafka.apache.org/
Apache Software Foundationhttp://www.apache.org/
22. Toolshttps://github.com/astubbs/parallel-consumer#tools
https://github.com/astubbs/parallel-consumer#22-tools
https://www.yourkit.com/java/profiler/index.jsp
YourKit Java Profilerhttps://www.google.com/url?q=https://www.yourkit.com/java/profiler/&source=gmail-imap&ust=1670918364000000&usg=AOvVaw3kaQak_H7lmT_plCEzxvde
YourKit .NET Profilerhttps://www.google.com/url?q=https://www.yourkit.com/.net/profiler/&source=gmail-imap&ust=1670918364000000&usg=AOvVaw1ZgQhyH2rIOHTuqtTjFAsA
YourKit YouMonitorhttps://www.google.com/url?q=https://www.yourkit.com/youmonitor/&source=gmail-imap&ust=1670918364000000&usg=AOvVaw13UzOhGkJLEn-Md3-GNjYB
23. Change Loghttps://github.com/astubbs/parallel-consumer#change-log
https://github.com/astubbs/parallel-consumer#23-change-log
23.1. 0.6.0.0https://github.com/astubbs/parallel-consumer#0-6-0-0
https://github.com/astubbs/parallel-consumer#231-0600
23.1.1. Breakinghttps://github.com/astubbs/parallel-consumer#breaking
https://github.com/astubbs/parallel-consumer#2311-breaking
23.1.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes
https://github.com/astubbs/parallel-consumer#2312-fixes
23.1.3. Improvementshttps://github.com/astubbs/parallel-consumer#improvements
https://github.com/astubbs/parallel-consumer#2313-improvements
23.2. 0.5.3.4https://github.com/astubbs/parallel-consumer#0-5-3-4
https://github.com/astubbs/parallel-consumer#232-0534
23.2.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-1
https://github.com/astubbs/parallel-consumer#2321-fixes
23.3. 0.5.3.3https://github.com/astubbs/parallel-consumer#0-5-3-3
https://github.com/astubbs/parallel-consumer#233-0533
23.3.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-2
https://github.com/astubbs/parallel-consumer#2331-fixes
23.4. 0.5.3.2https://github.com/astubbs/parallel-consumer#0-5-3-2
https://github.com/astubbs/parallel-consumer#234-0532
23.4.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-3
https://github.com/astubbs/parallel-consumer#2341-fixes
23.4.2. Notehttps://github.com/astubbs/parallel-consumer#note
https://github.com/astubbs/parallel-consumer#2342-note
23.5. 0.5.3.1https://github.com/astubbs/parallel-consumer#0-5-3-1
https://github.com/astubbs/parallel-consumer#235-0531
23.5.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-4
https://github.com/astubbs/parallel-consumer#2351-fixes
23.6. 0.5.3.0https://github.com/astubbs/parallel-consumer#0-5-3-0
https://github.com/astubbs/parallel-consumer#236-0530
23.6.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-5
https://github.com/astubbs/parallel-consumer#2361-fixes
23.6.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-1
https://github.com/astubbs/parallel-consumer#2362-improvements
23.6.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies
https://github.com/astubbs/parallel-consumer#2363-dependencies
23.7. 0.5.2.8https://github.com/astubbs/parallel-consumer#0-5-2-8
https://github.com/astubbs/parallel-consumer#237-0528
23.7.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-6
https://github.com/astubbs/parallel-consumer#2371-fixes
23.7.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-2
https://github.com/astubbs/parallel-consumer#2372-improvements
23.8. 0.5.2.7https://github.com/astubbs/parallel-consumer#0-5-2-7
https://github.com/astubbs/parallel-consumer#238-0527
23.8.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-7
https://github.com/astubbs/parallel-consumer#2381-fixes
23.8.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-3
https://github.com/astubbs/parallel-consumer#2382-improvements
23.9. 0.5.2.6https://github.com/astubbs/parallel-consumer#0-5-2-6
https://github.com/astubbs/parallel-consumer#239-0526
23.9.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-4
https://github.com/astubbs/parallel-consumer#2391-improvements
23.9.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-8
https://github.com/astubbs/parallel-consumer#2392-fixes
23.9.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies-1
https://github.com/astubbs/parallel-consumer#2393-dependencies
23.10. 0.5.2.5https://github.com/astubbs/parallel-consumer#0-5-2-5
https://github.com/astubbs/parallel-consumer#2310-0525
23.10.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-9
https://github.com/astubbs/parallel-consumer#23101-fixes
23.10.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-5
https://github.com/astubbs/parallel-consumer#23102-improvements
23.11. 0.5.2.4https://github.com/astubbs/parallel-consumer#0-5-2-4
https://github.com/astubbs/parallel-consumer#2311-0524
23.11.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-6
https://github.com/astubbs/parallel-consumer#23111-improvements
23.11.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-10
https://github.com/astubbs/parallel-consumer#23112-fixes
23.12. 0.5.2.3https://github.com/astubbs/parallel-consumer#0-5-2-3
https://github.com/astubbs/parallel-consumer#2312-0523
23.12.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-7
https://github.com/astubbs/parallel-consumer#23121-improvements
23.12.2. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-11
https://github.com/astubbs/parallel-consumer#23122-fixes
23.13. v0.5.2.2https://github.com/astubbs/parallel-consumer#v0-5-2-2
https://github.com/astubbs/parallel-consumer#2313-v0522
23.13.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-12
https://github.com/astubbs/parallel-consumer#23131-fixes
23.14. v0.5.2.1https://github.com/astubbs/parallel-consumer#v0-5-2-1
https://github.com/astubbs/parallel-consumer#2314-v0521
23.14.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-13
https://github.com/astubbs/parallel-consumer#23141-fixes
23.15. v0.5.2.0https://github.com/astubbs/parallel-consumer#v0-5-2-0
https://github.com/astubbs/parallel-consumer#2315-v0520
23.15.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements
https://github.com/astubbs/parallel-consumer#23151-fixes-and-improvements
23.15.2. Buildhttps://github.com/astubbs/parallel-consumer#build
https://github.com/astubbs/parallel-consumer#23152-build
23.15.3. Dependencieshttps://github.com/astubbs/parallel-consumer#dependencies-2
https://github.com/astubbs/parallel-consumer#23153-dependencies
23.15.4. Linked issueshttps://github.com/astubbs/parallel-consumer#linked-issues
https://github.com/astubbs/parallel-consumer#23154-linked-issues
23.16. v0.5.1.0https://github.com/astubbs/parallel-consumer#v0-5-1-0
https://github.com/astubbs/parallel-consumer#2316-v0510
23.16.1. Featureshttps://github.com/astubbs/parallel-consumer#features
https://github.com/astubbs/parallel-consumer#23161-features
23.16.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-1
https://github.com/astubbs/parallel-consumer#23162-fixes-and-improvements
23.17. v0.5.0.0https://github.com/astubbs/parallel-consumer#v0-5-0-0
https://github.com/astubbs/parallel-consumer#2317-v0500
23.17.1. Featureshttps://github.com/astubbs/parallel-consumer#features-1
https://github.com/astubbs/parallel-consumer#23171-features
23.17.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-2
https://github.com/astubbs/parallel-consumer#23172-fixes-and-improvements
Truth Generatorhttps://github.com/astubbs/truth-generator
Google Truthhttps://truth.dev/
23.17.3. Buildhttps://github.com/astubbs/parallel-consumer#build-1
https://github.com/astubbs/parallel-consumer#23173-build
23.18. v0.4.0.1https://github.com/astubbs/parallel-consumer#v0-4-0-1
https://github.com/astubbs/parallel-consumer#2318-v0401
23.18.1. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-8
https://github.com/astubbs/parallel-consumer#23181-improvements
23.18.2. Docshttps://github.com/astubbs/parallel-consumer#docs
https://github.com/astubbs/parallel-consumer#23182-docs
23.19. v0.4.0.0https://github.com/astubbs/parallel-consumer#v0-4-0-0
https://github.com/astubbs/parallel-consumer#2319-v0400
23.19.1. Featureshttps://github.com/astubbs/parallel-consumer#features-2
https://github.com/astubbs/parallel-consumer#23191-features
Project Reactorhttps://projectreactor.io/
23.19.2. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-3
https://github.com/astubbs/parallel-consumer#23192-fixes-and-improvements
23.20. v0.3.2.0https://github.com/astubbs/parallel-consumer#v0-3-2-0
https://github.com/astubbs/parallel-consumer#2320-v0320
23.20.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-4
https://github.com/astubbs/parallel-consumer#23201-fixes-and-improvements
23.21. v0.3.1.0https://github.com/astubbs/parallel-consumer#v0-3-1-0
https://github.com/astubbs/parallel-consumer#2321-v0310
23.21.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-5
https://github.com/astubbs/parallel-consumer#23211-fixes-and-improvements
23.22. v0.3.0.3https://github.com/astubbs/parallel-consumer#v0-3-0-3
https://github.com/astubbs/parallel-consumer#2322-v0303
23.22.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-6
https://github.com/astubbs/parallel-consumer#23221-fixes-and-improvements
Overviewhttps://github.com/astubbs/parallel-consumer#overview
https://github.com/astubbs/parallel-consumer#overview
Details:https://github.com/astubbs/parallel-consumer#details
https://github.com/astubbs/parallel-consumer#details
23.23. v0.3.0.2https://github.com/astubbs/parallel-consumer#v0-3-0-2
https://github.com/astubbs/parallel-consumer#2323-v0302
23.23.1. Fixes and Improvementshttps://github.com/astubbs/parallel-consumer#fixes-and-improvements-7
https://github.com/astubbs/parallel-consumer#23231-fixes-and-improvements
23.24. v0.3.0.1https://github.com/astubbs/parallel-consumer#v0-3-0-1
https://github.com/astubbs/parallel-consumer#2324-v0301
23.25. v0.3.0.0https://github.com/astubbs/parallel-consumer#v0-3-0-0
https://github.com/astubbs/parallel-consumer#2325-v0300
23.25.1. Featureshttps://github.com/astubbs/parallel-consumer#features-3
https://github.com/astubbs/parallel-consumer#23251-features
#47https://github.com/confluentinc/parallel-consumer/issues/47
23.25.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-9
https://github.com/astubbs/parallel-consumer#23252-improvements
Support BitSet encoding lengths longer than Short.MAX_VALUE #37https://github.com/confluentinc/parallel-consumer/issues/37
23.25.3. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-14
https://github.com/astubbs/parallel-consumer#23253-fixes
23.26. v0.2.0.3https://github.com/astubbs/parallel-consumer#v0-2-0-3
https://github.com/astubbs/parallel-consumer#2326-v0203
23.26.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-15
https://github.com/astubbs/parallel-consumer#23261-fixes
Bitset overflow check (#35)https://github.com/confluentinc/parallel-consumer/issues/35
Support BitSet encoding lengths longer than Short.MAX_VALUE #37https://github.com/confluentinc/parallel-consumer/issues/37
23.27. v0.2.0.2https://github.com/astubbs/parallel-consumer#v0-2-0-2
https://github.com/astubbs/parallel-consumer#2327-v0202
23.27.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-16
https://github.com/astubbs/parallel-consumer#23271-fixes
Bitset overflow check (#35)https://github.com/confluentinc/parallel-consumer/issues/35
23.28. v0.2.0.1 DO NOT USE - has critical bughttps://github.com/astubbs/parallel-consumer#v0-2-0-1-do-not-use-has-critical-bug
https://github.com/astubbs/parallel-consumer#2328-v0201-do-not-use---has-critical-bug
23.28.1. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-17
https://github.com/astubbs/parallel-consumer#23281-fixes
offset serialisation system (#35)https://github.com/confluentinc/parallel-consumer/issues/35
23.29. v0.2.0.0https://github.com/astubbs/parallel-consumer#v0-2-0-0
https://github.com/astubbs/parallel-consumer#2329-v0200
23.29.1. Featureshttps://github.com/astubbs/parallel-consumer#features-4
https://github.com/astubbs/parallel-consumer#23291-features
23.29.2. Improvementshttps://github.com/astubbs/parallel-consumer#improvements-10
https://github.com/astubbs/parallel-consumer#23292-improvements
23.29.3. Fixeshttps://github.com/astubbs/parallel-consumer#fixes-18
https://github.com/astubbs/parallel-consumer#23293-fixes
confluentinc#25https://github.com/confluentinc/parallel-consumer/issues/25
23.30. v0.1https://github.com/astubbs/parallel-consumer#v0-1
https://github.com/astubbs/parallel-consumer#2330-v01
23.30.1. Features:https://github.com/astubbs/parallel-consumer#features-5
https://github.com/astubbs/parallel-consumer#23301-features
Readme https://github.com/astubbs/parallel-consumer#readme-ov-file
Apache-2.0 license https://github.com/astubbs/parallel-consumer#Apache-2.0-1-ov-file
Please reload this pagehttps://github.com/astubbs/parallel-consumer
Activityhttps://github.com/astubbs/parallel-consumer/activity
3 forkshttps://github.com/astubbs/parallel-consumer/forks
Report repository https://github.com/contact/report-content?content_url=https%3A%2F%2Fgithub.com%2Fastubbs%2Fparallel-consumer&report=astubbs+%28user%29
Releaseshttps://github.com/astubbs/parallel-consumer/releases
19 tags https://github.com/astubbs/parallel-consumer/tags
Packages 0https://github.com/users/astubbs/packages?repo_name=parallel-consumer
Please reload this pagehttps://github.com/astubbs/parallel-consumer
Please reload this pagehttps://github.com/astubbs/parallel-consumer
Contributorshttps://github.com/astubbs/parallel-consumer/graphs/contributors
Please reload this pagehttps://github.com/astubbs/parallel-consumer
https://github.com
Termshttps://docs.github.com/site-policy/github-terms/github-terms-of-service
Privacyhttps://docs.github.com/site-policy/privacy-policies/github-privacy-statement
Securityhttps://github.com/security
Statushttps://www.githubstatus.com/
Communityhttps://github.community/
Docshttps://docs.github.com/
Contacthttps://support.github.com?tags=dotcom-footer

Viewport: width=device-width


URLs of crawlers that visited me.