MINOR: fix flaky Streams EOS system test
Reviewer: Guozhang Wang Bill Bejeck
@@ -159,7 +159,7 @@ class StreamsEosTest(KafkaTest):
def wait_for_startup(self, monitor, processor):
self.wait_for(monitor, processor, "StateChange: REBALANCING -> RUNNING")
- self.wait_for(monitor, processor, "processed 500 records from topic=data")
+ self.wait_for(monitor, processor, "processed 500 records from topic")
def wait_for(self, monitor, processor, output):
monitor.wait_until(output,
