showuon commented on pull request #10736: URL: https://github.com/apache/kafka/pull/10736#issuecomment-850119016
1 more thing to add, because I can still see ``` reason: removing member KTable-FKJ-Multi-98311d03-31f2-4b20-bfcf-0cfc516741f5-StreamThread-1-consumer-06247087-0bc9-4f74-b0a4-a617c638e427 on heartbeat expiration ``` So, the session timeout increasing is to avoid this unexpected rebalancing happen, to make the test reliable. I think it makes sense. Just concerning the data lost issue mentioned above. Thank you. -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org