Run used-defined function in provided scheduler rather than in pc-pool thread

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

76 stars 125 forks source link

Run used-defined function in provided scheduler rather than in pc-pool thread #798

Closed rkolesnev closed 3 months ago

rkolesnev commented 3 months ago

Merge of PR #794 by yevheniisemenov Fixes the issue described here #793

Checklist

[ ] Documentation (if applicable)
[x] Changelog