issues
search
confluentinc
/
parallel-consumer
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.
https://confluent.io/confluent-accelerators/#parallel-consumer
Apache License 2.0
689
stars
117
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Sporadic timeouts from ConsumerOffsetCommitter.CommitRequest
#809
tedcaozoom
opened
3 days ago
4
remove publish auto-promotion
#807
rkolesnev
closed
2 weeks ago
0
Revert release update script path
#806
rkolesnev
closed
2 weeks ago
0
Backout release add ossrh handling
#805
rkolesnev
closed
2 weeks ago
0
Transactional Producer instance gets timeout getting commit lock while second instance starts
#803
PatrickChauveau
opened
2 weeks ago
3
Fix: update vault secret and revert release 0.5.3.0 prep commits
#802
rkolesnev
closed
2 weeks ago
0
dont do release:perform in release task - its part of deploy
#801
rkolesnev
closed
2 weeks ago
0
push changes on release prepare steps
#800
rkolesnev
closed
2 weeks ago
0
change version in changelog / readme for 0.5.3.0 release
#799
rkolesnev
closed
2 weeks ago
0
Run used-defined function in provided scheduler rather than in pc-pool thread
#798
rkolesnev
closed
2 weeks ago
0
Run user defined react function in provided scheduler
#797
rkolesnev
closed
2 weeks ago
0
regenerate readme from template/changelog
#796
rkolesnev
closed
2 weeks ago
1
Add wait cycles in a test to help de-flake it.
#795
rkolesnev
closed
2 weeks ago
0
Run used-defined function in provided scheduler rather than in `pc-pool` thread
#794
yevheniisemenov
closed
2 weeks ago
5
ReactorProcessor executes a user-provided function in a thread from the pc-pool rather than in the provided scheduler
#793
yevheniisemenov
closed
2 weeks ago
5
chore: update repo by service bot
#792
ConfluentJenkins
closed
2 weeks ago
2
Move tasks block into semaphore block in service.yml
#791
rkolesnev
closed
3 weeks ago
0
Release of 0.5.2.9
#790
bernardmo
closed
3 weeks ago
1
fix issue #787 for cannot close and exit properly when rebalancing storm
#789
sangreal
closed
3 weeks ago
4
update semaphore release related commands
#788
rkolesnev
closed
3 weeks ago
0
Cannot exit and close when there are rebalancing storm
#787
sangreal
closed
2 weeks ago
6
Bump org.apache.maven.plugins:maven-site-plugin from 4.0.0-M13 to 4.0.0-M15
#786
dependabot[bot]
opened
3 weeks ago
0
Bump org.apache.maven.plugins:maven-javadoc-plugin from 3.5.0 to 3.7.0
#785
dependabot[bot]
opened
3 weeks ago
0
Update CODEOWNERS
#784
johnbyrnejb
closed
3 weeks ago
1
add release pipeline for semaphore
#783
rkolesnev
closed
3 weeks ago
0
Seeking to a specific offset for a partition
#782
ebrockman1
opened
4 weeks ago
5
Bump com.github.tomakehurst:wiremock-jre8 from 2.35.1 to 2.35.2
#781
dependabot[bot]
opened
4 weeks ago
0
Bump org.sonatype.plugins:nexus-staging-maven-plugin from 1.6.13 to 1.7.0
#780
dependabot[bot]
opened
4 weeks ago
0
stale containers exclusion and handling improvement
#779
sangreal
closed
2 weeks ago
7
Handling Partition Revocation in Parallel-Consumer Leading to Duplicate Event Processing
#777
ajax-levashov-m
opened
1 month ago
2
Bump org.apache.maven.plugins:maven-site-plugin from 4.0.0-M13 to 4.0.0-M14
#776
dependabot[bot]
closed
3 weeks ago
2
Support Kafka-clients:3.7.0
#775
dumontxiong
closed
1 month ago
1
Bump io.micrometer:micrometer-core from 1.12.2 to 1.13.0
#773
dependabot[bot]
closed
4 weeks ago
1
Bump mockito.version from 5.10.0 to 5.12.0
#772
dependabot[bot]
closed
1 month ago
0
build(deps-dev): bump junit.platform.version from 1.10.1 to 1.10.2
#771
dependabot[bot]
closed
1 month ago
0
build(deps): bump org.apache.maven.plugins:maven-deploy-plugin from 3.1.1 to 3.1.2
#770
dependabot[bot]
closed
1 month ago
0
build(deps): bump testcontainers.version from 1.19.3 to 1.19.8
#769
dependabot[bot]
closed
4 weeks ago
1
build(deps): bump junit.version from 5.10.1 to 5.10.2
#768
dependabot[bot]
closed
1 month ago
0
docs: readme - move changes in #735 into template
#767
rkolesnev
closed
1 month ago
0
Question: How to limit message consumption at a certain RPS?
#766
IshankGulati
closed
1 month ago
3
Fix redundant rebalance callback in `LongPollingMockConsumer` for Kafka >= 3.6
#765
nscuro
closed
1 month ago
1
Remove redundant line in the React example
#764
maksmas
closed
1 month ago
6
Can all subscribers share one user-function threadpool?
#763
dumontxiong
closed
1 month ago
2
Fix failing auto-commit check for kafka-clients >= v3.7.0
#762
nscuro
closed
1 month ago
17
build(deps): bump com.google.guava:guava from 32.1.1-jre to 33.2.0-jre
#761
dependabot[bot]
closed
1 month ago
1
Remove Jenkinsfile as Jenkins CI jobs are migrated to Semaphore
#760
rkolesnev
closed
1 month ago
0
Fix/public ci job
#759
rkolesnev
closed
1 month ago
0
fix: NullPointerException on partitions revoked (#757)
#758
sangreal
closed
1 month ago
8
NullPointerException on partitions revoked
#757
Amoratinos
closed
1 month ago
4
build(deps): bump org.slf4j:slf4j-api from 2.0.7 to 2.0.13
#755
dependabot[bot]
closed
1 month ago
2
Next