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 baef516 Add ConfigurableProducerSpec to Trogdor for improved E2E
latency tracking. (#9736)
add 5c921af KAFKA-10547; Add TopicId in MetadataResponse (#9622)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 2 +-
.../kafka/clients/admin/TopicDescription.java | 12 +++++
.../main/java/org/apache/kafka/common/Cluster.java | 37 ++++++++++++--
.../kafka/common/requests/MetadataResponse.java | 21 ++++++--
.../common/requests/UpdateMetadataRequest.java | 24 +++++++--
.../resources/common/message/MetadataRequest.json | 6 ++-
.../resources/common/message/MetadataResponse.json | 4 +-
.../common/message/UpdateMetadataRequest.json | 4 +-
.../common/message/UpdateMetadataResponse.json | 2 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 3 +-
.../kafka/common/requests/RequestResponseTest.java | 2 +-
.../common/requests/UpdateMetadataRequestTest.java | 31 +++++++++---
core/src/main/scala/kafka/admin/TopicCommand.scala | 24 +++++----
core/src/main/scala/kafka/api/ApiVersion.scala | 11 ++++-
.../controller/ControllerChannelManager.scala | 9 +++-
.../main/scala/kafka/server/MetadataCache.scala | 30 ++++++++----
.../kafka/api/AuthorizerIntegrationTest.scala | 3 +-
.../test/scala/unit/kafka/api/ApiVersionTest.scala | 4 +-
.../controller/ControllerChannelManagerTest.scala | 57 +++++++++++++---------
.../kafka/server/BrokerEpochIntegrationTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 4 +-
.../unit/kafka/server/MetadataCacheTest.scala | 19 +++++---
.../unit/kafka/server/MetadataRequestTest.scala | 27 ++++++++++
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +-
.../jmh/metadata/MetadataRequestBenchmark.java | 2 +-
25 files changed, 260 insertions(+), 85 deletions(-)
