Meine dispatcher says there's something wrong mit deine Kabel. Java 8 BlockingQueue Kafka Consumer with automatically maintained offset.
7
stars
3
forks
source link
Expose stopped from Processor for easier testing #8
Closed
dhiller closed 7 years ago
To better support testing we would export the property
Processor.isStopped()so we can verify that the processor stops on the right conditions.