kafka
kafka copied to clipboard
KAFKA-19402: Typo in EventAccumulator.java
Current comment on that class: A concurrent event accumulator which group events per key and ensure that only one event with a given key can't be processed concurrently.
To my understanding, it should be ensure that only one event with a given key can be processed concurrently.