kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (5db02ea -> ae0c6e5)
Date Wed, 05 Feb 2020 17:13:45 GMT
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


Mime
View raw message