vamossagar12 opened a new pull request, #15594: URL: https://github.com/apache/kafka/pull/15594
Main changes: 1. Parameterizes the tests to use new coordinator and pass in consumer group protocol. This would be applicable to sink connectors only. 2. Enhances the sink connector creation code in system tests to accept a new optional parameter for consumer group protocol to be used. 3. Sets the consumer group protocol via `consumer.override.` override config which gets passed to the consumer. -- 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
