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.lifecycle/staleDenotes an issue or PR has remained open with no activity and has become stale.

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions