Skip to content

Instantly share code, notes, and snippets.

@joekohlsdorf

joekohlsdorf/gist:983f65238691e86ddd5210d75c66b404 Secret

Created July 12, 2019 14:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save joekohlsdorf/983f65238691e86ddd5210d75c66b404 to your computer and use it in GitHub Desktop.
Save joekohlsdorf/983f65238691e86ddd5210d75c66b404 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
[2019-07-12 13:31:54,599] DEBUG <opicOperator:382> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Removing last waiter onResourceDeleted
[2019-07-12 13:31:54,599] DEBUG <opicOperator:413> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Lock released
[2019-07-12 13:31:54,599] INFO <TopicWatcher:39> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:54,599] DEBUG <opicOperator:408> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:54,596] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999)
[2019-07-12 13:31:53,791] INFO <opicOperator:343> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Deleting topic 'testtopic3'
[2019-07-12 13:31:53,790] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999)
[2019-07-12 13:31:53,790] DEBUG <opicOperator:502> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:53,790] INFO <opicOperator:460> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:53,324] DEBUG <opicOperator:417> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:53,323] DEBUG <opicOperator:405> [oop-thread-1] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Lock acquired
[2019-07-12 13:31:53,312] DEBUG <opicOperator:385> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Removing waiter onResourceModified, 1 waiters left
[2019-07-12 13:31:53,312] DEBUG <opicOperator:413> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Lock released
[2019-07-12 13:31:53,311] INFO <TopicWatcher:39> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:53,311] DEBUG <opicOperator:408> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:53,311] INFO <opicOperator:599> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: All three topics are identical
[2019-07-12 13:31:53,311] DEBUG <opicOperator:597> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:53,311] DEBUG <opicOperator:588> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:53,311] DEBUG <opicOperator:586> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:53,311] DEBUG <opicOperator:524> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: 3 way diff
[2019-07-12 13:31:53,311] INFO <opicOperator:460> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:53,210] DEBUG <opicOperator:399> [0.64.0.1/...] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Adding waiter onResourceDeleted: 2
[2019-07-12 13:31:53,210] DEBUG <opicOperator:393> [0.64.0.1/...] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:53,210] INFO <TopicWatcher:36> [0.64.0.1/...] 2585|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177999: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:52,579] DEBUG <opicOperator:417> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:52,579] DEBUG <opicOperator:405> [oop-thread-1] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Lock acquired
[2019-07-12 13:31:52,186] DEBUG <opicOperator:399> [0.64.0.1/...] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Adding waiter onResourceModified: 3
[2019-07-12 13:31:52,186] DEBUG <K8sImpl :76> [er-thread-17] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:52,186] DEBUG <opicOperator:393> [0.64.0.1/...] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:52,186] INFO <TopicWatcher:36> [0.64.0.1/...] 2544|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177980: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:52,180] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=2480|/brokers/topics -testtopic3|177878)
[2019-07-12 13:31:52,175] DEBUG <opicOperator:385> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:52,175] DEBUG <opicOperator:413> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Lock released
[2019-07-12 13:31:52,175] INFO <TopicWatcher:39> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:52,175] DEBUG <opicOperator:408> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:52,175] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878) succeeded
[2019-07-12 13:31:52,175] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878)
[2019-07-12 13:31:52,172] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878)
[2019-07-12 13:31:52,172] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878)
[2019-07-12 13:31:52,172] INFO <opicOperator:210> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:51,791] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878)
[2019-07-12 13:31:51,790] DEBUG <opicOperator:482> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:51,790] INFO <opicOperator:460> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:51,160] DEBUG <opicOperator:417> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:51,160] DEBUG <opicOperator:405> [oop-thread-1] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Lock acquired
[2019-07-12 13:31:51,160] DEBUG <opicOperator:385> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:51,160] DEBUG <opicOperator:413> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Lock released
[2019-07-12 13:31:51,159] INFO <TopicWatcher:39> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:51,159] DEBUG <opicOperator:408> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:51,157] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864)
[2019-07-12 13:31:50,416] INFO <opicOperator:343> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Deleting topic 'testtopic3'
[2019-07-12 13:31:50,416] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864)
[2019-07-12 13:31:50,416] DEBUG <opicOperator:502> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:50,415] INFO <opicOperator:460> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:50,031] DEBUG <opicOperator:417> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:50,031] DEBUG <opicOperator:405> [oop-thread-1] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Lock acquired
[2019-07-12 13:31:50,021] DEBUG <opicOperator:385> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:50,021] DEBUG <opicOperator:413> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Lock released
[2019-07-12 13:31:50,021] INFO <TopicWatcher:39> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:50,021] DEBUG <opicOperator:408> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:50,021] INFO <opicOperator:599> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: All three topics are identical
[2019-07-12 13:31:50,020] DEBUG <opicOperator:597> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:50,020] DEBUG <opicOperator:588> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:50,020] DEBUG <opicOperator:586> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:50,020] DEBUG <opicOperator:524> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: 3 way diff
[2019-07-12 13:31:50,020] INFO <opicOperator:460> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:49,351] DEBUG <opicOperator:417> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:49,351] DEBUG <opicOperator:405> [oop-thread-1] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Lock acquired
[2019-07-12 13:31:49,348] DEBUG <opicOperator:399> [0.64.0.1/...] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:49,348] DEBUG <opicOperator:393> [0.64.0.1/...] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:49,348] INFO <TopicWatcher:36> [0.64.0.1/...] 2386|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177878: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:49,347] DEBUG <K8sImpl :47> [er-thread-17] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177878
[2019-07-12 13:31:49,060] DEBUG <opicOperator:399> [0.64.0.1/...] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:49,060] DEBUG <opicOperator:393> [0.64.0.1/...] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:49,060] INFO <TopicWatcher:36> [0.64.0.1/...] 2368|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177864: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:48,908] DEBUG <K8sImpl :76> [er-thread-18] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:48,908] DEBUG <opicOperator:399> [0.64.0.1/...] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Adding waiter onResourceModified: 3
[2019-07-12 13:31:48,908] DEBUG <opicOperator:393> [0.64.0.1/...] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:48,908] INFO <TopicWatcher:36> [0.64.0.1/...] 2358|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177856: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:48,900] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=2289|/brokers/topics -testtopic3|177735)
[2019-07-12 13:31:48,896] DEBUG <opicOperator:385> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:48,896] DEBUG <opicOperator:413> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Lock released
[2019-07-12 13:31:48,896] INFO <TopicWatcher:39> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:48,895] DEBUG <opicOperator:408> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:48,895] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735) succeeded
[2019-07-12 13:31:48,895] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735)
[2019-07-12 13:31:48,893] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735)
[2019-07-12 13:31:48,893] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735)
[2019-07-12 13:31:48,893] INFO <opicOperator:210> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:48,431] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735)
[2019-07-12 13:31:48,431] DEBUG <opicOperator:482> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:48,431] INFO <opicOperator:460> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:47,864] DEBUG <opicOperator:417> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:47,864] DEBUG <opicOperator:405> [oop-thread-1] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Lock acquired
[2019-07-12 13:31:47,864] DEBUG <opicOperator:385> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:47,864] DEBUG <opicOperator:413> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Lock released
[2019-07-12 13:31:47,864] INFO <TopicWatcher:39> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:47,864] DEBUG <opicOperator:408> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:47,858] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713)
[2019-07-12 13:31:46,837] INFO <opicOperator:343> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Deleting topic 'testtopic3'
[2019-07-12 13:31:46,837] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713)
[2019-07-12 13:31:46,837] DEBUG <opicOperator:502> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:46,837] INFO <opicOperator:460> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:46,380] DEBUG <opicOperator:417> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:46,380] DEBUG <opicOperator:405> [oop-thread-1] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Lock acquired
[2019-07-12 13:31:46,364] DEBUG <opicOperator:385> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:46,364] DEBUG <opicOperator:413> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Lock released
[2019-07-12 13:31:46,363] INFO <TopicWatcher:39> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:46,363] DEBUG <opicOperator:408> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:46,363] INFO <opicOperator:599> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: All three topics are identical
[2019-07-12 13:31:46,363] DEBUG <opicOperator:597> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:46,363] DEBUG <opicOperator:588> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:46,363] DEBUG <opicOperator:586> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:46,363] DEBUG <opicOperator:524> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: 3 way diff
[2019-07-12 13:31:46,363] INFO <opicOperator:460> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:45,459] DEBUG <opicOperator:417> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:45,459] DEBUG <opicOperator:405> [oop-thread-1] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Lock acquired
[2019-07-12 13:31:45,455] DEBUG <opicOperator:399> [0.64.0.1/...] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:45,455] DEBUG <opicOperator:393> [0.64.0.1/...] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:45,455] DEBUG <K8sImpl :47> [ker-thread-3] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177735
[2019-07-12 13:31:45,455] INFO <TopicWatcher:36> [0.64.0.1/...] 2182|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177735: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:45,011] DEBUG <opicOperator:399> [0.64.0.1/...] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:45,010] DEBUG <opicOperator:393> [0.64.0.1/...] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:45,010] INFO <TopicWatcher:36> [0.64.0.1/...] 2156|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177713: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:45,004] DEBUG <opicOperator:399> [0.64.0.1/...] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Adding waiter onResourceModified: 3
[2019-07-12 13:31:45,004] DEBUG <opicOperator:393> [0.64.0.1/...] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:45,003] INFO <TopicWatcher:36> [0.64.0.1/...] 2154|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177712: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:45,003] DEBUG <K8sImpl :76> [ker-thread-1] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:44,995] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=2084|/brokers/topics -testtopic3|177612)
[2019-07-12 13:31:44,991] DEBUG <opicOperator:385> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:44,990] DEBUG <opicOperator:413> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Lock released
[2019-07-12 13:31:44,990] INFO <TopicWatcher:39> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:44,990] DEBUG <opicOperator:408> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:44,990] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612) succeeded
[2019-07-12 13:31:44,990] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612)
[2019-07-12 13:31:44,988] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612)
[2019-07-12 13:31:44,987] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612)
[2019-07-12 13:31:44,987] INFO <opicOperator:210> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:44,501] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612)
[2019-07-12 13:31:44,501] DEBUG <opicOperator:482> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:44,501] INFO <opicOperator:460> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:43,985] DEBUG <opicOperator:417> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:43,985] DEBUG <opicOperator:405> [oop-thread-1] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Lock acquired
[2019-07-12 13:31:43,985] DEBUG <opicOperator:385> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:43,985] DEBUG <opicOperator:413> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Lock released
[2019-07-12 13:31:43,985] INFO <TopicWatcher:39> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:43,985] DEBUG <opicOperator:408> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:43,982] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593)
[2019-07-12 13:31:42,992] INFO <opicOperator:343> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Deleting topic 'testtopic3'
[2019-07-12 13:31:42,992] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593)
[2019-07-12 13:31:42,991] DEBUG <opicOperator:502> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:42,991] INFO <opicOperator:460> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:42,538] DEBUG <opicOperator:417> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:42,538] DEBUG <opicOperator:405> [oop-thread-1] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Lock acquired
[2019-07-12 13:31:42,526] DEBUG <opicOperator:385> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:42,526] DEBUG <opicOperator:413> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Lock released
[2019-07-12 13:31:42,526] INFO <TopicWatcher:39> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:42,526] DEBUG <opicOperator:408> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:42,526] INFO <opicOperator:599> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: All three topics are identical
[2019-07-12 13:31:42,526] DEBUG <opicOperator:597> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:42,526] DEBUG <opicOperator:588> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:42,526] DEBUG <opicOperator:586> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:42,526] DEBUG <opicOperator:524> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: 3 way diff
[2019-07-12 13:31:42,525] INFO <opicOperator:460> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:41,769] DEBUG <opicOperator:417> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:41,769] DEBUG <opicOperator:405> [oop-thread-1] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Lock acquired
[2019-07-12 13:31:41,764] DEBUG <K8sImpl :47> [er-thread-12] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177612
[2019-07-12 13:31:41,764] DEBUG <opicOperator:399> [0.64.0.1/...] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:41,764] DEBUG <opicOperator:393> [0.64.0.1/...] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:41,764] INFO <TopicWatcher:36> [0.64.0.1/...] 1989|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177612: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:41,461] DEBUG <opicOperator:399> [0.64.0.1/...] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:41,461] DEBUG <opicOperator:393> [0.64.0.1/...] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:41,461] INFO <TopicWatcher:36> [0.64.0.1/...] 1966|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177593: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:41,454] DEBUG <opicOperator:399> [0.64.0.1/...] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Adding waiter onResourceModified: 3
[2019-07-12 13:31:41,454] DEBUG <opicOperator:393> [0.64.0.1/...] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:41,454] INFO <TopicWatcher:36> [0.64.0.1/...] 1965|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177590: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:41,454] DEBUG <K8sImpl :76> [ker-thread-5] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:41,445] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=1897|/brokers/topics -testtopic3|177476)
[2019-07-12 13:31:41,440] DEBUG <opicOperator:385> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:41,440] DEBUG <opicOperator:413> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Lock released
[2019-07-12 13:31:41,440] INFO <TopicWatcher:39> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:41,440] DEBUG <opicOperator:408> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:41,440] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476) succeeded
[2019-07-12 13:31:41,440] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476)
[2019-07-12 13:31:41,437] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476)
[2019-07-12 13:31:41,437] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476)
[2019-07-12 13:31:41,437] INFO <opicOperator:210> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:40,640] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476)
[2019-07-12 13:31:40,640] DEBUG <opicOperator:482> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:40,640] INFO <opicOperator:460> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:40,117] DEBUG <opicOperator:417> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:40,117] DEBUG <opicOperator:405> [oop-thread-1] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Lock acquired
[2019-07-12 13:31:40,117] DEBUG <opicOperator:385> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:40,117] DEBUG <opicOperator:413> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Lock released
[2019-07-12 13:31:40,117] INFO <TopicWatcher:39> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:40,116] DEBUG <opicOperator:408> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:40,114] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455)
[2019-07-12 13:31:38,847] INFO <opicOperator:343> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Deleting topic 'testtopic3'
[2019-07-12 13:31:38,847] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455)
[2019-07-12 13:31:38,847] DEBUG <opicOperator:502> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:38,847] INFO <opicOperator:460> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:38,271] DEBUG <opicOperator:417> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:38,271] DEBUG <opicOperator:405> [oop-thread-1] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Lock acquired
[2019-07-12 13:31:38,266] DEBUG <opicOperator:385> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:38,266] DEBUG <opicOperator:413> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Lock released
[2019-07-12 13:31:38,266] INFO <TopicWatcher:39> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:38,266] DEBUG <opicOperator:408> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:38,266] INFO <opicOperator:599> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: All three topics are identical
[2019-07-12 13:31:38,266] DEBUG <opicOperator:597> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:38,266] DEBUG <opicOperator:588> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:38,266] DEBUG <opicOperator:586> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:38,266] DEBUG <opicOperator:524> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: 3 way diff
[2019-07-12 13:31:38,266] INFO <opicOperator:460> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:37,482] DEBUG <opicOperator:417> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:37,482] DEBUG <opicOperator:405> [oop-thread-1] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Lock acquired
[2019-07-12 13:31:37,477] DEBUG <opicOperator:399> [0.64.0.1/...] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:37,477] DEBUG <opicOperator:393> [0.64.0.1/...] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:37,477] INFO <TopicWatcher:36> [0.64.0.1/...] 1782|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177476: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:37,477] DEBUG <K8sImpl :47> [er-thread-15] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177476
[2019-07-12 13:31:37,307] DEBUG <opicOperator:399> [0.64.0.1/...] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:37,307] DEBUG <opicOperator:393> [0.64.0.1/...] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:37,307] INFO <TopicWatcher:36> [0.64.0.1/...] 1761|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177455: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:37,301] DEBUG <opicOperator:399> [0.64.0.1/...] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Adding waiter onResourceModified: 3
[2019-07-12 13:31:37,301] DEBUG <opicOperator:393> [0.64.0.1/...] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:37,301] INFO <TopicWatcher:36> [0.64.0.1/...] 1760|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177454: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:37,300] DEBUG <K8sImpl :76> [ker-thread-4] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:37,286] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=1677|/brokers/topics -testtopic3|177334)
[2019-07-12 13:31:37,281] DEBUG <opicOperator:385> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:37,281] DEBUG <opicOperator:413> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Lock released
[2019-07-12 13:31:37,281] INFO <TopicWatcher:39> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:37,281] DEBUG <opicOperator:408> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:37,281] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334) succeeded
[2019-07-12 13:31:37,281] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334)
[2019-07-12 13:31:37,278] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334)
[2019-07-12 13:31:37,278] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334)
[2019-07-12 13:31:37,278] INFO <opicOperator:210> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:36,734] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334)
[2019-07-12 13:31:36,734] DEBUG <opicOperator:482> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:36,734] INFO <opicOperator:460> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:36,201] DEBUG <opicOperator:417> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:36,201] DEBUG <opicOperator:405> [oop-thread-1] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Lock acquired
[2019-07-12 13:31:36,201] DEBUG <opicOperator:385> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:36,201] DEBUG <opicOperator:413> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Lock released
[2019-07-12 13:31:36,201] INFO <TopicWatcher:39> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:36,201] DEBUG <opicOperator:408> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:36,197] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312)
[2019-07-12 13:31:34,966] INFO <opicOperator:343> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Deleting topic 'testtopic3'
[2019-07-12 13:31:34,966] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312)
[2019-07-12 13:31:34,966] DEBUG <opicOperator:502> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:34,966] INFO <opicOperator:460> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:34,176] DEBUG <opicOperator:417> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:34,176] DEBUG <opicOperator:405> [oop-thread-1] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Lock acquired
[2019-07-12 13:31:34,164] DEBUG <opicOperator:385> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:34,164] DEBUG <opicOperator:413> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Lock released
[2019-07-12 13:31:34,164] INFO <TopicWatcher:39> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:34,164] DEBUG <opicOperator:408> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:34,164] INFO <opicOperator:599> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: All three topics are identical
[2019-07-12 13:31:34,164] DEBUG <opicOperator:597> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:34,164] DEBUG <opicOperator:588> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:34,164] DEBUG <opicOperator:586> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:34,161] DEBUG <opicOperator:524> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: 3 way diff
[2019-07-12 13:31:34,161] INFO <opicOperator:460> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:33,152] DEBUG <opicOperator:417> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:33,152] DEBUG <opicOperator:405> [oop-thread-1] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Lock acquired
[2019-07-12 13:31:33,146] DEBUG <opicOperator:399> [0.64.0.1/...] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:33,146] DEBUG <opicOperator:393> [0.64.0.1/...] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:33,146] INFO <TopicWatcher:36> [0.64.0.1/...] 1574|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177334: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:33,146] DEBUG <K8sImpl :47> [ker-thread-7] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177334
[2019-07-12 13:31:32,793] DEBUG <opicOperator:399> [0.64.0.1/...] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:32,793] DEBUG <opicOperator:393> [0.64.0.1/...] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:32,793] INFO <TopicWatcher:36> [0.64.0.1/...] 1548|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177312: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:32,787] DEBUG <K8sImpl :76> [ker-thread-6] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:32,786] DEBUG <opicOperator:399> [0.64.0.1/...] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Adding waiter onResourceModified: 3
[2019-07-12 13:31:32,786] DEBUG <opicOperator:393> [0.64.0.1/...] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:32,786] INFO <TopicWatcher:36> [0.64.0.1/...] 1547|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177311: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:32,779] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=1468|/brokers/topics -testtopic3|177193)
[2019-07-12 13:31:32,770] DEBUG <opicOperator:385> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:32,770] DEBUG <opicOperator:413> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Lock released
[2019-07-12 13:31:32,770] INFO <TopicWatcher:39> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:32,770] DEBUG <opicOperator:408> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:32,770] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193) succeeded
[2019-07-12 13:31:32,770] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193)
[2019-07-12 13:31:32,767] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193)
[2019-07-12 13:31:32,767] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193)
[2019-07-12 13:31:32,767] INFO <opicOperator:210> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:32,326] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193)
[2019-07-12 13:31:32,326] DEBUG <opicOperator:482> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:32,326] INFO <opicOperator:460> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:31,493] DEBUG <opicOperator:417> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:31,493] DEBUG <opicOperator:405> [oop-thread-1] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Lock acquired
[2019-07-12 13:31:31,493] DEBUG <opicOperator:385> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:31,493] DEBUG <opicOperator:413> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Lock released
[2019-07-12 13:31:31,493] INFO <TopicWatcher:39> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:31,493] DEBUG <opicOperator:408> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:31,490] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176)
[2019-07-12 13:31:29,998] INFO <opicOperator:343> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Deleting topic 'testtopic3'
[2019-07-12 13:31:29,998] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176)
[2019-07-12 13:31:29,998] DEBUG <opicOperator:502> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:29,998] INFO <opicOperator:460> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:29,331] DEBUG <opicOperator:417> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:29,331] DEBUG <opicOperator:405> [oop-thread-1] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Lock acquired
[2019-07-12 13:31:29,325] DEBUG <opicOperator:385> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:29,325] DEBUG <opicOperator:413> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Lock released
[2019-07-12 13:31:29,325] INFO <TopicWatcher:39> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:29,325] DEBUG <opicOperator:408> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:29,325] INFO <opicOperator:599> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: All three topics are identical
[2019-07-12 13:31:29,325] DEBUG <opicOperator:597> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:29,325] DEBUG <opicOperator:588> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:29,325] DEBUG <opicOperator:586> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:29,325] DEBUG <opicOperator:524> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: 3 way diff
[2019-07-12 13:31:29,325] INFO <opicOperator:460> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:28,382] DEBUG <opicOperator:417> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:28,382] DEBUG <opicOperator:405> [oop-thread-1] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Lock acquired
[2019-07-12 13:31:28,377] DEBUG <opicOperator:399> [0.64.0.1/...] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:28,377] DEBUG <opicOperator:393> [0.64.0.1/...] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:28,377] INFO <TopicWatcher:36> [0.64.0.1/...] 1365|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177193: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:28,375] DEBUG <K8sImpl :47> [er-thread-16] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177193
[2019-07-12 13:31:28,164] DEBUG <opicOperator:399> [0.64.0.1/...] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Adding waiter onResourceDeleted: 4
[2019-07-12 13:31:28,163] DEBUG <opicOperator:393> [0.64.0.1/...] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:28,163] INFO <TopicWatcher:36> [0.64.0.1/...] 1346|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177176: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:28,155] DEBUG <opicOperator:399> [0.64.0.1/...] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Adding waiter onResourceModified: 3
[2019-07-12 13:31:28,155] DEBUG <opicOperator:393> [0.64.0.1/...] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:28,155] INFO <TopicWatcher:36> [0.64.0.1/...] 1345|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177175: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:28,155] DEBUG <K8sImpl :76> [ker-thread-0] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:28,147] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=1255|/brokers/topics -testtopic3|177046)
[2019-07-12 13:31:28,142] DEBUG <opicOperator:385> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:28,142] DEBUG <opicOperator:413> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Lock released
[2019-07-12 13:31:28,142] INFO <TopicWatcher:39> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:28,142] DEBUG <opicOperator:408> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:28,142] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046) succeeded
[2019-07-12 13:31:28,142] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046)
[2019-07-12 13:31:28,139] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046)
[2019-07-12 13:31:28,139] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046)
[2019-07-12 13:31:28,139] INFO <opicOperator:210> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:27,416] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046)
[2019-07-12 13:31:27,416] DEBUG <opicOperator:482> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:27,416] INFO <opicOperator:460> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:26,848] DEBUG <opicOperator:417> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:26,848] DEBUG <opicOperator:405> [oop-thread-1] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Lock acquired
[2019-07-12 13:31:26,848] DEBUG <opicOperator:385> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:26,848] DEBUG <opicOperator:413> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Lock released
[2019-07-12 13:31:26,848] INFO <TopicWatcher:39> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Success processing event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:26,848] DEBUG <opicOperator:408> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:26,839] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008)
[2019-07-12 13:31:25,126] INFO <opicOperator:343> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Deleting topic 'testtopic3'
[2019-07-12 13:31:25,126] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008)
[2019-07-12 13:31:25,126] DEBUG <opicOperator:502> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:25,126] INFO <opicOperator:460> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:24,268] DEBUG <opicOperator:417> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:24,268] DEBUG <opicOperator:405> [oop-thread-1] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Lock acquired
[2019-07-12 13:31:24,265] DEBUG <opicOperator:385> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:24,265] DEBUG <opicOperator:413> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Lock released
[2019-07-12 13:31:24,265] INFO <TopicWatcher:39> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Success processing event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:24,265] DEBUG <opicOperator:408> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:24,265] INFO <opicOperator:599> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: All three topics are identical
[2019-07-12 13:31:24,265] DEBUG <opicOperator:597> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Diffs do not conflict, merged diff: TopicDiff{differences={}}
[2019-07-12 13:31:24,265] DEBUG <opicOperator:588> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: topicStore->k8sTopic: TopicDiff{differences={}}
[2019-07-12 13:31:24,265] DEBUG <opicOperator:586> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: topicStore->kafkaTopic: TopicDiff{differences={}}
[2019-07-12 13:31:24,264] DEBUG <opicOperator:524> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: 3 way diff
[2019-07-12 13:31:24,264] INFO <opicOperator:460> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:22,953] DEBUG <opicOperator:417> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:22,953] DEBUG <opicOperator:405> [oop-thread-1] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Lock acquired
[2019-07-12 13:31:22,948] DEBUG <opicOperator:399> [0.64.0.1/...] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Adding waiter onResourceAdded: 4
[2019-07-12 13:31:22,948] DEBUG <opicOperator:393> [0.64.0.1/...] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:22,948] INFO <TopicWatcher:36> [0.64.0.1/...] 1158|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177046: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:22,947] DEBUG <K8sImpl :47> [er-thread-12] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 177046
[2019-07-12 13:31:22,378] DEBUG <opicOperator:399> [0.64.0.1/...] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Adding waiter onResourceDeleted: 3
[2019-07-12 13:31:22,378] DEBUG <opicOperator:393> [0.64.0.1/...] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:22,377] INFO <TopicWatcher:36> [0.64.0.1/...] 1113|kube -testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177008: event DELETED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:22,372] DEBUG <opicOperator:399> [0.64.0.1/...] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Adding waiter onResourceModified: 3
[2019-07-12 13:31:22,371] DEBUG <opicOperator:393> [0.64.0.1/...] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:22,371] INFO <TopicWatcher:36> [0.64.0.1/...] 1112|kube =testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|177007: event MODIFIED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:22,371] DEBUG <K8sImpl :76> [er-thread-13] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec deleted
[2019-07-12 13:31:22,363] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteResource(mapName=testtopic3---b5468e19767964482a1c366cef576c108e76b6ec,ctx=1034|/brokers/topics -testtopic3|176859)
[2019-07-12 13:31:22,355] DEBUG <opicOperator:385> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:22,355] DEBUG <opicOperator:413> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Lock released
[2019-07-12 13:31:22,355] INFO <TopicWatcher:39> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Success processing event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:22,355] DEBUG <opicOperator:408> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:22,355] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859) succeeded
[2019-07-12 13:31:22,355] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859)
[2019-07-12 13:31:22,352] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859)
[2019-07-12 13:31:22,352] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859)
[2019-07-12 13:31:22,352] INFO <opicOperator:210> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Created topic 'testtopic3' for KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec'
[2019-07-12 13:31:21,476] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859)
[2019-07-12 13:31:21,476] DEBUG <opicOperator:482> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:31:21,476] INFO <opicOperator:460> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:31:20,685] DEBUG <opicOperator:417> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:20,685] DEBUG <opicOperator:405> [oop-thread-1] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Lock acquired
[2019-07-12 13:31:20,685] DEBUG <opicOperator:385> [oop-thread-1] 683|kube -testtopic3|176685: Removing waiter onResourceDeleted, 1 waiters left
[2019-07-12 13:31:20,685] DEBUG <opicOperator:413> [oop-thread-1] 683|kube -testtopic3|176685: Lock released
[2019-07-12 13:31:20,685] INFO <TopicWatcher:39> [oop-thread-1] 683|kube -testtopic3|176685: Success processing event DELETED on resource testtopic3 with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:20,685] DEBUG <opicOperator:408> [oop-thread-1] 683|kube -testtopic3|176685: Executing handler for action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:20,681] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=683|kube -testtopic3|176685)
[2019-07-12 13:31:18,703] INFO <opicOperator:343> [oop-thread-1] 683|kube -testtopic3|176685: Deleting topic 'testtopic3'
[2019-07-12 13:31:18,702] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event DeleteKafkaTopic(topicName=testtopic3,ctx=683|kube -testtopic3|176685)
[2019-07-12 13:31:18,702] DEBUG <opicOperator:502> [oop-thread-1] 683|kube -testtopic3|176685: KafkaTopic deleted in k8s => delete topic from kafka and from topicStore
[2019-07-12 13:31:18,702] INFO <opicOperator:460> [oop-thread-1] 683|kube -testtopic3|176685: Reconciling topic testtopic3, k8sTopic:null, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:18,163] DEBUG <K8sImpl :119> [er-thread-15] Creating event Event(action=null, apiVersion=v1, count=null, eventTime=null, firstTimestamp=null, involvedObject=ObjectReference(apiVersion=kafka.strimzi.io/v1beta1, fieldPath=null, kind=KafkaTopic, name=testtopic3, namespace=kafka-cdc, resourceVersion=null, uid=061a903e-a4a9-11e9-9dde-0a737df49790, additionalProperties={}), kind=Event, lastTimestamp=2019-07-12T13:31:18Z, message=Failure processing KafkaTopic watch event MODIFIED on resource testtopic3 with labels {strimzi.io/cluster=cdc}: Topic 'testtopic3' is already managed via KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec' it cannot also be managed via the KafkaTopic 'testtopic3', metadata=ObjectMeta(annotations={}, clusterName=null, creationTimestamp=null, deletionGracePeriodSeconds=null, deletionTimestamp=null, finalizers=[], generateName=topic-operator, generation=null, initializers=null, labels={strimzi.io/cluster=cdc}, name=null, namespace=kafka-cdc, ownerReferences=[], resourceVersion=null, selfLink=null, uid=null, additionalProperties={}), reason=null, related=null, reportingComponent=null, reportingInstance=null, series=null, source=EventSource(component=io.strimzi.operator.topic.TopicOperator, host=null, additionalProperties={}), type=Warning, additionalProperties={})
[2019-07-12 13:31:18,163] DEBUG <opicOperator:417> [oop-thread-1] 683|kube -testtopic3|176685: Executing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:18,163] DEBUG <opicOperator:405> [oop-thread-1] 683|kube -testtopic3|176685: Lock acquired
[2019-07-12 13:31:18,163] WARN <opicOperator:106> [oop-thread-1] Failure processing KafkaTopic watch event MODIFIED on resource testtopic3 with labels {strimzi.io/cluster=cdc}: Topic 'testtopic3' is already managed via KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec' it cannot also be managed via the KafkaTopic 'testtopic3'
[2019-07-12 13:31:18,158] DEBUG <opicOperator:385> [oop-thread-1] 681|kube =testtopic3|176683: Removing waiter onResourceModified, 2 waiters left
[2019-07-12 13:31:18,158] DEBUG <opicOperator:413> [oop-thread-1] 681|kube =testtopic3|176683: Lock released
, message=Failure processing KafkaTopic watch event MODIFIED on resource testtopic3 with labels {strimzi.io/cluster=cdc}: Topic 'testtopic3' is already managed via KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec' it cannot also be managed via the KafkaTopic 'testtopic3')
selfLink: "/apis/kafka.strimzi.io/v1beta1/namespaces/kafka-cdc/kafkatopics/testtopic3"
name: "testtopic3"
:\"true\"},\"labels\":{\"strimzi.io/cluster\":\"cdc\"},\"name\":\"testtopic3\"\
io.strimzi.operator.topic.OperatorException: Topic 'testtopic3' is already managed via KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec' it cannot also be managed via the KafkaTopic 'testtopic3'
[2019-07-12 13:31:18,156] ERROR <TopicWatcher:48> [oop-thread-1] 681|kube =testtopic3|176683: Failure processing KafkaTopic watch event MODIFIED on resource testtopic3 with labels {strimzi.io/cluster=cdc}: Topic 'testtopic3' is already managed via KafkaTopic 'testtopic3---b5468e19767964482a1c366cef576c108e76b6ec' it cannot also be managed via the KafkaTopic 'testtopic3'
[2019-07-12 13:31:18,156] DEBUG <opicOperator:408> [oop-thread-1] 681|kube =testtopic3|176683: Executing handler for action onResourceModified on topic testtopic3
[2019-07-12 13:31:18,156] DEBUG <opicOperator:524> [oop-thread-1] 681|kube =testtopic3|176683: 3 way diff
[2019-07-12 13:31:18,156] INFO <opicOperator:460> [oop-thread-1] 681|kube =testtopic3|176683: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:nonnull, privateTopic:nonnull
[2019-07-12 13:31:16,159] DEBUG <opicOperator:399> [0.64.0.1/...] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Adding waiter onResourceAdded: 3
[2019-07-12 13:31:16,159] DEBUG <opicOperator:393> [0.64.0.1/...] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:31:16,159] INFO <TopicWatcher:36> [0.64.0.1/...] 942|kube +testtopic3---b5468e19767964482a1c366cef576c108e76b6ec|176859: event ADDED on resource testtopic3---b5468e19767964482a1c366cef576c108e76b6ec with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:16,156] DEBUG <opicOperator:417> [oop-thread-1] 681|kube =testtopic3|176683: Executing action onResourceModified on topic testtopic3
[2019-07-12 13:31:16,156] DEBUG <opicOperator:405> [oop-thread-1] 681|kube =testtopic3|176683: Lock acquired
[2019-07-12 13:31:16,139] DEBUG <K8sImpl :47> [ker-thread-3] KafkaTopic testtopic3---b5468e19767964482a1c366cef576c108e76b6ec created with version 176859
[2019-07-12 13:31:14,423] DEBUG <opicOperator:385> [oop-thread-0] 152|initial kube testtopic3|175770: Removing waiter reconcile-with-kube, 3 waiters left
[2019-07-12 13:31:14,423] DEBUG <opicOperator:413> [oop-thread-0] 152|initial kube testtopic3|175770: Lock released
[2019-07-12 13:31:14,422] DEBUG <opicOperator:408> [oop-thread-0] 152|initial kube testtopic3|175770: Executing handler for action reconcile-with-kube on topic testtopic3
[2019-07-12 13:31:14,422] INFO <opicOperator:1239> [oop-thread-0] 152|initial kube testtopic3|175770: Success reconciling KafkaTopic kafka-cdc/testtopic3
[2019-07-12 13:31:13,638] DEBUG <opicOperator:399> [0.64.0.1/...] 683|kube -testtopic3|176685: Adding waiter onResourceDeleted: 4
[2019-07-12 13:31:13,638] DEBUG <opicOperator:393> [0.64.0.1/...] 683|kube -testtopic3|176685: Queuing action onResourceDeleted on topic testtopic3
[2019-07-12 13:31:13,637] INFO <TopicWatcher:36> [0.64.0.1/...] 683|kube -testtopic3|176685: event DELETED on resource testtopic3 with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:13,630] DEBUG <opicOperator:399> [0.64.0.1/...] 681|kube =testtopic3|176683: Adding waiter onResourceModified: 3
[2019-07-12 13:31:13,630] DEBUG <opicOperator:658> [oop-thread-0] Enqueuing event DeleteFromTopicStore(topicName=testtopic3,ctx=152|initial kube testtopic3|175770)
[2019-07-12 13:31:13,630] DEBUG <K8sImpl :76> [er-thread-17] KafkaTopic testtopic3 deleted
[2019-07-12 13:31:13,630] DEBUG <opicOperator:393> [0.64.0.1/...] 681|kube =testtopic3|176683: Queuing action onResourceModified on topic testtopic3
[2019-07-12 13:31:13,630] INFO <TopicWatcher:36> [0.64.0.1/...] 681|kube =testtopic3|176683: event MODIFIED on resource testtopic3 with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:13,349] DEBUG <opicOperator:658> [oop-thread-0] Enqueuing event DeleteResource(mapName=testtopic3,ctx=152|initial kube testtopic3|175770)
[2019-07-12 13:31:13,349] DEBUG <opicOperator:514> [oop-thread-0] 152|initial kube testtopic3|175770: topic deleted in kafkas => delete KafkaTopic from k8s and from topicStore
[2019-07-12 13:31:13,349] INFO <opicOperator:460> [oop-thread-0] 152|initial kube testtopic3|175770: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:nonnull
[2019-07-12 13:31:05,230] DEBUG <opicOperator:417> [oop-thread-0] 152|initial kube testtopic3|175770: Executing action reconcile-with-kube on topic testtopic3
[2019-07-12 13:31:05,229] DEBUG <opicOperator:385> [oop-thread-1] 110|kube +testtopic3|175770: Removing waiter onResourceAdded, 2 waiters left
[2019-07-12 13:31:05,229] DEBUG <opicOperator:405> [oop-thread-0] 152|initial kube testtopic3|175770: Lock acquired
[2019-07-12 13:31:05,229] DEBUG <opicOperator:413> [oop-thread-1] 110|kube +testtopic3|175770: Lock released
[2019-07-12 13:31:05,229] INFO <TopicWatcher:39> [oop-thread-1] 110|kube +testtopic3|175770: Success processing event ADDED on resource testtopic3 with labels {strimzi.io/cluster=cdc}
[2019-07-12 13:31:05,229] DEBUG <opicOperator:408> [oop-thread-1] 110|kube +testtopic3|175770: Executing handler for action onResourceAdded on topic testtopic3
[2019-07-12 13:31:05,229] DEBUG <opicOperator:948> [oop-thread-1] CreateInTopicStore(topicName=testtopic3,ctx=110|kube +testtopic3|175770) succeeded
[2019-07-12 13:31:05,229] DEBUG <opicOperator:943> [oop-thread-1] Completing CreateInTopicStore(topicName=testtopic3,ctx=110|kube +testtopic3|175770)
[2019-07-12 13:31:05,222] DEBUG <opicOperator:941> [oop-thread-1] Executing CreateInTopicStore(topicName=testtopic3,ctx=110|kube +testtopic3|175770)
[2019-07-12 13:31:05,222] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateInTopicStore(topicName=testtopic3,ctx=110|kube +testtopic3|175770)
[2019-07-12 13:31:05,222] INFO <opicOperator:210> [oop-thread-1] 110|kube +testtopic3|175770: Created topic 'testtopic3' for KafkaTopic 'testtopic3'
[2019-07-12 13:30:58,747] DEBUG <opicOperator:658> [oop-thread-1] Enqueuing event CreateKafkaTopic(topicName=testtopic3,ctx=110|kube +testtopic3|175770)
[2019-07-12 13:30:58,747] DEBUG <opicOperator:482> [oop-thread-1] 110|kube +testtopic3|175770: KafkaTopic created in k8s, will create topic in kafka and topicStore
[2019-07-12 13:30:58,746] INFO <opicOperator:460> [oop-thread-1] 110|kube +testtopic3|175770: Reconciling topic testtopic3, k8sTopic:nonnull, kafkaTopic:null, privateTopic:null
[2019-07-12 13:30:58,032] DEBUG <opicOperator:417> [oop-thread-1] 110|kube +testtopic3|175770: Executing action onResourceAdded on topic testtopic3
[2019-07-12 13:30:58,032] DEBUG <opicOperator:405> [oop-thread-1] 110|kube +testtopic3|175770: Lock acquired
[2019-07-12 13:30:57,996] DEBUG <opicOperator:399> [oop-thread-0] 152|initial kube testtopic3|175770: Adding waiter reconcile-with-kube: 2
[2019-07-12 13:30:57,996] DEBUG <opicOperator:393> [oop-thread-0] 152|initial kube testtopic3|175770: Queuing action reconcile-with-kube on topic testtopic3
[2019-07-12 13:30:57,996] DEBUG <opicOperator:1071> [oop-thread-0] 152|initial kube testtopic3|175770: Topic testtopic3 exists in Kafka, but not Kubernetes
[2019-07-12 13:30:57,996] DEBUG <TopicWatcher:72> [oop-thread-0] 152|initial kube testtopic3: Concurrent modification in kube: new version 175770
[2019-07-12 13:30:57,969] DEBUG <opicOperator:396> [0.64.0.1/...] 110|kube +testtopic3|175770: Adding first waiter onResourceAdded
[2019-07-12 13:30:57,968] DEBUG <opicOperator:393> [0.64.0.1/...] 110|kube +testtopic3|175770: Queuing action onResourceAdded on topic testtopic3
[2019-07-12 13:30:57,968] INFO <TopicWatcher:36> [0.64.0.1/...] 110|kube +testtopic3|175770: event ADDED on resource testtopic3 with labels {strimzi.io/cluster=cdc}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment