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.
JavaApache-2.0
Issues
- 3
- 4
NullPointerException on partitions revoked
#757 opened by Amoratinos - 2
- 7
- 4
Concurrent modification exception when closing
#723 opened by krvajal - 4
- 6
Missing feature to terminate processing
#718 opened by Zordid - 0
- 1
- 2
- 0
Wrong multiplier value in retry delay function example
#622 opened by zerda - 0
Warning log to verbose in RemovedPartitionState
#631 opened by bmaggi - 0
- 1
- 3
Release 0.5.2.8 to Maven
#679 opened by C0mbatwombat - 9
The ParallelStreamProcessor closing problem
#685 opened by Satrix - 3
parallel-consumer-example-core failing
#678 opened by tsuz - 7
Offset map data too large warnings
#647 opened by botPotyo - 2
Parallel Consumer stops processing
#680 opened by anoop-bicycle - 4
Batching not working as expected
#551 opened by dixitsingla - 22
Truncating state
#546 opened by lennehendrickx - 5
When parallel consumer does not close kafka consumer if commmit fails during close
#597 opened by BartoszSta - 4
Interrupted exception during shutdown
#668 opened by JorgenRingen - 3
Consumer is not able to poll and process valid messages when a lot of invalid messages occurred
#582 opened by kapmati - 2
- 1
onOffsetCommitSuccess always cleans partition, even if another work was completed.
#664 opened by zwendris - 2
parallelConsumer.close() is timing out in 0.5.2.6 and 0.5.2.7 for consumer with set producer, after rebalace
#648 opened by BartoszSta - 11
Parrallel consumer stuck in infinite rebalance
#637 opened by bmaggi - 4
- 4
Is There Any Exception Handler?
#550 opened by 10000-ki - 1
ByteArray key parallelism is not working as expected
#579 opened by larinje - 0
Add explanation of close modes to documentation
#642 opened by rkolesnev - 3
Error when making a POST request with vertx
#600 opened by JonaCaste - 2
- 13
- 0
- 3
Metrics error with 0.5.2.6
#618 opened by makghub9 - 7
Parallel consumer stops processing data sometimes
#606 opened by bdeneuter - 3
How to kill the thread pc-broker-poll
#608 opened by Amerousful - 4
- 2
- 2
No methor found : groupMetaData | org.apache.kafka.clients.consumer.ConsumerGroupMetadata
#573 opened by dixitsingla - 3
0.5.2.6 not published to Maven
#605 opened by ryan-clancy - 1
I can see two dependencies in https://mvnrepository.com/ - which one is correct.
#592 opened by dixitsingla - 2
- 6
- 1
Consumer hangs while polling
#576 opened by shaileshkulkarni - 2
Question: I encountered message loss, how can I check when & where did the offset was commited ?
#565 opened by flodetan - 2
Parallel consumer doesn't process any more records due to incorrect management of work
#547 opened by RaviKalasapur - 0
Why use of Scheduler if the processing has been proven NON blocking please?
#543 opened by patpatpat123