jolshan commented on a change in pull request #10282:
URL: https://github.com/apache/kafka/pull/10282#discussion_r598142963
##########
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##########
@@ -1892,8 +1892,9 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boolean, dynamicConfigO
}
}
+ // Topic IDs are used with all self-managed quorum clusters and ZK cluster
with IBP greater than or equal to 2.8
def usesTopicId: Boolean =
Review comment:
Hmmm. In that case would we be going to an old version that doesn't
support topic IDs though and this behavior is expected? I think the main reason
I wanted to differentiate was so a client would know not to keep trying the
request with topic IDs on an old version. But maybe this is not common enough
to support this error.
--
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
