This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 5db02ea MINOR: Fix typos introduced in KIP-559 (#8042)
add ae0c6e5 KAFKA-9261; Client should handle unavailable leader metadata
(#7770)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/Metadata.java | 113 +++++++------
.../org/apache/kafka/clients/MetadataCache.java | 105 ++++--------
.../org/apache/kafka/clients/NetworkClient.java | 2 +-
.../admin/internals/MetadataOperationContext.java | 4 +-
.../kafka/clients/consumer/KafkaConsumer.java | 4 +-
.../kafka/clients/consumer/MockConsumer.java | 5 +-
.../kafka/clients/consumer/OffsetAndMetadata.java | 4 +-
.../consumer/internals/ConsumerCoordinator.java | 6 +-
.../kafka/clients/consumer/internals/Fetcher.java | 55 +++---
.../consumer/internals/SubscriptionState.java | 8 +-
.../main/java/org/apache/kafka/common/Cluster.java | 21 +--
.../kafka/common/requests/MetadataResponse.java | 184 ++++++++++-----------
.../apache/kafka/common/requests/RequestUtils.java | 9 +-
.../apache/kafka/clients/MetadataCacheTest.java | 85 ++++++++++
.../org/apache/kafka/clients/MetadataTest.java | 115 ++++++++++---
.../kafka/clients/admin/KafkaAdminClientTest.java | 51 +++---
.../internals/ConsumerCoordinatorTest.java | 5 +-
.../consumer/internals/ConsumerMetadataTest.java | 3 +-
.../clients/consumer/internals/FetcherTest.java | 37 +++--
.../internals/OffsetForLeaderEpochClientTest.java | 8 +-
.../consumer/internals/SubscriptionStateTest.java | 47 +++---
.../kafka/common/requests/RequestResponseTest.java | 26 +--
.../test/java/org/apache/kafka/test/TestUtils.java | 15 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 8 +-
.../main/scala/kafka/server/MetadataCache.scala | 89 ++++++----
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 23 ++-
.../admin/TopicCommandWithAdminClientTest.scala | 2 +-
.../server/AbstractCreateTopicsRequestTest.scala | 4 +-
.../unit/kafka/server/MetadataCacheTest.scala | 33 ++--
.../unit/kafka/server/MetadataRequestTest.scala | 43 +++--
30 files changed, 635 insertions(+), 479 deletions(-)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/MetadataCacheTest.java
