This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 462c89e KAFKA-12211: don't change perm for base/state dir when no
persistent store (#9904)
add 86b9fde KAFKA-10869: Gate topic IDs behind IBP 2.8 (KIP-516) (#9814)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/api/ApiVersion.scala | 2 +-
.../controller/ControllerChannelManager.scala | 4 +-
.../scala/kafka/controller/KafkaController.scala | 12 ++-
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 5 +-
.../main/scala/kafka/server/ZkAdminManager.scala | 2 +-
core/src/main/scala/kafka/zk/AdminZkClient.scala | 21 ++--
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 22 ++--
core/src/main/scala/kafka/zk/ZkData.scala | 4 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 2 +-
.../controller/ControllerIntegrationTest.scala | 119 ++++++++++++++++++++-
.../kafka/security/auth/ZkAuthorizationTest.scala | 2 +-
.../TopicIdWithOldInterBrokerProtocolTest.scala | 66 ++++++++++++
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 12 +--
tests/kafkatest/services/kafka/kafka.py | 32 ++++++
tests/kafkatest/tests/core/downgrade_test.py | 8 ++
tests/kafkatest/tests/core/upgrade_test.py | 14 ++-
tests/kafkatest/version.py | 8 ++
18 files changed, 290 insertions(+), 47 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/MetadataRequestIBPTest/TopicIdWithOldInterBrokerProtocolTest.scala