Page History

...

The coupling of the KafkaController and KafkaApi is complicated. Let's start from a class diagram indicating existing and new class properties and methods. New method and properties proposed are prefixed by `+`

Image Modified

1. When a topic gets created, clients will pass the topic config `internal` to servers so Zookeeper will aware of the client-created internal topics.
2. KafkaZkClient will be able to query all the internal topics.
3. KafkaController can then utilize the information provided by KafkaZkClient and wrap a boolean field in its UpdateMetadataRequests to all the servers, which indicates if the topic is internal or not.

...