This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch kafka-10867-improved-task-idling
in repository https://gitbox.apache.org/repos/asf/kafka.git.
discard 47d7856 CR feedback
discard fcfd462 rebase fix
discard 2d4e6fb Rollback streams-side metadata caching
discard d43d550 Streams changes to cope with cached metadata response
discard 251cc89 ditto
discard 674a053 disable idling for selected ITs
discard de18994 fix diff
discard bb260b1 switch default
discard 52e8afb KAFKA-10867: Improved task idling
discard 1cc0bb7 CR feedback
discard 2e46bce drop beginningOffset from the metadata
discard 3b4e86c Rollback consumer-side metadata caching
discard 3da66f1 Consumer changes to cope with cached metadata response
discard 36db117 spotbugs
discard 118ecfb fix test
discard 06b2492 fix core integration test failures
discard d091e9c tests
discard 8c7e551 KAFKA-10866: Add fetched metadata to ConsumerRecords
add 287b600 KAFKA-12210; AdminClient should use DescribeCluster API when
available (KIP-700) (#9905)
add 462c89e KAFKA-12211: don't change perm for base/state dir when no
persistent store (#9904)
add 86b9fde KAFKA-10869: Gate topic IDs behind IBP 2.8 (KIP-516) (#9814)
add 484c99e KAFKA-12175 Migrate generator module to junit5 (#9926)
add 62860fa MINOR: Remind user index file is empty when dumping
LogSegment index file (#9891)
add eb026fc KAFKA-12152; Idempotent Producer does not reset the sequence
number of partitions without in-flight batches (#9832)
add 24e7e81 MINOR: Refactor DescribeAuthorizedOperationsTest (#9938)
add 92e72f7 KAFKA-12185: fix ConcurrentModificationException in newly
added Tasks container class (#9940)
add 976e6ea MINOR: Tweak IBM i support in "stop" scripts (#9810)
add fea2f65 MINOR: Import RaftConfig config definitions into KafkaConfig
(#9916)
add 5ce8141 KAFKA-10866: Add fetched metadata to ConsumerRecords
add 746f235 tests
add 8d64a7c fix core integration test failures
add 1ffa71c fix test
add 79f8f1f spotbugs
add 88cf06a Consumer changes to cope with cached metadata response
add ce1230a Rollback consumer-side metadata caching
add 59cb4a5 drop beginningOffset from the metadata
add c2ce4c8 CR feedback
add ffbaeab guard against early long-poll return due to metadata-only
response
add 93252f6 KAFKA-10867: Improved task idling
add 4e15d21 switch default
add f59abc8 fix diff
add e205d27 disable idling for selected ITs
add 28b541d ditto
add 56fda48 Streams changes to cope with cached metadata response
add 1eeae1f Rollback streams-side metadata caching
add 57cce0e rebase fix
add 0634433 CR feedback
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 (47d7856)
\
N -- N -- N refs/heads/kafka-10867-improved-task-idling (0634433)
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:
bin/kafka-server-stop.sh | 2 +-
bin/zookeeper-server-stop.sh | 2 +-
build.gradle | 15 +-
.../kafka/clients/admin/KafkaAdminClient.java | 65 ++++-
.../producer/internals/RecordAccumulator.java | 14 +-
.../producer/internals/TransactionManager.java | 59 +++--
.../org/apache/kafka/common/config/ConfigDef.java | 5 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 108 ++++++--
.../clients/producer/internals/SenderTest.java | 279 ++++++++++++++++++++-
.../producer/internals/TransactionManagerTest.java | 5 +
.../test/java/org/apache/kafka/test/TestUtils.java | 9 +
core/src/main/scala/kafka/api/ApiVersion.scala | 2 +-
.../controller/ControllerChannelManager.scala | 4 +-
.../scala/kafka/controller/KafkaController.scala | 12 +-
core/src/main/scala/kafka/raft/RaftManager.scala | 6 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 38 ++-
.../main/scala/kafka/server/ZkAdminManager.scala | 2 +-
.../main/scala/kafka/tools/DumpLogSegments.scala | 5 +
core/src/main/scala/kafka/zk/AdminZkClient.scala | 21 +-
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 22 +-
core/src/main/scala/kafka/zk/ZkData.scala | 4 +-
.../api/DescribeAuthorizedOperationsTest.scala | 146 ++++++-----
.../kafka/api/PlaintextConsumerTest.scala | 36 ++-
...PreferredReplicaLeaderElectionCommandTest.scala | 2 +-
.../controller/ControllerIntegrationTest.scala | 119 ++++++++-
.../kafka/security/auth/ZkAuthorizationTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 58 ++++-
.../TopicIdWithOldInterBrokerProtocolTest.scala | 66 +++++
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 15 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 12 +-
.../org/apache/kafka/message/CodeBufferTest.java | 35 ++-
.../org/apache/kafka/message/EntityTypeTest.java | 16 +-
.../kafka/message/IsNullConditionalTest.java | 18 +-
.../kafka/message/MessageDataGeneratorTest.java | 18 +-
.../apache/kafka/message/MessageGeneratorTest.java | 16 +-
.../apache/kafka/message/StructRegistryTest.java | 27 +-
.../kafka/message/VersionConditionalTest.java | 38 ++-
.../org/apache/kafka/message/VersionsTest.java | 33 +--
raft/README.md | 6 +-
.../java/org/apache/kafka/raft/RaftConfig.java | 169 +++++--------
.../apache/kafka/raft/RaftClientTestContext.java | 10 +-
.../java/org/apache/kafka/raft/RaftConfigTest.java | 76 ------
.../apache/kafka/raft/RaftEventSimulationTest.java | 11 +-
.../java/org/apache/kafka/raft/RaftTestUtil.java | 65 -----
.../processor/internals/StateDirectory.java | 45 ++--
.../kafka/streams/processor/internals/Tasks.java | 6 +-
.../processor/internals/StateDirectoryTest.java | 15 +-
.../processor/internals/TaskManagerTest.java | 168 ++++++++-----
tests/kafkatest/services/kafka/kafka.py | 32 +++
tests/kafkatest/tests/core/downgrade_test.py | 8 +
tests/kafkatest/tests/core/upgrade_test.py | 14 +-
tests/kafkatest/version.py | 8 +
53 files changed, 1300 insertions(+), 671 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/MetadataRequestIBPTest/TopicIdWithOldInterBrokerProtocolTest.scala
delete mode 100644 raft/src/test/java/org/apache/kafka/raft/RaftConfigTest.java
delete mode 100644 raft/src/test/java/org/apache/kafka/raft/RaftTestUtil.java
