Skip to content

new Kafka Broker/Channel/Sink requests "CreateTopics" n times #4406

@matzew

Description

@matzew

with 1.16 we noticed a couple of unneeded "Create Topic Requests":

shark -r ...kafka-controller-b4c646559-khnl2 | grep Kafka 
 1636  52.524158  10.131.0.63 → 172.30.179.71 Kafka 91 Kafka Metadata v7 Request
 1641  52.525098 172.30.179.71 → 10.131.0.63  Kafka 309 Kafka Metadata v7 Response
 1658  52.528969  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 1660  52.560470  10.128.2.29 → 10.131.0.63  Kafka 116 Kafka CreateTopics v3 Response
 2074  52.748347  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2075  52.749500  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2212  52.793653  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2213  52.794762  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2343  52.819567  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2344  52.820512  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2481  52.863093  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2482  52.864078  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2687  53.691616  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2688  53.692715  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2814  53.768847  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2815  53.769924  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 
 2928  53.816665  10.131.0.63 → 10.128.2.29  Kafka 139 Kafka CreateTopics v3 Request
 2929  53.817722  10.128.2.29 → 10.131.0.63  Kafka 168 Kafka CreateTopics v3 Response [Topic already exists] 

The creation of the topic should be skipped if the condition of type: TopicReady is already True

Metadata

Metadata

Assignees

No one assigned

    Labels

    kind/bugCategorizes issue or PR as related to a bug.

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions