lucasbru commented on code in PR #19230:
URL: https://github.com/apache/kafka/pull/19230#discussion_r2010255687
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java:
##########
@@ -59,6 +62,10 @@
*/
public class StreamsGroupHeartbeatRequestManager implements RequestManager {
+ private static final String UNSUPPORTED_VERSION_ERROR_MESSAGE = "The
cluster does not support the new STREAMS group protocol. Set " +
Review Comment:
Yes, that's what I meant. We shouldn't imply that the RPCs aren't supported
'yet'.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
