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

Run user defined react function in provided scheduler #797

Closed rkolesnev closed 2 weeks ago

rkolesnev commented 2 weeks ago

Merge of PR (#794) This contribution fixes the issue described here https://github.com/confluentinc/parallel-consumer/issues/793

Checklist