Skip to content
代码片段 群组 项目
  1. 9月 09, 2020
  2. 9月 08, 2020
  3. 9月 07, 2020
  4. 9月 05, 2020
    • ConfluentSemaphore's avatar
    • Vikas Singh's avatar
      CNKAF-1087: Fix rack aware topic placement for cloud use case (#2491) · ff95eedb
      Vikas Singh 创作于
      * CNKAF-1087: Fix rack aware topic placement for cloud use case
      
      In cloud deployements the partition assigment is done by
      TenantPartitionAssignor class. The class relies on cluster metadata from
      the callback that is called by 'UpdateMetadataRequest' api. In this
      callback we have bug where rack information isn't propagated, hence we
      end up doing rack unaware assignment.
      
      This change fixes that by passign rack information in the callback. The
      fix is just one line in MetadataCache. Most of the change is adding
      integration tests to make sure TenantPartitionAssignor works as expected
      for cloud use case, for both rack aware and unaware case.
      
      The newly written rack aware test case fails w/o this change and passes
      with this change.
      ff95eedb
  5. 9月 04, 2020
  6. 9月 03, 2020
  7. 9月 02, 2020
    • ConfluentSemaphore's avatar
    • aloknnikhil's avatar
      CNKAF-902: Add metrics to track SSL handshake failures and avg/max time (#2475) · 6de8bc40
      aloknnikhil 创作于
      * CNKAF-697 - High bandwidth throttles during cluster roll
      
      - The quotas are configured with a minimum and a maximum per producer/consumer per tenant per broker.
      - The maximum is universal and is applicable to both followers and leaders.
        However, only the leaders ever reach the maximum quota.
      - The minimum is exclusively followed by the followers for cases when the cluster
        needs to roll (i.e. follower becomes a leader).
      - During this transition, it's necessary to maintain the throughput before the maximum quota is applied.
      - Per-broker tenant quota is always greater than zero to avoid excessive throttling of requests
        received before cluster metadata or quota configs are refreshed. These expose the configuration
        allowing this to be tuned at broker startup.
      
      Parameters added:
      ```java
      confluent.quota.tenant.follower.broker.min.producer.rate
      confluent.quota.tenant.follower.broker.min.consumer.rate
      ```
      
      Also, refactored quota configuration parameters into ConfluentConfigs
      and marked as internal.
      
      * Fix checkstyle issue
      
      * Addressing comments
      
      * CNKAF-902: Add metrics for SSL handshake failures + time
      
      - Max + avg (ns) time for a connection handshake
      - Cumulative count + rate of handshake failures
      
      * Add unit-tests for SSL handshake metrics
      
      * Timeout if handshakes are not drained
      6de8bc40
    • An Qi Wu's avatar
  8. 9月 01, 2020
加载中