You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by bo...@apache.org on 2021/02/06 21:07:40 UTC
[kafka] branch trunk updated (3a766bd -> d2cb2dc)
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