This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch cmccabe_2024_02_26_fix
in repository https://gitbox.apache.org/repos/asf/kafka.git
discard 925c61a99ce MINOR: remove test constructor for PartitionAssignment
add 027fad4b2a0 KAFKA-16277: AbstractStickyAssignor - Sort owned
TopicPartitions by partition when reassigning (#15416)
add ddfcc333f8d KAFKA-16226 Add test for concurrently updatingMetadata and
fetching snapshot/cluster (#15385)
add 1c9f360f4af KAFKA-15215: migrate StreamedJoinTest to Mockito (#15424)
add 3075a3f144c MINOR: Add 3.7.0 to system tests (#15436)
add 09793275208 KAFKA-16306: fix GroupCoordinatorService logger (#15433)
add 5d6936a4992 KAFKA-16305: Avoid optimisation in handshakeUnwrap
(#15434)
add 53c41aca7ba KAFKA-16116: Rebalance Metrics for AsyncKafkaConsumer
(#15339)
add 52289c92be4 MINOR: Optimize EventAccumulator (#15430)
add 1bb9a851744 MINOR: Remove the space between two words (#15439)
add 55a6d30ccbe KAFKA-16154: Broker returns offset for
LATEST_TIERED_TIMESTAMP (#15213)
add 96c68096a26 KAFKA-15462: Add Group Type Filter for List Group to the
Admin Client (#15150)
add f8eb4294d67 KAFKA-16191: Clean up of consumer client internal events
(#15438)
add d066b94c810 MINOR: Fix UpdatedImage and HighWatermarkUpdated events'
logs (#15432)
add c8843f06841 KAFKA-16167: Disable wakeups during autocommit on close
(#15445)
add 8e1516f88b8 KAFKA-16261: updateSubscription fails if already empty
subscription (#15440)
add 52a3fa07446 KAFKA-15878: KIP-768 - Extend support for opaque (i.e.
non-JWT) tokens in SASL/OAUTHBEARER (#14818)
add 21a5bbd84c3 MINOR: Upgrade jqwik to version 1.8.3 (#14365)
add 44af72fd773 MINOR: fix link for
ListTransactionsOptions#filterOnDuration (#15459)
add 907e945c0b7 MINOR: fix SessionStore java doc (#15412)
add 2c0cab39aed MINOR: Remove unnecessary easymock/powermock dependencies
(#15460)
add 7dbdc15c668 KAFKA-15625: Do not flush global state store at each
commit (#15361)
add 21a888c4ca0 MINOR: Updating comments to match the code (#15388)
add aa0443eb607 KAFKA-16285: Make group metadata available when a new
assignment is set (#15426)
add c254b22a487 MINOR: simplify ensure topic exists condition (#15458)
add 4f92a3f0afd KAFKA-14747: record discarded FK join subscription
responses (#15395)
add 99e511c706b KAFKA-16288, KAFKA-16289: Fix Values convertToDecimal
exception and parseString corruption (#15399)
add 47792770a28 KAFKA-16169: FencedException in commitAsync not propagated
without callback (#15437)
add eea369af947 KAFKA-14588 Log cleaner configuration move to
CleanerConfig (#15387)
add 2f401ff4c85 MINOR: parameterize group-id in
GroupMetadataManagerTestContext (#15467)
add fc13cd04d7f MINOR: remove test constructor for PartitionAssignment
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 (925c61a99ce)
\
N -- N -- N refs/heads/cmccabe_2024_02_26_fix (fc13cd04d7f)
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.
No new revisions were added by this update.
Summary of changes:
build.gradle | 11 +-
checkstyle/import-control-core.xml | 1 +
checkstyle/import-control.xml | 2 +
checkstyle/suppressions.xml | 1 +
.../java/org/apache/kafka/clients/admin/Admin.java | 2 +-
.../kafka/clients/admin/ConsumerGroupListing.java | 64 ++-
.../kafka/clients/admin/KafkaAdminClient.java | 20 +-
.../clients/admin/ListConsumerGroupsOptions.java | 25 +-
.../consumer/internals/AbstractStickyAssignor.java | 1 +
.../consumer/internals/AsyncKafkaConsumer.java | 230 +++++-----
.../consumer/internals/CommitRequestManager.java | 2 +-
.../internals/CoordinatorRequestManager.java | 6 +-
.../internals/HeartbeatRequestManager.java | 25 +-
.../consumer/internals/MembershipManager.java | 7 +-
.../consumer/internals/MembershipManagerImpl.java | 109 +++--
.../internals/OffsetCommitCallbackInvoker.java | 10 -
.../consumer/internals/OffsetsRequestManager.java | 4 +-
.../consumer/internals/RequestManagers.java | 7 +-
.../clients/consumer/internals/RequestState.java | 2 +-
.../clients/consumer/internals/WakeupTrigger.java | 11 +
...nEvent.java => AbstractTopicMetadataEvent.java} | 24 +-
...tableEvent.java => AllTopicsMetadataEvent.java} | 9 +-
.../internals/events/ApplicationEvent.java | 35 +-
.../internals/events/ApplicationEventHandler.java | 6 +-
.../events/ApplicationEventProcessor.java | 123 +++--
...cationEvent.java => AssignmentChangeEvent.java} | 33 +-
...ApplicationEvent.java => AsyncCommitEvent.java} | 15 +-
.../consumer/internals/events/BackgroundEvent.java | 32 +-
.../internals/events/BackgroundEventHandler.java | 2 +-
...ommitApplicationEvent.java => CommitEvent.java} | 21 +-
...mpletableEvent.java => CommitOnCloseEvent.java} | 9 +-
.../events/CompletableApplicationEvent.java | 45 +-
.../events/CompletableBackgroundEvent.java | 28 +-
.../internals/events/CompletableEvent.java | 1 -
...merRebalanceListenerCallbackCompletedEvent.java | 31 +-
...nsumerRebalanceListenerCallbackNeededEvent.java | 30 +-
.../internals/events/ErrorBackgroundEvent.java | 59 ---
...nCloseApplicationEvent.java => ErrorEvent.java} | 23 +-
...nEvent.java => FetchCommittedOffsetsEvent.java} | 31 +-
.../internals/events/GroupMetadataUpdateEvent.java | 79 ----
...ompletableEvent.java => LeaveOnCloseEvent.java} | 9 +-
...ApplicationEvent.java => ListOffsetsEvent.java} | 33 +-
.../NewTopicsMetadataUpdateRequestEvent.java | 7 -
.../internals/events/PollApplicationEvent.java | 57 ---
...OnCloseApplicationEvent.java => PollEvent.java} | 21 +-
...licationEvent.java => ResetPositionsEvent.java} | 4 +-
...tionEvent.java => SubscriptionChangeEvent.java} | 4 +-
...tApplicationEvent.java => SyncCommitEvent.java} | 17 +-
.../events/TopicMetadataApplicationEvent.java | 78 ----
...plicationEvent.java => TopicMetadataEvent.java} | 22 +-
...ApplicationEvent.java => UnsubscribeEvent.java} | 5 +-
...ationEvent.java => ValidatePositionsEvent.java} | 4 +-
.../internals/metrics/RebalanceMetricsManager.java | 114 +++++
.../kafka/common/network/SslTransportLayer.java | 7 +-
.../kafka/common/requests/ListOffsetsRequest.java | 2 +
.../OAuthBearerClientInitialResponse.java | 2 +-
.../org/apache/kafka/clients/MetadataTest.java | 106 +++++
.../kafka/clients/admin/KafkaAdminClientTest.java | 124 ++++-
.../internals/AbstractStickyAssignorTest.java | 65 ++-
.../consumer/internals/AsyncKafkaConsumerTest.java | 503 ++++++++++-----------
.../internals/CommitRequestManagerTest.java | 2 -
.../internals/ConsumerNetworkThreadTest.java | 54 +--
.../consumer/internals/ConsumerTestBuilder.java | 26 +-
.../internals/CoordinatorRequestManagerTest.java | 6 +-
.../internals/HeartbeatRequestManagerTest.java | 105 +----
.../internals/MembershipManagerImplTest.java | 268 +++++++++--
.../internals/OffsetsRequestManagerTest.java | 6 +-
.../consumer/internals/RequestManagersTest.java | 70 +++
.../consumer/internals/WakeupTriggerTest.java | 39 ++
.../events/ApplicationEventProcessorTest.java | 4 +-
.../common/network/SslTransportLayerTest.java | 60 +++
.../OAuthBearerClientInitialResponseTest.java | 12 +
.../test/java/org/apache/kafka/test/TestUtils.java | 9 +
.../java/org/apache/kafka/connect/data/Values.java | 20 +-
.../org/apache/kafka/connect/data/ValuesTest.java | 110 ++++-
.../util/clusters/EmbeddedKafkaCluster.java | 3 +-
.../scala/kafka/admin/ConsumerGroupCommand.scala | 107 +++--
core/src/main/scala/kafka/log/LogCleaner.scala | 12 +-
core/src/main/scala/kafka/log/UnifiedLog.scala | 56 ++-
core/src/main/scala/kafka/server/KafkaConfig.scala | 76 +---
.../java/kafka/testkit/KafkaClusterTestKit.java | 3 +-
.../integration/kafka/api/BaseConsumerTest.scala | 19 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 12 +-
.../server/DynamicBrokerReconfigurationTest.scala | 32 +-
.../kafka/server/KRaftClusterTest.scala | 4 -
.../kafka/admin/ConsumerGroupCommandTest.scala | 7 +-
.../LogCleanerParameterizedIntegrationTest.scala | 12 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 8 +-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 86 ++++
.../unit/kafka/server/ControllerApisTest.scala | 13 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 18 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 18 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 2 +-
gradle/dependencies.gradle | 4 +-
.../coordinator/group/GroupCoordinatorService.java | 9 +-
.../group/runtime/CoordinatorRuntime.java | 144 +++---
.../group/runtime/EventAccumulator.java | 37 +-
.../group/runtime/MultiThreadedEventProcessor.java | 9 +-
.../group/GroupMetadataManagerTestContext.java | 12 +-
.../group/runtime/EventAccumulatorTest.java | 30 +-
.../runtime/MultiThreadedEventProcessorTest.java | 61 +--
.../placement/StripedReplicaPlacerTest.java | 2 +-
.../server/config/ServerTopicConfigSynonyms.java | 2 +-
.../org/apache/kafka/server/config/Defaults.java | 7 -
.../log/remote/storage/RemoteLogMetadata.java | 4 +-
.../kafka/storage/internals/log/CleanerConfig.java | 42 ++
.../ResponseJoinProcessorSupplier.java | 13 +
.../SubscriptionJoinProcessorSupplier.java | 6 +-
.../processor/internals/GlobalStateMaintainer.java | 2 +
.../processor/internals/GlobalStateUpdateTask.java | 20 +-
.../processor/internals/GlobalStreamThread.java | 25 +-
.../kafka/streams/state/ReadOnlyKeyValueStore.java | 2 +-
.../kafka/streams/state/ReadOnlySessionStore.java | 17 +-
.../kafka/streams/state/ReadOnlyWindowStore.java | 4 +-
.../integration/utils/EmbeddedKafkaCluster.java | 3 +-
.../ForeignTableJoinProcessorSupplierTest.java | 2 +-
.../ResponseJoinProcessorSupplierTest.java | 56 ++-
.../processor/internals/GlobalStateTaskTest.java | 111 ++++-
.../processor/internals/StateConsumerTest.java | 31 +-
.../apache/kafka/test/GlobalStateManagerStub.java | 10 +-
.../streams/scala/kstream/StreamJoinedTest.scala | 18 +-
.../apache/kafka/streams/TopologyTestDriver.java | 4 +-
tests/docker/Dockerfile | 2 +
.../java/org/apache/kafka/tools/TopicCommand.java | 10 +-
.../org/apache/kafka/tools/ToolsTestUtils.java | 2 +
.../consumer/group/ConsumerGroupCommandTest.java | 13 +-
.../consumer/group/ListConsumerGroupTest.java | 386 ++++++++++++++--
vagrant/base.sh | 2 +
128 files changed, 2919 insertions(+), 1822 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CommitOnCloseApplicationEvent.java
=> AbstractTopicMetadataEvent.java} (61%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CompletableEvent.java
=> AllTopicsMetadataEvent.java} (82%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{AssignmentChangeApplicationEvent.java
=> AssignmentChangeEvent.java} (56%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{AsyncCommitApplicationEvent.java
=> AsyncCommitEvent.java} (73%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CommitApplicationEvent.java
=> CommitEvent.java} (71%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CompletableEvent.java
=> CommitOnCloseEvent.java} (86%)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ErrorBackgroundEvent.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CommitOnCloseApplicationEvent.java
=> ErrorEvent.java} (65%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{FetchCommittedOffsetsApplicationEvent.java
=> FetchCommittedOffsetsEvent.java} (60%)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/GroupMetadataUpdateEvent.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CompletableEvent.java
=> LeaveOnCloseEvent.java} (85%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ListOffsetsApplicationEvent.java
=> ListOffsetsEvent.java} (69%)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/PollApplicationEvent.java
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{CommitOnCloseApplicationEvent.java
=> PollEvent.java} (70%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ResetPositionsApplicationEvent.java
=> ResetPositionsEvent.java} (89%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{SubscriptionChangeApplicationEvent.java
=> SubscriptionChangeEvent.java} (90%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{SyncCommitApplicationEvent.java
=> SyncCommitEvent.java} (73%)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicMetadataApplicationEvent.java
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{LeaveOnCloseApplicationEvent.java
=> TopicMetadataEvent.java} (66%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{UnsubscribeApplicationEvent.java
=> UnsubscribeEvent.java} (91%)
rename
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ValidatePositionsApplicationEvent.java
=> ValidatePositionsEvent.java} (89%)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceMetricsManager.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestManagersTest.java
