Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

LIKAFKA-41423: Kafka federation proof of concept using dual-cluster integration test (ProxyBasedFederationTest) #326

Open
wants to merge 9 commits into
base: 2.4-li
Choose a base branch
from
Open

LIKAFKA-41423: Kafka federation proof of concept using dual-cluster integration test (ProxyBasedFederationTest) #326

wants to merge 9 commits into from

Commits on Feb 10, 2022

  1. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test (ProxyBasedFederationTest). Main changes live in KafkaController, ControllerChannelManager, KafkaApis, MetadataCache, and UpdateMetadataRequest itself (both .java and .json).
    @groelofs
    groelofs committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    7d0f719 View commit details
    Browse the repository at this point in the history

  2. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test. (Fix for overlooked merge bug/typo.)
    @groelofs
    groelofs committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    fa534d4 View commit details
    Browse the repository at this point in the history

  3. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test. (Fix for infinite loop in testBasicMultiClusterSetup(), plus indentation fix for ControllerChannelManager and cleanup of obsolete debug noise in KafkaController.)
    @groelofs
    groelofs committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    5e83597 View commit details
    Browse the repository at this point in the history

Commits on Feb 16, 2022

  1. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test. (Code-review fixes: refactor MetadataCache into legacy and federated-subclass variants, and merge ControllerChannelManager's brokerStateInfo and remoteControllerStateInfo maps in favor of simple remoteControllerIds hashset to mark remote controllers.)
    @groelofs
    groelofs committed Feb 16, 2022
    Configuration menu
    Copy the full SHA
    91da79d View commit details
    Browse the repository at this point in the history

  2. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test. (Code-review fixes: rename UMR 'ClusterId' to 'OriginClusterId', and this time include new FederatedMetadataCache class, doh...)
    @groelofs
    groelofs committed Feb 16, 2022
    Configuration menu
    Copy the full SHA
    b1718a4 View commit details
    Browse the repository at this point in the history

Commits on Feb 19, 2022

  1. Forward the UMR inside the ControllerEvent thread

    @gitlw
    gitlw committed Feb 19, 2022
    1 Configuration menu
    Copy the full SHA
    6da08dd View commit details
    Browse the repository at this point in the history

Commits on Mar 8, 2022

  1. Polishing logs and removed some comments

    @gitlw
    gitlw committed Mar 8, 2022
    Configuration menu
    Copy the full SHA
    f7fc2e7 View commit details
    Browse the repository at this point in the history

Commits on Mar 9, 2022

  1. Fixing bug on when the UMR should be forwarded

    @gitlw
    gitlw committed Mar 9, 2022
    Configuration menu
    Copy the full SHA
    4af1d23 View commit details
    Browse the repository at this point in the history

Commits on Mar 29, 2022

  1. LIKAFKA-41423: Kafka federation proof of concept using dual-cluster i… 

    …ntegration test. (Add integ-test support for non-random embedded ZK ports.)
    @groelofs
    groelofs committed Mar 29, 2022
    Configuration menu
    Copy the full SHA
    0b2923b View commit details
    Browse the repository at this point in the history