mirror of https://github.com/apache/kafka.git
Revert removal of contains() from CompletableEventReaper
This commit is contained in:
parent
99304db9e8
commit
702b25753b
|
|
@ -156,6 +156,10 @@ public class CompletableEventReaper {
|
|||
return tracked.size();
|
||||
}
|
||||
|
||||
public boolean contains(CompletableEvent<?> event) {
|
||||
return event != null && tracked.contains(event);
|
||||
}
|
||||
|
||||
public List<CompletableEvent<?>> uncompletedEvents() {
|
||||
// The following code does not use the Java Collections Streams API to reduce overhead in the critical
|
||||
// path of the ConsumerNetworkThread loop.
|
||||
|
|
|
|||
Loading…
Reference in New Issue