Skip to content
代码片段 群组 项目
  • Dhruvil Shah's avatar
    484f1172
    Merge remote-tracking branch 'ckafka/master' into sync-upstream-4-30 · 484f1172
    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
    484f1172
    历史
    Merge remote-tracking branch 'ckafka/master' into sync-upstream-4-30
    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