kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From boy...@apache.org
Subject [kafka] branch trunk updated (3a766bd -> d2cb2dc)
Date Sat, 06 Feb 2021 21:07:40 GMT
This is an automated email from the ASF dual-hosted git repository.

boyang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 3a766bd  MINOR: remove the indent in security doc
     add d2cb2dc  KAFKA-9751: Forward CreateTopicsRequest for FindCoordinator/Metadata when
topic creation is needed (#9579)

No new revisions were added by this update.

Summary of changes:
 .../producer/internals/TransactionManager.java     |   2 +-
 .../kafka/common/requests/CreateTopicsRequest.java |  10 +
 .../common/requests/FindCoordinatorRequest.java    |   3 +-
 .../FindCoordinatorRequestTest.java}               |  13 +-
 .../kafka/server/AutoTopicCreationManager.scala    | 321 +++++++++++++++++++++
 .../server/BrokerToControllerChannelManager.scala  |   1 -
 .../scala/kafka/server/ForwardingManager.scala     |   1 -
 core/src/main/scala/kafka/server/KafkaApis.scala   | 264 +++++++----------
 core/src/main/scala/kafka/server/KafkaServer.scala |  28 +-
 .../kafka/api/ConsumerTopicCreationTest.scala      |  28 +-
 .../scala/integration/kafka/api/MetricsTest.scala  |  16 +-
 .../kafka/api/PlaintextConsumerTest.scala          |   2 +
 .../server/AbstractCreateTopicsRequestTest.scala   |   2 +-
 .../kafka/server/AbstractMetadataRequestTest.scala |  61 ++++
 .../server/AutoTopicCreationManagerTest.scala      | 194 +++++++++++++
 .../CreateTopicsRequestWithForwardingTest.scala    |   1 -
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 264 ++++++++++++++++-
 .../unit/kafka/server/MetadataRequestTest.scala    |  62 ++--
 .../server/MetadataRequestWithForwardingTest.scala | 111 +++++++
 .../jmh/metadata/MetadataRequestBenchmark.java     |   3 +
 .../streams/processor/internals/StandbyTask.java   |  16 +-
 .../streams/processor/internals/StreamTask.java    |  36 +--
 .../streams/processor/internals/StreamThread.java  |   4 +-
 .../kafka/streams/processor/internals/Task.java    |   6 +-
 .../streams/processor/internals/TaskManager.java   |  22 +-
 .../streams/integration/EosIntegrationTest.java    |   2 +-
 .../processor/internals/StandbyTaskTest.java       |   2 +-
 .../processor/internals/StreamTaskTest.java        | 152 +++-------
 .../processor/internals/StreamThreadTest.java      |   2 +-
 .../processor/internals/TaskManagerTest.java       | 150 +++++-----
 streams/src/test/resources/log4j.properties        |   2 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +-
 32 files changed, 1311 insertions(+), 472 deletions(-)
 copy clients/src/test/java/org/apache/kafka/common/{utils/LoggingSignalHandlerTest.java =>
requests/FindCoordinatorRequestTest.java} (69%)
 create mode 100644 core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/AbstractMetadataRequestTest.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/MetadataRequestWithForwardingTest.scala


Mime
View raw message