Skip to content
代码片段 群组 项目
  1. 9月 27, 2022
  2. 9月 24, 2022
    • ConfluentSemaphore's avatar
    • Aishwarya Gune's avatar
      KAFKALESS-1210: Remove version from RawMetricType and its usages (#7412) · 69127191
      Aishwarya Gune 创作于
      * Remove version from RawMetricType and its usages
      69127191
    • Feng Min's avatar
      Sync ccs/master into ce-kafka/master up to 08/25/2022 · 9fdc713c
      Feng Min 创作于
      Notable conflicts.
      * KAFKA-13850(
      https://github.com/confluentinc/kafka/commit/19581effbf9265db318f855cc37f6b0526c1b544) and KMETA-290(https://github.com/confluentinc/ce-kafka/commit/53cabfd3a80f3533e49489ee31fd3879b7d52454) are not compatible. KAFKA-13850 ends up mostly dropped.
      * A bunch of upstream connect cleanup conflict with our own non-ak files in ce-kafka
      
      Conflicts to be solved:
      	both modified:   clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java
      	both modified:   clients/src/main/java/org/apache/kafka/common/requests/AllocateProducerIdsResponse.java
      	both modified:   clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java
      	both modified:   clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
      	both modified:   connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java
      	both modified:   connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
      	both modified:   connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java
      	both modified:   connect/runtime/src/test/java/org/apache/kafka/connect/util/ConnectUtilsTest.java
      	both modified:   core/src/main/java/kafka/server/builders/LogManagerBuilder.java
      	both modified:   core/src/main/scala/kafka/controller/KafkaController.scala
      	both modified:   core/src/main/scala/kafka/log/LogManager.scala
      	both modified:   core/src/main/scala/kafka/raft/RaftManager.scala
      	both modified:   core/src/main/scala/kafka/server/BrokerServer.scala
      	both modified:   core/src/main/scala/kafka/server/ControllerApis.scala
      	both modified:   core/src/main/scala/kafka/server/ControllerServer.scala
      	both modified:   core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
      	both modified:   core/src/main/scala/kafka/server/KafkaConfig.scala
      	both modified:   core/src/main/scala/kafka/server/KafkaServer.scala
      	both modified:   core/src/main/scala/kafka/server/ReplicationQuotaManager.scala
      	both modified:   core/src/main/scala/kafka/server/Server.scala
      	both modified:   core/src/main/scala/kafka/tools/DumpLogSegments.scala
      	both modified:   core/src/main/scala/kafka/tools/StorageTool.scala
      	both modified:   core/src/main/scala/kafka/utils/KafkaScheduler.scala
      	both modified:   core/src/test/java/kafka/test/ClusterInstance.java
      	both modified:   core/src/test/java/kafka/test/junit/RaftClusterInvocationContext.java
      	both modified:   core/src/test/java/kafka/testkit/KafkaClusterTestKit.java
      	both added:      core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala
      	both modified:   core/src/test/scala/integration/kafka/api/TransactionsExpirationTest.scala
      	both modified:   core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala
      	both modified:   core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
      	both modified:   core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala
      	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/AddPartitionsTest.scala
      	both added:      core/src/test/scala/unit/kafka/admin/MetadataQuorumCommandTest.scala
      	both modified:   core/src/test/scala/unit/kafka/controller/ControllerContextTest.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/integration/KafkaServerTestHarness.scala
      	both modified:   core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.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/LocalLogTest.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/network/SocketServerTest.scala
      	both added:      core/src/test/scala/unit/kafka/server/AllocateProducerIdsRequestTest.scala
      	both modified:   core/src/test/scala/unit/kafka/server/ControllerApisTest.scala
      	both modified:   core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
      	both modified:   core/src/test/scala/unit/kafka/server/KafkaRaftServerTest.scala
      	both modified:   core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.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
      	deleted by them: metadata/src/main/java/org/apache/kafka/controller/BootstrapMetadata.java
      	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 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 modified:   metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
      	both added:      retry_zinc
      	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
      9fdc713c
    • ConfluentSemaphore's avatar
    • Akhilesh C's avatar
      KAFKA-14214: Introduce read-write lock to StandardAuthorizer for consistent... · 536e3368
      Akhilesh C 创作于
      KAFKA-14214: Introduce read-write lock to StandardAuthorizer for consistent ACL reads. (#12628) (#7535)
      
      Fixes an issue with StandardAuthorizer#authorize that allowed inconsistent results. The underlying
      concurrent data structure (ConcurrentSkipListMap) had weak consistency guarantees. This meant
      that a concurrent update to the authorizer data could result in the authorize function processing
      ACL updates out of order.
      
      This patch replaces the concurrent data structures with regular non-thread safe equivalents and uses
      a read/write lock for thread safety and strong consistency.
      
      Reviewers: David Arthur <mumrah@gmail.com>, Jason Gustafson <jason@confluent.io>, Colin P. McCabe <cmccabe@apache.org>, Luke Chen <showuon@gmail.com>
      
      Conflicts:
      	metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
      	metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
      
      Changes to be committed:
      	modified:   metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAcl.java
      	modified:   metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
      	modified:   metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
      536e3368
    • ConfluentSemaphore's avatar
    • Eric Sirianni's avatar
      Add new TelemetrySubmitter role [METRICS-4564] (#7275) · 9e0c1c7e
      Eric Sirianni 创作于
      Add new TelemetrySubmitter role.
      
      This role grants privilege to submit metrics to the Confluent Telemetry Receiver (https://collector.telemetry.confluent.cloud).
      The role will be used by BYOC automation as part of provisioning a Service Account & API Key that will be injected into
      BYOC clusters TelemetryReporter configuration.
      9e0c1c7e
    • Stanislav Kozlovski's avatar
      b29e2ae8
    • Stanislav Kozlovski's avatar
      MINOR: Simplify SBC's Entity interface and the rest of the metric... · c509de84
      Stanislav Kozlovski 创作于
      MINOR: Simplify SBC's Entity interface and the rest of the metric (aggregator,sample) interfaces (#7521)
      
      This patch does one simple thing - it simplifies the generic configurable Entity<G> interface to an Entity. The reasoning is that all of our entities (including the test ones) use String, and for 2+ years we have never had reason to change this. Even recently while we've been extending the entities by adding a ReplicaEntity, we still use a String. It is unlikely we will need to use another type anytime soon, and the simplification benefits are high.
      
      By doing that, a lot of other valuable downstream simplifications happen - MetricSampleAggregator, AggregationOptions, MetricSample, MetricSampleCompleteness, MetricAggregationResult - all used a complex <G, E> generic interface, where G was always String.
      c509de84
  3. 9月 23, 2022
加载中