This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch KAFKA-18223-gha-1
in repository https://gitbox.apache.org/repos/asf/kafka.git
omit 7fc2d4f654d empty
omit 1f8ca8dc5a1 trying org secret
omit aca88a5740f try DEVELOCITY_ACCESS_KEY
omit 7f42ecfc318 add env
omit e3d722c9359 fix command
omit fe59cb4c0d5 add GHA to run report
add 3b1bd3812e4 KAFKA-16368: Update remote.log.manager.* default thread
pool values for KIP-1030 (#18137)
add 9b776ffc50c KAFKA-18026: KIP-1112 convert StreamToTableNode (#18149)
add ef2e4600f37 KAFKA-18026: KIP-1112, migrate stream-stream joins to use
ProcesserSupplier#stores (#18111)
add ce77a7413ed KAFKA-18194 Flaky test_broker_rolling_bounce due to
metadata update (#18153)
add baa870a5829 KAFKA-18214 TestUtils#waitForCondition does not honor the
maxWaitMs (#18145)
add 92352a96e86 MINOR: ensure SuppressWarnings annotation is effective for
mockValidationIsolation (#18158)
add d7c80a7257d MINOR: update Kafka version for docker scan
add 747dc172e87 KIP-1073: Return fenced brokers in DescribeCluster
response (#17524)
add d5ad9228cf4 KAFKA-17750; Extend kafka-consumer-groups command line
tool to support new consumer group (part 3) (#18141)
add 770d64d2ccb KAFKA-16143: New JMX metrics for AsyncKafkaConsumer
(#17199)
add b94defa1898 KAFKA-18199; Fix size calculation for nullable tagged
structs (#18127)
add 714038dbebb add GHA to run report
add 07a9480bfb9 fix command
add 935ba0b60d8 add env
add e050b2a9718 try DEVELOCITY_ACCESS_KEY
add 432a7a07ea1 trying org secret
add 627c6e65480 empty
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 (7fc2d4f654d)
\
N -- N -- N refs/heads/KAFKA-18223-gha-1 (627c6e65480)
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:
.github/workflows/docker_scan.yml | 2 +-
.../clients/admin/DescribeClusterOptions.java | 15 ++
.../kafka/clients/admin/KafkaAdminClient.java | 13 +-
.../consumer/internals/AsyncKafkaConsumer.java | 84 +++---
.../consumer/internals/ConsumerNetworkThread.java | 22 +-
.../clients/consumer/internals/ConsumerUtils.java | 1 +
.../consumer/internals/NetworkClientDelegate.java | 31 ++-
.../consumer/internals/ShareConsumerImpl.java | 26 +-
.../internals/events/ApplicationEvent.java | 16 +-
.../internals/events/ApplicationEventHandler.java | 13 +-
.../consumer/internals/events/BackgroundEvent.java | 16 +-
.../internals/events/BackgroundEventHandler.java | 30 ++-
.../internals/events/CompletableEventReaper.java | 24 +-
.../internals/metrics/AsyncConsumerMetrics.java | 262 ++++++++++++++++++
.../main/java/org/apache/kafka/common/Node.java | 26 +-
.../common/requests/DescribeClusterResponse.java | 2 +-
.../common/message/DescribeClusterRequest.json | 7 +-
.../common/message/DescribeClusterResponse.json | 7 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 17 ++
.../internals/ApplicationEventHandlerTest.java | 73 +++++
.../consumer/internals/AsyncKafkaConsumerTest.java | 33 ++-
.../internals/BackgroundEventHandlerTest.java | 65 +++++
.../internals/ConsumerMembershipManagerTest.java | 3 +-
.../internals/ConsumerNetworkThreadTest.java | 99 ++++++-
.../internals/FetchRequestManagerTest.java | 3 +-
.../internals/NetworkClientDelegateTest.java | 53 +++-
.../internals/ShareConsumeRequestManagerTest.java | 15 +-
.../consumer/internals/ShareConsumerImplTest.java | 2 +-
.../events/CompletableEventReaperTest.java | 16 +-
.../metrics/AsyncConsumerMetricsTest.java | 237 ++++++++++++++++
.../common/message/NullableStructMessageTest.java | 26 ++
.../common/message/SimpleExampleMessageTest.java | 2 +
.../kafka/connect/runtime/AbstractHerderTest.java | 2 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 8 +-
.../main/scala/kafka/server/MetadataCache.scala | 2 +
.../kafka/server/metadata/KRaftMetadataCache.scala | 4 +
.../kafka/server/metadata/ZkMetadataCache.scala | 4 +
.../kafka/api/PlaintextAdminIntegrationTest.scala | 24 ++
.../kafka/api/SslAdminIntegrationTest.scala | 23 +-
docs/upgrade.html | 14 +
.../apache/kafka/message/MessageDataGenerator.java | 19 +-
.../apache/kafka/metadata/BrokerRegistration.java | 2 +-
.../kafka/metadata/BrokerRegistrationTest.java | 2 +-
.../log/remote/storage/RemoteLogManagerConfig.java | 17 +-
.../remote/storage/RemoteLogManagerConfigTest.java | 6 +-
.../kstream/internals/InternalStreamsBuilder.java | 4 +-
.../streams/kstream/internals/KStreamImpl.java | 3 +-
.../streams/kstream/internals/KStreamImplJoin.java | 33 +--
.../kstream/internals/KStreamJoinWindow.java | 19 +-
.../kstream/internals/KStreamKStreamJoin.java | 37 ++-
.../internals/KStreamKStreamJoinLeftSide.java | 13 +-
.../internals/KStreamKStreamJoinRightSide.java | 13 +-
.../kstream/internals/KStreamKStreamSelfJoin.java | 27 +-
.../internals/graph/BaseJoinProcessorNode.java | 1 -
.../internals/graph/StreamStreamJoinNode.java | 131 +++------
.../kstream/internals/graph/StreamToTableNode.java | 29 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 215 ++++++++++++++-
.../kstream/internals/KStreamKStreamJoinTest.java | 53 ++--
.../kafka/common/test/KafkaClusterTestKit.java | 7 +-
.../org/apache/kafka/common/test/TestUtils.java | 33 +--
tests/kafkatest/services/verifiable_consumer.py | 4 +-
tests/kafkatest/tests/client/consumer_test.py | 7 +-
.../java/org/apache/kafka/tools/ClusterTool.java | 62 ++++-
.../tools/consumer/group/ConsumerGroupCommand.java | 244 +++++++++++------
.../tools/consumer/group/GroupInformation.java | 16 +-
.../consumer/group/MemberAssignmentState.java | 24 +-
.../consumer/group/PartitionAssignmentState.java | 19 +-
.../kafka/tools/BrokerApiVersionsCommandTest.java | 2 +-
.../org/apache/kafka/tools/ClusterToolTest.java | 50 ++++
.../group/ConsumerGroupCommandTestUtils.java | 12 +-
.../consumer/group/ConsumerGroupServiceTest.java | 47 +++-
.../consumer/group/DeleteConsumerGroupsTest.java | 2 +-
.../consumer/group/DescribeConsumerGroupTest.java | 300 +++++++++++++++++----
73 files changed, 2245 insertions(+), 530 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/AsyncConsumerMetrics.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ApplicationEventHandlerTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/BackgroundEventHandlerTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/AsyncConsumerMetricsTest.java
