派生自
oss-mirrors / ICV / kafka
5843 提交 落后, 3621 提交 领先 上游代码库。
-
由 Dhruvil Shah 创作于
* ckafka/master: (64 commits) CONFLUENT: Sync from apache/kafka (29 April 2020) MINOR: Fix broken JMX link in docs by adding missing starting double quote (#8587) KAFKA-9652: Fix throttle metric in RequestChannel and request log due to KIP-219 (#8567) KAFKA-9922: Update demo instructions in examples README (#8559) KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses (#8442) KAFKA-9875: Make integration tests more resilient (#8578) KAFKA-9932: Don't load configs from ZK when the log has already been loaded (#8582) KAFKA-9925: decorate pseudo-topics with app id (#8574) KAFKA-9832: fix attempt to commit non-running tasks (#8580) KAFKA-9127: don't create StreamThreads for global-only topology (#8540) MINOR: add support for kafka 2.4 and 2.5 to downgrade test KAFKA-9176: Retry on getting local stores from KafkaStreams (#8568) KAFKA-9823: Follow-up, check state for handling commit error response (#8548) KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) MINOR: Fix partition numbering from 0 to P-1 instead of P in docs (#8572) KAFKA-9921: disable caching on stores configured to retain duplicates (#8564) Minor: remove redundant check in auto preferred leader election (#8566) MINOR: Update the link to the Raft paper in docs (#8560) MINOR: Fix typos in config properties in MM2 test (#8561) MINOR: Improve producer test BufferPoolTest#testCloseNotifyWaiters. (#7982) ... Conflicts: Jenkinsfile build.gradle clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java clients/src/main/java/org/apache/kafka/common/protocol/Errors.java clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java core/src/main/scala/kafka/admin/ConfigCommand.scala core/src/main/scala/kafka/cluster/Partition.scala core/src/main/scala/kafka/log/LogManager.scala core/src/main/scala/kafka/network/RequestChannel.scala core/src/main/scala/kafka/network/SocketServer.scala core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala core/src/main/scala/kafka/server/ClientQuotaManager.scala core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/server/ReplicaManager.scala core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala core/src/test/scala/unit/kafka/cluster/PartitionTest.scala core/src/test/scala/unit/kafka/server/BaseRequestTest.scala core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala gradle.properties gradle/dependencies.gradle tests/kafkatest/tests/core/downgrade_test.py
由 Dhruvil Shah 创作于* ckafka/master: (64 commits) CONFLUENT: Sync from apache/kafka (29 April 2020) MINOR: Fix broken JMX link in docs by adding missing starting double quote (#8587) KAFKA-9652: Fix throttle metric in RequestChannel and request log due to KIP-219 (#8567) KAFKA-9922: Update demo instructions in examples README (#8559) KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses (#8442) KAFKA-9875: Make integration tests more resilient (#8578) KAFKA-9932: Don't load configs from ZK when the log has already been loaded (#8582) KAFKA-9925: decorate pseudo-topics with app id (#8574) KAFKA-9832: fix attempt to commit non-running tasks (#8580) KAFKA-9127: don't create StreamThreads for global-only topology (#8540) MINOR: add support for kafka 2.4 and 2.5 to downgrade test KAFKA-9176: Retry on getting local stores from KafkaStreams (#8568) KAFKA-9823: Follow-up, check state for handling commit error response (#8548) KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) MINOR: Fix partition numbering from 0 to P-1 instead of P in docs (#8572) KAFKA-9921: disable caching on stores configured to retain duplicates (#8564) Minor: remove redundant check in auto preferred leader election (#8566) MINOR: Update the link to the Raft paper in docs (#8560) MINOR: Fix typos in config properties in MM2 test (#8561) MINOR: Improve producer test BufferPoolTest#testCloseNotifyWaiters. (#7982) ... Conflicts: Jenkinsfile build.gradle clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java clients/src/main/java/org/apache/kafka/common/protocol/Errors.java clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java core/src/main/scala/kafka/admin/ConfigCommand.scala core/src/main/scala/kafka/cluster/Partition.scala core/src/main/scala/kafka/log/LogManager.scala core/src/main/scala/kafka/network/RequestChannel.scala core/src/main/scala/kafka/network/SocketServer.scala core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala core/src/main/scala/kafka/server/ClientQuotaManager.scala core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/server/ReplicaManager.scala core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala core/src/test/scala/unit/kafka/cluster/PartitionTest.scala core/src/test/scala/unit/kafka/server/BaseRequestTest.scala core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala gradle.properties gradle/dependencies.gradle tests/kafkatest/tests/core/downgrade_test.py
jenkins.sh 3.24 KiB