This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch kip1071
in repository https://gitbox.apache.org/repos/asf/kafka.git
omit 881541b8d7a Remove superfluous record version
omit c9507cff82e KIP1071 trunk rebase 11_25 add streams membership manager
stream thread integration (#17968)
omit 790311027d8 Fixes from rebase
omit 9b995426eab Correctness updates from rebase
omit ae8b81b2d9b Resolve conflicts from 11/15 trunk rebase - Initialize
topologies as part of heartbeat (#17695)
omit 13478962f35 Introduce the streams membership manager (#17564)
omit 6069ba983b1 Resolve conflicts from 11/25 trunk rebase - Internal topic
auto creation (#17433)
omit 072e979dd33 Resolve conflicts from trunk rebase - Port tools for topic
configuration (#17371)
omit 5b4bebc0d3e Resolve conflicts from 11/25 trunk rebase - MINOR: Rebase
dev branch on current trunk
omit 86fbb0c8a1a Complete topic metadata for automatic topic creation
(#17391)
omit 662db9e0304 MINOR: Fix unit tests (#17374)
omit 584ff178d23 MINOR: Use subtopologyId and spelling consistently (#17370)
omit 854624c25ee KAFKA-17125: finalize TaskId (#17300)
omit 64bcba7b99b Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-09-25
omit 00bd56cbd63 Add broker configs for streams group
omit 6c0b266039b Resolve conflict from 11/25 trunk rebase - Streams
reconciliation logic
omit 58c2b74b611 Improve the Streams group initialization handler
omit bbd9708bbb7 Rename streamsHeartbeatX and streamsInitializeX to
streamsGroupX
omit ff472e36156 StickyTaskAssignor
omit eb8ecfdca98 Minor: Revert test changes
omit b97a8d02779 Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-08-15
omit eddb74f24e1 Resolve conflicts from 11/25 trunk rebase - Implement
DescribeStreamsGroup RPC handling
omit 072c1fe9747 Resovle conflicts from 11/25 trunk rebase - Update RPCs
omit 7490fda1fea Resolve conflicts for 11/25 trunk rebase - Rebased on AK
trunk 2024-07-16
omit 9cfcf1a33db Resolve conflicts from 11/25 rebase - Get
SmokeTestDriverIntegrationTest working
omit 89a2b27394a Reslove confict from 11/25 trunk rebase - Replay all
streams-related records
omit e218779e42d Reslove conflicts from 11/25 rebase - Create
assignment-related classes for streams groups
omit 08d78f802f0 Define the assignor interface for streams and implement a
simple assignor
omit 63eef9d740e Add streams group member
omit 8ccd17c0d39 Resolve conflict from 11/25 rebase Basic heartbeat RPC
handler
omit 460d0b777e8 Minor: Rename TaskId to TaskIds
omit 9af3f93669f Add Assignment class in group coordinator for Streams
omit a5ab91ccbf6 Resolve merge conflict from 11/25 trunk rebase Implement
InitStreamsApp RPC in the group coordinator
omit 97c53d1c0b5 Define initial record types for the consumer offset topic
omit 53169a3a68a Minor: Test fixes
omit 548283e93c7 Resolve conflict from 11/25 trunk rebase - Create and
inject StreamsHeartbeatRequestManager
omit 8c26aae0f92 Implement StreamsInitialize request manager
omit 528e3cb307b Resolve merge conflict from 11/25 rebase - Specify
AsyncKafkaConsumer interface with Streams for the Rebalance PoC
omit 9c8c30e67d8 Resolve merge conflict from 11/25 trunk rebase - Define
RPCs to perform client-side assignment
omit 16be1c4253a Reslove merge conflict from 11/25 trunk rebase -
StreamsInitialize RPC and some errors
omit 02dca3ef6dc Very initial (compiling) streams RPCs.
add 3268435fd66 KAFKA-18013: Add AutoOffsetResetStrategy internal class
(#17858)
add 54843e6e1ed KAFKA-18077 Remove deprecated JmxReporter(String) (#17923)
add d17a1492054 KAFKA-17956 Remove Admin.listShareGroups (#17912)
add 7908a4838b4 Fix long running RangeQueryIntegrationTest. (#17933)
add 0f33b16fdf7 KAFKA-18085: Abort inflight requests on existing
connections while rebootstrapping (#17939)
add 13d9a199f25 KAFKA-18011 Remove ZooKeeper sections from the docs
(#17813)
add 95947d2f581 KAFKA-17299: add unit tests for previous fix (#17919)
add 7f8a592ad19 KAFKA-17869: Adding tests to ensure KIP-1076 doesn't
interfere producer metrics[2/3] (#17783)
add 4fc9e442c30 KAFKA-17898: Refine Epoch Bumping Logic (#17849)
add 918a67ece83 MINOR: Improve Docker examples readme (#17894)
add 5480d54d185 KAFKA-17544: Add log message for early access use of
KafkaShareConsumer (#17940)
add 48d60efe980 KAFKA-17990: Deflake testShareAutoOffsetResetDefaultValue
(#17916)
add cebec91470c KAFKA-18080 Replace DelayedItem by Long type (#17927)
add 58bf20d6753 MINOR: add </script> back to security.html (#17944)
add 0b081fc3100 KAFKA-15561 [2/N]: Background event and subscription state
changes for RE2J pattern (#17918)
add 55577e73b2a KAFKA-18083 ClusterInstance custom controllerListener not
work (#17932)
add 866d66229da KAFKA-18056: Fixed bug in handling commitAsync responses
(#17909)
add 056a76e2b91 KAFKA-17811 Separate modules to use different JDKs (#17522)
add 0e4d8b3e868 KAFKA-17569 Rewrite TestLinearWriteSpeed by Java (#17736)
add 11ce41fb1d5 KAFKA-18092: Mark testBumpTransactionalEpochWithTV2Enabled
as flaky (#17945)
add 24dd11d6936 KAFKA-17593; [8/N] Resolve regular expressions (#17864)
add b42efc7dc26 KAFKA-18049: Upgrade the caffeine version to 3.1.1 (#17879)
add 98d47f47ef2 KAFKA-18028 the effective kraft version of
--no-initial-controllers should be 1 rather than 0 (#17836)
add f5d712396bd MINOR: fix warnings in Kafka Streams state store tests
(#17855)
add 2b2b3cd355c KAFKA-18062: use feature version to enable ELR (#17867)
add 3f834781a43 KAFKA-12844: clean up TaskId (#17904)
add 3710add2a7f KAFKA-18012: Update the Scram configuration section for
KRaft (#17844)
add 434fe7c26e3 KAFKA-18081 Remove isKRaftTest from the kraft-only tests
(#17934)
add c32a49549df MINOR: Remove duplicate valid value in document (#17947)
add 37b4d9b01d5 KAFKA-15561 [3/N]: Client support for SubscriptionPattern
in HB (#17951)
add aae42ef656a KAFKA-17593; [9/N] Mark ConsumerGroupHeartbeat API v1 as
stable (#17961)
add 486f65e8c60 KAFKA-18100 `Using` block suppresses all errors (#17954)
add a39c984d216 KAFKA-15561 [4/N]: MockConsumer support for
SubscriptionPattern (#17962)
add c446e799be3 KAFKA-17010 Remove `DescribeLogDirsResponse#LogDirInfo`,
`DescribeLogDirsResponse#ReplicaInfo`, and `DescribeLogDirsResult#all` (#17953)
add cdf3aab661f MINOR: remove zk from several tests (#17949)
add d334f60944f MINOR: KStreamRepartitionIntegrationTest bug (#17963)
add b08b64c2d85 KAFKA-18098 add kraft support to
testReplicaPlacementAllServers and testReplicaPlacementPartialServers (#17955)
add 8be99f44dc1 KAFKA-18097 Upgrade readme to include min JDK changes
(#17948)
add 5243fb9a7d7 KAFKA-18026: migrate KTableSource to use
ProcesserSupplier#stores (#17903)
add e1ba01d2144 KAFKA-18109 Fix failed
SaslClientsWithInvalidCredentialsTest in tools module (#17971)
new 5eb61c087ca Very initial (compiling) streams RPCs.
new f8ecdc9a716 Reslove merge conflict from 11/25 trunk rebase -
StreamsInitialize RPC and some errors
new 7cd85abe2db Resolve merge conflict from 11/25 trunk rebase - Define
RPCs to perform client-side assignment
new 9e3ba3e0f5a Resolve merge conflict from 11/25 rebase - Specify
AsyncKafkaConsumer interface with Streams for the Rebalance PoC
new a19bc7d97b7 Implement StreamsInitialize request manager
new b2e6b80df6e Resolve conflict from 11/25 trunk rebase - Create and
inject StreamsHeartbeatRequestManager
new 8f22f7a6181 Minor: Test fixes
new 286314d72ae Define initial record types for the consumer offset topic
new c1a597b211e Resolve merge conflict from 11/25 trunk rebase Implement
InitStreamsApp RPC in the group coordinator
new 60f6773fa63 Add Assignment class in group coordinator for Streams
new 41669d978ec Minor: Rename TaskId to TaskIds
new 4c64b358d62 Resolve conflict from 11/25 rebase Basic heartbeat RPC
handler
new 9b448029274 Add streams group member
new d06afbd4a96 Define the assignor interface for streams and implement a
simple assignor
new 049aece0aa3 Reslove conflicts from 11/25 rebase - Create
assignment-related classes for streams groups
new cc4985e5972 Reslove confict from 11/25 trunk rebase - Replay all
streams-related records
new 7d73d52e8b6 Resolve conflicts from 11/25 rebase - Get
SmokeTestDriverIntegrationTest working
new 6c36a43fe9d Resolve conflicts for 11/25 trunk rebase - Rebased on AK
trunk 2024-07-16
new 2dd10b7147e Resovle conflicts from 11/25 trunk rebase - Update RPCs
new 6a4aa0cf1d4 Resolve conflicts from 11/25 trunk rebase - Implement
DescribeStreamsGroup RPC handling
new dc5b2ef7ecd Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-08-15
new a002fe9c241 Minor: Revert test changes
new eeea1ca9205 StickyTaskAssignor
new 93b72dba05c Rename streamsHeartbeatX and streamsInitializeX to
streamsGroupX
new 7a9105b93fc Improve the Streams group initialization handler
new 133a442e66b Resolve conflict from 11/25 trunk rebase - Streams
reconciliation logic
new 51155f993e6 Add broker configs for streams group
new d1794f477ba Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-09-25
new deb38899cc9 KAFKA-17125: finalize TaskId (#17300)
new 8b6094c4e32 MINOR: Use subtopologyId and spelling consistently (#17370)
new 0953df59d7b MINOR: Fix unit tests (#17374)
new b18625b86ff Complete topic metadata for automatic topic creation
(#17391)
new 16c51af4e20 Resolve conflicts from 11/25 trunk rebase - MINOR: Rebase
dev branch on current trunk
new f5f901771ce Resolve conflicts from trunk rebase - Port tools for topic
configuration (#17371)
new 4686728d883 Resolve conflicts from 11/25 trunk rebase - Internal topic
auto creation (#17433)
new dcb0c923ff7 Introduce the streams membership manager (#17564)
new 6b98ec67ee3 Resolve conflicts from 11/15 trunk rebase - Initialize
topologies as part of heartbeat (#17695)
new e19b7e08737 Correctness updates from rebase
new 1e8284b71d2 Fixes from rebase
new b3eeed7a093 KIP1071 trunk rebase 11_25 add streams membership manager
stream thread integration (#17968)
new c7deec0e70c Remove superfluous record version
new 744679541e1 Remove unused import
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (881541b8d7a)
\
N -- N -- N refs/heads/kip1071 (744679541e1)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 42 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/build.yml | 2 +-
.github/workflows/ci-complete.yml | 2 +-
LICENSE-binary | 2 +-
README.md | 6 +-
build.gradle | 36 +-
checkstyle/import-control-jmh-benchmarks.xml | 1 +
.../apache/kafka/clients/CommonClientConfigs.java | 3 +-
.../java/org/apache/kafka/clients/KafkaClient.java | 6 -
.../org/apache/kafka/clients/MetadataUpdater.java | 17 +
.../org/apache/kafka/clients/NetworkClient.java | 53 +-
.../java/org/apache/kafka/clients/admin/Admin.java | 20 -
.../kafka/clients/admin/DescribeLogDirsResult.java | 46 --
.../kafka/clients/admin/ForwardingAdmin.java | 5 -
.../kafka/clients/admin/KafkaAdminClient.java | 142 +---
.../clients/admin/ListShareGroupsOptions.java | 51 --
.../kafka/clients/admin/ListShareGroupsResult.java | 84 ---
.../kafka/clients/admin/ShareGroupListing.java | 91 ---
.../admin/internals/AdminMetadataManager.java | 11 +-
.../kafka/clients/consumer/ConsumerConfig.java | 5 +-
.../kafka/clients/consumer/MockConsumer.java | 43 +-
.../kafka/clients/consumer/MockShareConsumer.java | 3 +-
.../clients/consumer/OffsetResetStrategy.java | 4 +
.../internals/AbstractHeartbeatRequestManager.java | 6 +
.../consumer/internals/AsyncKafkaConsumer.java | 35 +-
.../internals/AutoOffsetResetStrategy.java | 105 +++
.../consumer/internals/ClassicKafkaConsumer.java | 5 +-
.../internals/ConsumerHeartbeatRequestManager.java | 15 +-
.../clients/consumer/internals/ConsumerUtils.java | 5 +-
.../consumer/internals/OffsetFetcherUtils.java | 15 +-
.../internals/ShareConsumeRequestManager.java | 5 +-
.../internals/ShareConsumerDelegateCreator.java | 7 +
.../consumer/internals/SubscriptionState.java | 74 +-
.../internals/events/ApplicationEvent.java | 5 +-
.../events/ApplicationEventProcessor.java | 26 +
.../internals/events/ResetOffsetEvent.java | 8 +-
...> TopicRe2JPatternSubscriptionChangeEvent.java} | 23 +-
.../kafka/clients/producer/KafkaProducer.java | 14 +-
.../producer/internals/TransactionManager.java | 133 +++-
.../apache/kafka/common/config/TopicConfig.java | 2 +-
.../apache/kafka/common/metrics/JmxReporter.java | 13 +-
.../common/requests/DescribeLogDirsResponse.java | 66 --
.../message/ConsumerGroupHeartbeatRequest.json | 1 -
.../java/org/apache/kafka/clients/MockClient.java | 5 -
.../apache/kafka/clients/NetworkClientTest.java | 54 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 118 +--
.../kafka/clients/admin/MockAdminClient.java | 5 -
.../kafka/clients/consumer/KafkaConsumerTest.java | 15 +-
.../consumer/KafkaShareConsumerMetricsTest.java | 3 +-
.../kafka/clients/consumer/MockConsumerTest.java | 19 +-
.../internals/AbstractCoordinatorTest.java | 3 +-
.../consumer/internals/AsyncKafkaConsumerTest.java | 46 +-
.../internals/AutoOffsetResetStrategyTest.java | 77 ++
.../internals/CommitRequestManagerTest.java | 3 +-
.../consumer/internals/CompletedFetchTest.java | 3 +-
.../internals/ConsumerCoordinatorTest.java | 7 +-
.../ConsumerHeartbeatRequestManagerTest.java | 56 ++
.../consumer/internals/ConsumerMetadataTest.java | 3 +-
.../internals/FetchRequestManagerTest.java | 57 +-
.../clients/consumer/internals/FetcherTest.java | 61 +-
.../consumer/internals/OffsetFetcherTest.java | 81 +-
.../internals/OffsetForLeaderEpochClientTest.java | 5 +-
.../internals/OffsetsRequestManagerTest.java | 7 +-
.../internals/ShareConsumeRequestManagerTest.java | 70 +-
.../consumer/internals/ShareConsumerImplTest.java | 21 +-
.../consumer/internals/SubscriptionStateTest.java | 52 +-
.../internals/TopicMetadataFetcherTest.java | 3 +-
.../events/ApplicationEventProcessorTest.java | 43 +-
.../kafka/clients/producer/KafkaProducerTest.java | 116 +++
.../producer/internals/TransactionManagerTest.java | 60 +-
.../kafka/common/metrics/JmxReporterTest.java | 19 -
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 4 +-
.../runtime/isolation/SynchronizationTest.java | 1 +
.../storage/ConnectorOffsetBackingStoreTest.java | 4 +-
.../kafka/connect/util/KafkaBasedLogTest.java | 4 +-
.../common/runtime/MockCoordinatorExecutor.java | 127 ++++
.../scala/kafka/server/AbstractFetcherThread.scala | 19 +-
.../main/scala/kafka/server/ControllerServer.scala | 3 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 2 -
core/src/main/scala/kafka/tools/StorageTool.scala | 14 +-
core/src/main/scala/kafka/utils/DelayedItem.scala | 44 --
.../java/kafka/test/api/ShareConsumerTest.java | 47 +-
.../kafka/admin/RemoteTopicCrudTest.scala | 45 +-
...merWithLegacyMessageFormatIntegrationTest.scala | 34 +-
...onTokenEndToEndAuthorizationWithOwnerTest.scala | 6 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 27 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 5 +-
.../scala/integration/kafka/api/SaslSetup.scala | 2 +-
.../integration/kafka/api/TransactionsTest.scala | 1 +
.../server/DynamicBrokerReconfigurationTest.scala | 43 +-
.../kafka/server/GssapiAuthenticationTest.scala | 2 +-
.../kafka/server/QuorumTestHarness.scala | 8 +-
.../kafka/server/RaftClusterSnapshotTest.scala | 4 +-
.../scala/kafka/raft/KafkaMetadataLogTest.scala | 146 ++--
.../src/test/scala/kafka/utils/TestInfoUtils.scala | 8 +
.../scala/other/kafka/TestLinearWriteSpeed.scala | 254 -------
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 61 +-
.../group/CoordinatorLoaderImplTest.scala | 27 +-
.../kafka/integration/KafkaServerTestHarness.scala | 6 +-
.../kafka/log/remote/RemoteIndexCacheTest.scala | 4 +-
.../scala/unit/kafka/metrics/MetricsTest.scala | 2 +-
.../server/AbstractApiVersionsRequestTest.scala | 9 +-
.../server/AbstractCreateTopicsRequestTest.scala | 4 -
.../kafka/server/AbstractMetadataRequestTest.scala | 14 +-
.../server/ConsumerGroupHeartbeatRequestTest.scala | 91 ++-
.../kafka/server/ControllerMutationQuotaTest.scala | 15 +-
.../server/CreateTopicsRequestWithPolicyTest.scala | 18 +-
.../kafka/server/DeleteTopicsRequestTest.scala | 93 +--
...leteTopicsRequestWithDeletionDisabledTest.scala | 2 +-
.../kafka/server/DescribeClusterRequestTest.scala | 11 +-
.../kafka/server/DynamicConfigChangeTest.scala | 102 ++-
.../server/GroupCoordinatorBaseRequestTest.scala | 3 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 8 +-
.../kafka/server/KafkaMetricsReporterTest.scala | 9 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 8 +-
.../unit/kafka/server/ReplicationQuotasTest.scala | 4 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 4 +-
.../unit/kafka/server/ServerShutdownTest.scala | 12 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 8 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 2 +-
.../scala/unit/kafka/tools/StorageToolTest.scala | 38 +-
docker/examples/README.md | 131 ++--
docs/configuration.html | 44 +-
docs/design.html | 23 +-
docs/implementation.html | 39 -
docs/migration.html | 34 -
docs/ops.html | 482 +-----------
docs/quickstart.html | 31 +-
docs/security.html | 257 +------
docs/streams/quickstart.html | 28 +-
docs/toc.html | 37 +-
docs/upgrade.html | 11 +-
gradle/dependencies.gradle | 5 +-
.../coordinator/group/GroupCoordinatorConfig.java | 2 +
.../coordinator/group/GroupCoordinatorShard.java | 1 +
.../coordinator/group/GroupMetadataManager.java | 382 +++++++++-
.../group/modern/consumer/ConsumerGroup.java | 48 +-
.../modern/consumer/ResolvedRegularExpression.java | 2 +
.../group/GroupMetadataManagerTest.java | 525 ++++++++++++-
.../group/GroupMetadataManagerTestContext.java | 19 +-
.../coordinator/group/MetadataImageBuilder.java | 16 +-
.../group/OffsetMetadataManagerTest.java | 3 +
.../group/modern/consumer/ConsumerGroupTest.java | 17 +
.../jmh/consumer/SubscriptionStateBenchmark.java | 4 +-
.../jmh/coordinator/RegexResolutionBenchmark.java | 128 ++++
.../apache/kafka/jmh/log/TestLinearWriteSpeed.java | 342 +++++++++
.../kafka/controller/FeatureControlManager.java | 9 +
.../apache/kafka/controller/QuorumController.java | 20 +-
.../controller/ReplicationControlManager.java | 18 +-
.../apache/kafka/metadata/storage/Formatter.java | 12 +-
.../QuorumControllerIntegrationTestUtils.java | 30 +-
.../kafka/controller/QuorumControllerTest.java | 21 +-
.../kafka/controller/QuorumControllerTestEnv.java | 12 +-
.../controller/ReplicationControlManagerTest.java | 14 +-
.../kafka/metadata/storage/FormatterTest.java | 68 +-
...ion.java => EligibleLeaderReplicasVersion.java} | 26 +-
.../org/apache/kafka/server/common/Features.java | 3 +-
.../kafka/server/config/ServerLogConfigs.java | 2 +-
.../apache/kafka/server/config/KRaftConfigs.java | 4 -
.../kafka/server/config/ReplicationConfigs.java | 7 +-
.../apache/kafka/server/BrokerFeaturesTest.java | 2 +
.../log/remote/storage/RemoteLogManagerConfig.java | 4 +-
.../remote/metadata/storage/ConsumerTaskTest.java | 4 +-
.../KStreamRepartitionIntegrationTest.java | 58 +-
.../integration/RangeQueryIntegrationTest.java | 10 +-
.../TestingMetricsInterceptingAdminClient.java | 7 -
.../org/apache/kafka/streams/StreamsBuilder.java | 8 +-
.../java/org/apache/kafka/streams/Topology.java | 8 +-
.../kstream/internals/InternalStreamsBuilder.java | 9 +-
.../streams/kstream/internals/KStreamImpl.java | 7 +-
.../streams/kstream/internals/KStreamImplJoin.java | 2 +-
.../streams/kstream/internals/KTableImpl.java | 7 +-
.../streams/kstream/internals/KTableSource.java | 24 +-
.../kstream/internals/MaterializedInternal.java | 11 +-
.../kstream/internals/graph/GlobalStoreNode.java | 12 +-
.../kstream/internals/graph/TableSourceNode.java | 34 +-
.../org/apache/kafka/streams/processor/TaskId.java | 24 +-
.../internals/InternalTopologyBuilder.java | 54 +-
.../processor/internals/PartitionGroup.java | 3 +-
.../processor/internals/StoreBuilderWrapper.java | 10 +-
.../StoreDelegatingProcessorSupplier.java} | 32 +-
.../streams/processor/internals/StoreFactory.java | 76 ++
.../streams/processor/internals/StreamThread.java | 37 +-
.../processor/internals/TopologyMetadata.java | 4 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 79 +-
.../apache/kafka/streams/StreamsConfigTest.java | 6 +-
.../org/apache/kafka/streams/TopologyTest.java | 13 +-
...StreamsThreadMetricsDelegatingReporterTest.java | 4 +-
.../internals/InternalStreamsBuilderTest.java | 18 +-
.../internals/SessionWindowedKStreamImplTest.java | 6 +-
.../internals/SlidingWindowedKStreamImplTest.java | 16 +-
.../internals/TimeWindowedKStreamImplTest.java | 12 +-
.../internals/graph/TableSourceNodeTest.java | 17 +-
.../internals/GlobalStateManagerImplTest.java | 30 +-
.../internals/GlobalStreamThreadTest.java | 13 +-
.../internals/InternalTopologyBuilderTest.java | 115 +--
.../processor/internals/PartitionGroupTest.java | 82 ++
.../processor/internals/StateConsumerTest.java | 4 +-
.../internals/StoreChangelogReaderTest.java | 14 +-
.../processor/internals/StreamTaskTest.java | 106 ++-
.../processor/internals/StreamThreadTest.java | 10 +-
...ctDualSchemaRocksDBSegmentedBytesStoreTest.java | 833 ++++++++++-----------
.../state/internals/AbstractKeyValueStoreTest.java | 66 +-
.../AbstractRocksDBSegmentedBytesStoreTest.java | 124 +--
.../internals/AbstractRocksDBWindowStoreTest.java | 153 ++--
.../internals/AbstractSessionBytesStoreTest.java | 58 +-
.../internals/AbstractWindowBytesStoreTest.java | 313 ++++----
.../internals/CachingInMemorySessionStoreTest.java | 8 +-
.../CachingPersistentSessionStoreTest.java | 8 +-
.../CachingPersistentWindowStoreTest.java | 18 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 20 +-
.../CompositeReadOnlySessionStoreTest.java | 16 +-
.../CompositeReadOnlyWindowStoreTest.java | 40 +-
.../state/internals/FilteredCacheIteratorTest.java | 6 +-
.../state/internals/InMemorySessionStoreTest.java | 6 +-
.../state/internals/ListValueStoreTest.java | 10 +-
.../StreamThreadStateStoreProviderTest.java | 6 +-
...imeOrderedCachingPersistentWindowStoreTest.java | 26 +-
.../internals/TimeOrderedWindowStoreTest.java | 26 +-
.../state/internals/WindowKeySchemaTest.java | 4 +-
.../org/apache/kafka/streams/utils/TestUtils.java | 16 +-
.../org/apache/kafka/test/MockClientSupplier.java | 6 +-
.../kafka/test/MockKeyValueStoreBuilder.java | 2 +-
.../org/apache/kafka/test/MockRestoreConsumer.java | 4 +-
.../org/apache/kafka/test/StreamsTestUtils.java | 32 +-
.../apache/kafka/streams/TopologyTestDriver.java | 6 +-
.../kafka/common/test/KafkaClusterTestKit.java | 11 +-
.../common/test/api/ClusterTestExtensionsTest.java | 8 +
.../tools/consumer/group/ShareGroupCommand.java | 18 +-
.../org/apache/kafka/tools/FeatureCommandTest.java | 23 +-
.../apache/kafka/tools/StreamsResetterTest.java | 10 +-
.../kafka/tools/consumer/ConsoleConsumerTest.java | 4 +-
.../SaslClientsWithInvalidCredentialsTest.java | 38 +-
232 files changed, 5054 insertions(+), 4331 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupsOptions.java
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupsResult.java
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ShareGroupListing.java
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AutoOffsetResetStrategy.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{TopicPatternSubscriptionChangeEvent.java
=> TopicRe2JPatternSubscriptionChangeEvent.java} (53%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AutoOffsetResetStrategyTest.java
create mode 100644
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorExecutor.java
delete mode 100644 core/src/main/scala/kafka/utils/DelayedItem.scala
delete mode 100755 core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala
delete mode 100644 docs/migration.html
create mode 100644
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator/RegexResolutionBenchmark.java
create mode 100644
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java
copy
server-common/src/main/java/org/apache/kafka/server/common/{GroupVersion.java
=> EligibleLeaderReplicasVersion.java} (69%)
copy
streams/src/main/java/org/apache/kafka/streams/{kstream/internals/PassThrough.java
=> processor/internals/StoreDelegatingProcessorSupplier.java} (55%)
