lucasbru opened a new pull request, #20419:
URL: https://github.com/apache/kafka/pull/20419

   What I observed is that if I run both combinations useNewProtocol=true, 
useNewProtocol=false it would often fail the second time, but if I only run the 
second variation useNewProtocol=false it works, and only the first variation 
useNewProtocol=true also works. So this points to some state that is not 
cleared between the tests  - and indeed, the test creates a topic “inputTopic”, 
produces to it, but doesn’t delete it, so the second variation will run with 
produce to it again and then run with twice the data.
   
   I also reduced heartbeat interval and session timeout since some of the 
tests need to wait for the old consumer to leave which (sigh) Kafka Streams 
doesn't do, so we have to wait that it gets kicked out by session timeout. So 
previously we waited for 45 seconds, now, we at least wait only 1 second.
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to