Skip to content
代码片段 群组 项目
  1. 10月 06, 2022
  2. 9月 30, 2022
  3. 9月 29, 2022
  4. 9月 28, 2022
    • ConfluentSemaphore's avatar
    • Aneesh Garg's avatar
      MINOR: Add configurable max receive size for SASL authentication requests (#7505) · 5021a33e
      Aneesh Garg 创作于
      
      This adds a new configuration `sasl.server.max.receive.size` that sets the maximum receive size for requests before and during authentication.
      
      Reviewers: Tom Bentley <tbentley@redhat.com>, Mickael Maison <mickael.maison@gmail.com>
      
      Co-authored-by: default avatarManikumar Reddy <manikumar.reddy@gmail.com>
      Co-authored-by: default avatarMickael Maison <mickael.maison@gmail.com>
      
      Co-authored-by: default avatarManikumar Reddy <manikumar.reddy@gmail.com>
      Co-authored-by: default avatarMickael Maison <mickael.maison@gmail.com>
      5021a33e
    • ConfluentSemaphore's avatar
    • Feng Min's avatar
    • Feng Min's avatar
      Merge commit '28d5a059' into sync-upstream-30-aug-2022 · 51d2c7c3
      Feng Min 创作于
      Sync ccs/master into ce-kafka/master up to 08/30/2022
      
      Fairly easy conflict to resolve as most of PR has been cherry-picked.
      
      Conflicts to be solved:
       	both modified:   core/src/main/scala/kafka/admin/FeatureCommand.scala
      	both modified:   core/src/main/scala/kafka/server/ControllerServer.scala
      	both modified:   core/src/test/java/kafka/testkit/KafkaClusterTestKit.java
      	both modified:   core/src/test/scala/integration/kafka/server/MetadataVersionIntegrationTest.scala
      	both modified:   core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
      	both modified:   core/src/test/scala/other/kafka/StressTestLog.scala
      	both modified:   core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala
      	both modified:   core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
      	both modified:   core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala
      	both modified:   core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogCleanerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogLoaderTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogManagerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/log/LogTestUtils.scala
      	deleted by us:   core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala
      	both modified:   core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala
      	both modified:   core/src/test/scala/unit/kafka/tools/StorageToolTest.scala
      	both modified:   core/src/test/scala/unit/kafka/utils/SchedulerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/utils/TestUtils.scala
      	both modified:   docs/upgrade.html
      	both modified:   metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
      	both modified:   metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java
      	both modified:   metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
      	both modified:   metadata/src/main/java/org/apache/kafka/image/FeaturesImage.java
      	both added:      metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java
      	both modified:   metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java
      	both modified:   metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java
      	both modified:   metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
      	both added:      metadata/src/test/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectoryTest.java
      	both added:      metadata/src/test/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadataTest.java
      	both modified:   server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
      	both modified:   server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTest.java
      	both modified:   shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
      	both modified:   shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java
      	both modified:   tests/kafkatest/services/kafka/kafka.py
      
      * commit '28d5a059': (13 commits)
        KAFKA-14187: kafka-features.sh: add support for --metadata (#12571)
        KAFKA-13036: Replace EasyMock and PowerMock with Mockito for RocksDBMetricsRecorderTest (#12459)
        MINOR: Add KRaft broker api to protocol docs (#11786)
        MINOR: Displaying default entity name in MetadataShell (#12053)
        MINOR:  MINOR: Remove redundant error log in ChannelBuilder (#12539)
        KAFKA-10199: Remove tasks from state updater on shutdown (#12562)
        KAFKA-10199: Handle restored tasks output by state updater (#12554)
        MINOR: Small code cleanups in GroupCoordinator (#12563)
        MINOR: Small javadoc/code cleanups in connect api and transforms (#12558)
        KAFKA-14183; Cluster metadata bootstrap file should use header/footer (#12565)
        ...
      51d2c7c3
  5. 9月 27, 2022
加载中