You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/10/06 21:12:57 UTC
[kafka] branch KAFKA-13280 updated (d35390b -> 32a228f)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch KAFKA-13280
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d35390b Test that put() throws UnsupportedOperationException
add f650a14 KAFKA-13312; 'NetworkDegradeTest#test_rate' should wait until iperf server is listening (#11344)
add 5a6f19b KAFKA-13246: StoreQueryIntegrationTest#shouldQueryStoresAfterAddingAndRemovingStreamThread now waits for the client state to go to REBALANCING/RUNNING after adding/removing a thread and waits for state RUNNING before querying the state store. (#11334)
add 02795d7 MINOR: fix CreateTopic to return the same as DescribeTopic (#11348)
add b61ec00 KAFKA-13211: add support for infinite range query for WindowStore (#11227)
add d15969a KAFKA-10544: Migrate KTable aggregate and reduce (#11316)
add 85548ac KAFKA-13279: allow CreateTopicsPolicy, AlterConfigsPolicy in KRaft mode (#11310)
add 509c165 MINOR: Replace EasyMock with Mockito in connect:basic-auth-extension (#11321)
add 9abc45e MINOR: Print lastTimestamp when dumping producer snapshots (#11354)
add d08e3ad KAFKA-13315: log layer exception during shutdown that caused an unclean shutdown (#11351)
add b76bcaf KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path (#11170)
add af0c2a9 MINOR: fix ClusterControlManager log message (#11358)
add 4eb386f KAFKA-13296: warn if previous assignment has duplicate partitions (#11347)
add 1af1c80 MINOR: replace deprecated exactly_once_beta into exactly_once_v2 (#10884)
add c6aeb5c KAFKA-13305: fix NullPointerException in LogCleanerManager "uncleanable-bytes" gauge (#11327)
add b741e93 KAFKA-13324: KRaft: fix validateOnly in CreateTopics (#11361)
add 5e45196 Add DirectoryConfigProvider to the service provider list (#11352)
add 5a5c058 MINOR: Fix use of ConfigException in AbstractConfig class (#11349)
add ef37d51 Merge branch 'trunk' into KAFKA-13280
add 32a228f Use TranslatedValueMapView
No new revisions were added by this update.
Summary of changes:
build.gradle | 2 +-
checkstyle/import-control.xml | 2 +
.../apache/kafka/common/config/AbstractConfig.java | 10 +-
.../common/config/provider/ConfigProvider.java | 2 +
.../kafka/common/internals/PartitionStates.java | 5 +
.../kafka/server/policy/AlterConfigPolicy.java | 14 ++
.../kafka/server/policy/CreateTopicPolicy.java | 19 +++
...che.kafka.common.config.provider.ConfigProvider | 1 +
.../provider/DirectoryConfigProviderTest.java | 8 +
.../config/provider/FileConfigProviderTest.java | 8 +
.../BasicAuthSecurityRestExtensionTest.java | 29 ++--
.../auth/extension/JaasBasicAuthFilterTest.java | 114 ++++++++------
core/src/main/scala/kafka/log/LogCleaner.scala | 2 +
.../main/scala/kafka/log/LogCleanerManager.scala | 33 +++-
.../kafka/server/AbstractFetcherManager.scala | 26 +++-
.../scala/kafka/server/AbstractFetcherThread.scala | 52 +++++--
.../src/main/scala/kafka/server/BrokerServer.scala | 16 +-
.../src/main/scala/kafka/server/ConfigHelper.scala | 8 +-
.../main/scala/kafka/server/ControllerServer.scala | 16 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 3 -
core/src/main/scala/kafka/server/KafkaServer.scala | 16 +-
.../kafka/server/ReplicaAlterLogDirsThread.scala | 23 ++-
.../scala/kafka/server/ReplicaFetcherThread.scala | 3 +-
.../main/scala/kafka/server/ReplicaManager.scala | 52 ++++++-
.../main/scala/kafka/server/ZkAdminManager.scala | 2 +-
.../main/scala/kafka/tools/DumpLogSegments.scala | 3 +-
.../main/scala/kafka/utils/KafkaScheduler.scala | 50 +++---
.../unit/kafka/log/LogCleanerIntegrationTest.scala | 20 ++-
.../kafka/server/AbstractFetcherManagerTest.scala | 91 ++++++++++-
.../kafka/server/AbstractFetcherThreadTest.scala | 90 +++++++----
.../AbstractFetcherThreadWithIbp26Test.scala | 4 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 18 +--
.../kafka/server/ReplicaFetcherThreadTest.scala | 30 ++--
.../unit/kafka/server/ReplicaManagerTest.scala | 103 ++++++++++++-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 2 +-
.../kafka/controller/ClusterControlManager.java | 8 +-
.../controller/ConfigurationControlManager.java | 41 ++++-
.../apache/kafka/controller/QuorumController.java | 25 ++-
.../controller/ReplicationControlManager.java | 49 +++++-
.../java/org/apache/kafka/image/TopicsImage.java | 135 +----------------
.../ConfigurationControlManagerTest.java | 95 ++++++++++--
.../controller/ReplicationControlManagerTest.java | 152 +++++++++++++++++--
.../kafka/server/util/TranslatedValueMapView.java | 117 +++++++++++++++
.../server/util/TranslatedValueMapViewTest.java | 109 ++++++++++++++
.../kstream/internals/KGroupedTableImpl.java | 45 +++---
.../streams/kstream/internals/KTableAggregate.java | 65 ++++----
.../streams/kstream/internals/KTableReduce.java | 39 ++---
.../internals/StreamsPartitionAssignor.java | 10 ++
.../kafka/streams/state/ReadOnlyWindowStore.java | 6 +-
.../apache/kafka/streams/state/WindowStore.java | 3 +-
.../AbstractRocksDBSegmentedBytesStore.java | 6 +-
.../state/internals/CachingWindowStore.java | 20 +--
.../internals/CompositeReadOnlyWindowStore.java | 4 -
.../state/internals/InMemoryWindowStore.java | 40 +++--
.../state/internals/MeteredWindowStore.java | 16 +-
.../streams/state/internals/SegmentIterator.java | 14 +-
.../integration/StoreQueryIntegrationTest.java | 6 +-
.../kstream/internals/KGroupedTableImplTest.java | 13 +-
.../kstream/internals/KTableAggregateTest.java | 13 +-
.../kstream/internals/KTableReduceTest.java | 14 +-
.../AbstractRocksDBSegmentedBytesStoreTest.java | 136 ++++++++++++++++-
.../internals/AbstractWindowBytesStoreTest.java | 58 +++++--
.../CachingPersistentWindowStoreTest.java | 167 ++++++++++++++++++---
.../CompositeReadOnlyWindowStoreTest.java | 103 +++++++++++--
.../state/internals/MeteredWindowStoreTest.java | 39 +++--
.../state/internals/ReadOnlyWindowStoreStub.java | 32 +++-
.../state/internals/SegmentIteratorTest.java | 145 ++++++++++++++++++
.../state/internals/WindowStoreFetchTest.java | 81 ++++++++++
.../org/apache/kafka/test/StreamsTestUtils.java | 20 +++
tests/kafkatest/tests/core/network_degrade_test.py | 7 +
.../streams/streams_broker_compatibility_test.py | 47 +++---
tests/kafkatest/tests/streams/streams_eos_test.py | 8 +-
.../tests/streams/streams_relational_smoke_test.py | 4 +-
73 files changed, 2150 insertions(+), 619 deletions(-)
create mode 100644 server-common/src/main/java/org/apache/kafka/server/util/TranslatedValueMapView.java
create mode 100644 server-common/src/test/java/org/apache/kafka/server/util/TranslatedValueMapViewTest.java