parallel-consumer
parallel-consumer copied to clipboard
confluentinc
Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
Bumps [me.tongfei:progressbar](https://github.com/ctongfei/progressbar) from 0.10.0 to 0.10.1. Release notes Sourced from me.tongfei:progressbar's releases. 0.10.1 Improvements: Changed the JPMS module dependency org.jline to a more fine-grained module org.jline.terminal (#158, PR #159). Thanks...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
a PR that resolves the good to go issue #622 . If you have any other suggestions, please feel free to let me know. ### Checklist - [x] Documentation (if...
This project doesn't owe me/us anything, but I feel at this point it is justified to raise an issue for this. Effectively this is also the subject of this discussion...
When trying to run the tests, I encountered an error because the class io.confluent.parallelconsumer.ManagedTruth (specifically referencing assertThat) could not be found. This prevents the tests from running. Error details: It...
## Context Currently, `ParallelConsumerOptions` class offers the ability to pass a JNDI name for custom implementations for the Thread executor service and thread factory (`managedExecutorService` and `managedThreadFactory` respectively). Java 21...
My team is using parallel-consumer in production, and we observed increasing memory usage over time in all of our services. After monitoring the heap, we found that this stack trace...
I am using the library v5.3.0 and i noticed that same record is being picked up by different threads of the same pod almost at the same time. It is...
Problem - Missing topic and offset infos when login error in ConsumerOffsetCommitter Solution - add topic and offsets info into the error log in ConsumerOffsetCommitter
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...
![renovatebot-confluentinc[bot] avatar](https://avatars.githubusercontent.com/u/9439498?v=4 "renovatebot-confluentinc[bot] avatar"){kind=avatar}
Metadata
Owner
Metadata
Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.