Advertisement
Guest User

Debug Log Confluent Kafka .NET Admin Client CreateTopic

a guest
Dec 30th, 2020
709
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Bash 96.72 KB | None | 0 0
  1. info: Extensions.Hosting.AsyncInitialization.RootInitializer[0]
  2.       Starting async initialization
  3. info: Extensions.Hosting.AsyncInitialization.RootInitializer[0]
  4.       Starting async initialization for WebApp.Kafka.Admin.KafkaAdminService
  5. %7|1609342004.413|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
  6. %7|1609342004.413|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
  7. %7|1609342004.413|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
  8. %7|1609342004.413|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
  9. %7|1609342004.413|CONNECT|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
  10. %7|1609342004.413|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.5.3 (0x10503ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STATIC_LINKING CC GXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
  11. %7|1609342004.413|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  12. %7|1609342004.413|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  13. %7|1609342004.413|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  14. %7|1609342004.413|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  15. %7|1609342004.413|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  16. %7|1609342004.413|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  17. %7|1609342004.417|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  18. %7|1609342004.417|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 4ms in state CONNECT) (_TRANSPORT)
  19. %3|1609342004.417|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 4ms in state CONNECT)
  20. %7|1609342004.417|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  21. %3|1609342004.417|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  22. %7|1609342004.417|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  23. %7|1609342004.417|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  24. %7|1609342004.417|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  25. %7|1609342004.417|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  26. %7|1609342004.417|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  27. %7|1609342004.417|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  28. %3|1609342004.421|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 4ms in state CONNECT)
  29. info: WebApp.Kafka.Admin.KafkaAdminService[0]
  30.       Admin service trying to create Kafka Topic...
  31. info: WebApp.Kafka.Admin.KafkaAdminService[0]
  32.       Topic::eventbus, ReplicationCount::1, PartitionCount::3
  33. info: WebApp.Kafka.Admin.KafkaAdminService[0]
  34.       Bootstrap Servers::localhost:9092
  35. %7|1609342004.434|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state initializing: Success
  36. %7|1609342004.434|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  37. %7|1609342004.434|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 28ms: lookup controller
  38. %7|1609342005.413|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 1 connection attempt(s))
  39. %7|1609342005.414|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  40. %7|1609342005.414|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  41. %7|1609342005.414|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  42. %7|1609342005.414|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  43. %7|1609342005.414|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  44. %7|1609342005.414|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  45. %7|1609342005.414|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  46. %7|1609342005.414|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  47. %7|1609342005.414|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  48. %7|1609342005.414|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  49. %7|1609342005.414|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  50. %3|1609342005.414|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  51. %7|1609342005.414|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  52. %7|1609342005.414|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  53. %7|1609342005.414|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  54. %7|1609342005.414|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  55. %7|1609342005.414|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  56. %7|1609342005.414|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  57. %7|1609342005.414|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  58. %7|1609342005.414|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  59. %7|1609342005.414|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  60. %7|1609342005.414|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  61. %3|1609342005.414|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  62. %7|1609342006.418|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 2 connection attempt(s))
  63. %7|1609342006.418|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  64. %7|1609342006.418|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  65. %7|1609342006.418|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  66. %7|1609342006.418|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  67. %7|1609342006.418|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  68. %7|1609342006.418|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  69. %7|1609342006.418|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  70. %7|1609342006.418|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  71. %7|1609342006.418|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  72. %7|1609342006.419|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  73. %7|1609342006.419|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error
  74. %3|1609342006.419|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed)
  75. %7|1609342006.419|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  76. %7|1609342006.419|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  77. %7|1609342006.419|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  78. %7|1609342006.419|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  79. %7|1609342006.419|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  80. %3|1609342006.419|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed)
  81. %7|1609342006.419|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  82. %7|1609342006.419|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  83. %7|1609342006.419|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  84. %7|1609342006.419|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  85. %7|1609342006.419|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  86. %7|1609342006.420|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  87. %7|1609342007.423|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 3 connection attempt(s))
  88. %7|1609342007.423|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  89. %7|1609342007.423|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  90. %7|1609342007.423|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  91. %7|1609342007.423|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  92. %7|1609342007.423|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  93. %7|1609342007.423|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  94. %7|1609342007.423|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  95. %7|1609342007.423|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  96. %7|1609342007.423|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  97. %7|1609342007.424|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  98. %7|1609342007.424|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  99. %7|1609342007.424|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  100. %7|1609342007.424|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  101. %7|1609342007.424|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  102. %7|1609342007.424|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  103. %7|1609342007.424|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  104. %7|1609342007.424|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  105. %7|1609342007.424|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  106. %7|1609342007.424|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  107. %7|1609342007.424|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  108. %7|1609342007.424|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  109. %7|1609342008.426|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 4 connection attempt(s))
  110. %7|1609342008.426|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  111. %7|1609342008.426|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  112. %7|1609342008.426|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  113. %7|1609342008.426|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  114. %7|1609342008.426|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  115. %7|1609342008.426|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  116. %7|1609342008.426|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  117. %7|1609342008.426|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  118. %7|1609342008.426|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  119. %7|1609342008.427|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  120. %7|1609342008.427|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  121. %3|1609342008.427|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  122. %7|1609342008.427|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  123. %7|1609342008.427|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  124. %7|1609342008.427|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  125. %3|1609342008.427|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  126. %7|1609342008.427|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  127. %7|1609342008.427|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  128. %7|1609342008.427|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  129. %7|1609342008.427|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  130. %7|1609342008.427|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  131. %7|1609342008.427|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  132. %7|1609342008.427|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  133. %7|1609342008.427|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  134. %7|1609342009.427|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 5 connection attempt(s))
  135. %7|1609342009.427|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  136. %7|1609342009.427|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  137. %7|1609342009.427|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  138. %7|1609342009.427|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  139. %7|1609342009.427|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  140. %7|1609342009.427|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  141. %7|1609342009.427|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  142. %7|1609342009.427|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  143. %7|1609342009.427|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  144. %7|1609342009.428|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  145. %7|1609342009.428|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  146. %7|1609342009.428|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  147. %7|1609342009.428|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  148. %7|1609342009.428|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  149. %7|1609342009.428|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  150. %7|1609342009.428|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  151. %7|1609342009.428|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  152. %7|1609342009.428|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  153. %7|1609342009.428|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  154. %7|1609342009.428|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  155. %7|1609342009.428|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  156. %7|1609342009.428|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  157. %7|1609342010.431|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 6 connection attempt(s))
  158. %7|1609342010.431|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  159. %7|1609342010.431|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  160. %7|1609342010.431|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  161. %7|1609342010.432|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  162. %7|1609342010.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  163. %7|1609342010.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  164. %7|1609342010.432|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  165. %7|1609342010.432|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  166. %7|1609342010.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  167. %7|1609342010.432|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  168. %7|1609342010.432|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  169. %7|1609342010.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  170. %7|1609342010.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  171. %7|1609342010.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  172. %7|1609342010.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  173. %7|1609342010.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  174. %7|1609342010.432|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  175. %7|1609342010.432|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  176. %7|1609342010.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  177. %7|1609342010.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  178. %7|1609342010.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  179. %7|1609342010.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  180. %7|1609342011.431|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 7 connection attempt(s))
  181. %7|1609342011.431|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  182. %7|1609342011.431|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  183. %7|1609342011.431|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  184. %7|1609342011.432|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  185. %7|1609342011.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  186. %7|1609342011.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  187. %7|1609342011.432|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  188. %7|1609342011.432|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  189. %7|1609342011.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  190. %7|1609342011.432|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  191. %7|1609342011.432|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  192. %3|1609342011.432|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  193. %7|1609342011.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  194. %7|1609342011.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  195. %3|1609342011.432|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  196. %7|1609342011.432|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  197. %7|1609342011.432|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  198. %7|1609342011.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  199. %7|1609342011.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  200. %7|1609342011.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  201. %7|1609342011.432|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  202. %7|1609342011.432|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  203. %7|1609342011.432|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  204. %7|1609342011.432|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  205. %7|1609342011.432|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  206. %7|1609342011.432|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  207. %7|1609342012.435|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 8 connection attempt(s))
  208. %7|1609342012.435|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  209. %7|1609342012.435|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  210. %7|1609342012.435|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  211. %7|1609342012.435|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  212. %7|1609342012.435|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  213. %7|1609342012.435|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  214. %7|1609342012.435|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  215. %7|1609342012.435|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  216. %7|1609342012.435|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  217. %7|1609342012.436|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  218. %7|1609342012.436|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  219. %3|1609342012.436|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  220. %7|1609342012.436|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  221. %7|1609342012.436|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  222. %3|1609342012.436|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  223. %7|1609342012.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  224. %7|1609342012.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  225. %7|1609342012.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  226. %7|1609342012.436|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  227. %7|1609342012.436|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  228. %7|1609342012.436|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  229. %7|1609342012.436|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  230. %7|1609342012.436|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  231. %7|1609342013.435|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 9 connection attempt(s))
  232. %7|1609342013.435|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  233. %7|1609342013.435|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  234. %7|1609342013.435|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  235. %7|1609342013.435|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  236. %7|1609342013.435|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  237. %7|1609342013.435|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  238. %7|1609342013.435|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  239. %7|1609342013.435|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  240. %7|1609342013.435|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  241. %7|1609342013.435|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  242. %7|1609342013.436|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  243. %3|1609342013.436|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  244. %7|1609342013.436|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  245. %7|1609342013.436|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  246. %7|1609342013.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  247. %7|1609342013.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  248. %7|1609342013.436|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  249. %7|1609342013.436|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  250. %7|1609342013.436|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  251. %3|1609342013.436|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  252. %7|1609342013.436|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  253. %7|1609342013.436|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  254. %7|1609342013.436|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  255. %7|1609342014.440|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 10 connection attempt(s))
  256. %7|1609342014.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  257. %7|1609342014.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  258. %7|1609342014.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  259. %7|1609342014.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  260. %7|1609342014.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  261. %7|1609342014.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  262. %7|1609342014.440|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  263. %7|1609342014.440|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  264. %7|1609342014.440|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  265. %7|1609342014.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  266. %7|1609342014.441|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  267. %7|1609342014.441|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  268. %7|1609342014.441|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  269. %7|1609342014.441|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  270. %7|1609342014.441|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  271. %7|1609342014.441|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  272. %7|1609342014.441|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  273. %7|1609342014.441|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  274. %7|1609342014.441|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  275. %7|1609342014.441|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  276. %7|1609342014.441|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  277. %7|1609342014.441|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  278. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 11 connection attempt(s))
  279. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  280. %7|1609342015.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  281. %7|1609342015.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  282. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  283. %7|1609342015.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  284. %7|1609342015.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  285. %7|1609342015.440|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  286. %7|1609342015.440|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  287. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  288. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  289. %7|1609342015.440|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  290. %3|1609342015.440|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  291. %7|1609342015.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  292. %7|1609342015.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  293. %7|1609342015.440|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  294. %7|1609342015.440|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  295. %7|1609342015.440|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  296. %7|1609342015.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  297. %7|1609342015.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  298. %3|1609342015.440|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  299. %7|1609342015.440|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  300. %7|1609342015.440|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  301. %7|1609342015.440|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  302. %7|1609342016.440|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 12 connection attempt(s))
  303. %7|1609342016.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  304. %7|1609342016.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  305. %7|1609342016.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  306. %7|1609342016.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  307. %7|1609342016.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  308. %7|1609342016.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  309. %7|1609342016.440|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  310. %7|1609342016.440|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  311. %7|1609342016.440|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  312. %7|1609342016.440|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  313. %7|1609342016.440|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  314. %3|1609342016.440|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  315. %7|1609342016.440|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  316. %7|1609342016.440|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  317. %7|1609342016.440|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  318. %7|1609342016.440|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  319. %3|1609342016.440|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  320. %7|1609342016.441|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  321. %7|1609342016.441|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  322. %7|1609342016.441|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  323. %7|1609342016.441|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  324. %7|1609342016.441|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  325. %7|1609342016.441|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  326. %7|1609342017.445|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 13 connection attempt(s))
  327. %7|1609342017.445|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  328. %7|1609342017.445|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  329. %7|1609342017.445|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  330. %7|1609342017.445|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  331. %7|1609342017.445|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  332. %7|1609342017.445|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  333. %7|1609342017.445|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  334. %7|1609342017.445|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  335. %7|1609342017.445|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  336. %7|1609342017.446|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  337. %7|1609342017.446|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  338. %7|1609342017.446|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  339. %7|1609342017.446|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  340. %7|1609342017.446|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  341. %7|1609342017.446|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  342. %7|1609342017.446|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  343. %7|1609342017.446|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  344. %7|1609342017.446|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  345. %7|1609342017.446|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  346. %7|1609342017.446|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  347. %7|1609342017.446|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  348. %7|1609342018.449|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 14 connection attempt(s))
  349. %7|1609342018.449|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  350. %7|1609342018.449|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  351. %7|1609342018.449|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  352. %7|1609342018.449|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  353. %7|1609342018.449|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  354. %7|1609342018.449|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  355. %7|1609342018.449|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  356. %7|1609342018.449|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  357. %7|1609342018.449|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  358. %7|1609342018.450|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  359. %7|1609342018.450|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed
  360. %7|1609342018.450|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  361. %7|1609342018.450|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  362. %7|1609342018.450|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  363. %7|1609342018.450|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  364. %7|1609342018.450|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  365. %7|1609342018.451|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  366. %7|1609342018.450|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  367. %7|1609342018.451|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  368. %7|1609342018.451|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  369. %7|1609342018.451|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  370. %7|1609342018.451|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  371. %7|1609342018.451|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  372. %7|1609342018.451|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  373. %7|1609342019.452|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 15 connection attempt(s))
  374. %7|1609342019.452|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  375. %7|1609342019.452|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  376. %7|1609342019.452|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  377. %7|1609342019.452|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  378. %7|1609342019.452|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  379. %7|1609342019.452|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  380. %7|1609342019.452|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  381. %7|1609342019.452|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  382. %7|1609342019.452|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  383. %7|1609342019.453|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  384. %7|1609342019.453|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  385. %3|1609342019.453|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  386. %7|1609342019.453|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  387. %7|1609342019.453|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  388. %7|1609342019.453|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  389. %7|1609342019.453|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  390. %3|1609342019.453|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)
  391. %7|1609342019.453|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  392. %7|1609342019.453|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  393. %7|1609342019.453|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  394. %7|1609342019.453|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  395. %7|1609342019.453|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  396. %7|1609342019.453|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  397. %7|1609342020.456|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 16 connection attempt(s))
  398. %7|1609342020.456|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  399. %7|1609342020.456|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  400. %7|1609342020.456|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  401. %7|1609342020.456|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  402. %7|1609342020.456|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  403. %7|1609342020.456|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  404. %7|1609342020.456|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  405. %7|1609342020.456|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  406. %7|1609342020.456|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  407. %7|1609342020.457|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  408. %7|1609342020.457|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) (_TRANSPORT)
  409. %3|1609342020.457|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  410. %7|1609342020.457|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN
  411. %7|1609342020.457|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  412. %7|1609342020.457|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  413. %7|1609342020.457|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  414. %7|1609342020.457|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  415. %7|1609342020.457|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  416. %3|1609342020.457|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
  417. %7|1609342020.457|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  418. %7|1609342020.457|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  419. %7|1609342020.457|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  420. %7|1609342020.457|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  421. %7|1609342020.457|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  422. %7|1609342021.456|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 17 connection attempt(s))
  423. %7|1609342021.456|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
  424. %7|1609342021.456|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  425. %7|1609342021.456|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  426. %7|1609342021.456|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  427. %7|1609342021.456|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  428. %7|1609342021.456|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  429. %7|1609342021.456|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  430. %7|1609342021.456|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  431. %7|1609342021.456|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  432. %7|1609342021.456|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  433. %7|1609342021.457|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092
  434. %7|1609342021.457|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)
  435. %7|1609342021.457|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  436. %7|1609342021.457|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  437. %7|1609342021.457|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  438. %7|1609342021.457|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  439. %7|1609342021.457|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  440. %7|1609342021.457|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  441. %7|1609342021.457|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 1)
  442. %7|1609342021.462|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 5ms in state APIVERSION_QUERY) (_TRANSPORT)
  443. %6|1609342021.462|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 5ms in state APIVERSION_QUERY)
  444. %7|1609342021.462|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to
  445. %7|1609342021.462|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN
  446. %3|1609342021.462|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  447. %7|1609342021.462|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  448. %7|1609342021.462|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 1 buffers
  449. %7|1609342021.462|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  450. %7|1609342021.462|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  451. %7|1609342021.462|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  452. %7|1609342021.462|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  453. %7|1609342021.462|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  454. %7|1609342021.462|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  455. %7|1609342021.462|RECONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Delaying next reconnect by 121ms
  456. %3|1609342021.462|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 5ms in state APIVERSION_QUERY)
  457. %7|1609342021.462|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  458. %7|1609342021.463|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  459. %7|1609342021.463|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 43ms: lookup controller
  460. %7|1609342021.588|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  461. %7|1609342021.588|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  462. %7|1609342021.588|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  463. %7|1609342021.588|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  464. %7|1609342021.588|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  465. %7|1609342021.588|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: lookup controller
  466. %7|1609342021.589|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  467. %7|1609342021.589|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv6#[::1]:9092
  468. %7|1609342021.589|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#2)
  469. %7|1609342021.589|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  470. %7|1609342021.589|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  471. %7|1609342021.589|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  472. %7|1609342021.589|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  473. %7|1609342021.589|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  474. %7|1609342021.589|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  475. %7|1609342021.589|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 2)
  476. %7|1609342021.592|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 3ms in state APIVERSION_QUERY) (_TRANSPORT): identical to last error: error log suppressed
  477. %7|1609342021.592|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to
  478. %7|1609342021.592|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN
  479. %3|1609342021.592|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  480. %7|1609342021.592|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  481. %7|1609342021.592|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 1 buffers
  482. %7|1609342021.592|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  483. %7|1609342021.592|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  484. %7|1609342021.592|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  485. %7|1609342021.592|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  486. %7|1609342021.592|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  487. %7|1609342021.592|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  488. %7|1609342021.592|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  489. %7|1609342021.592|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  490. %7|1609342021.592|RECONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Delaying next reconnect by 588ms
  491. %7|1609342021.592|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 45ms: lookup controller
  492. %7|1609342022.181|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  493. %7|1609342022.181|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  494. %7|1609342022.181|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  495. %7|1609342022.181|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  496. %7|1609342022.181|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  497. %7|1609342022.181|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: lookup controller
  498. %7|1609342022.181|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  499. %7|1609342022.181|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092
  500. %7|1609342022.181|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#3)
  501. %7|1609342022.181|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  502. %7|1609342022.181|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  503. %7|1609342022.181|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  504. %7|1609342022.181|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  505. %7|1609342022.181|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: lookup controller
  506. %7|1609342022.181|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 3)
  507. %7|1609342022.181|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  508. %7|1609342022.186|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 4ms in state APIVERSION_QUERY) (_TRANSPORT): identical to last error: error log suppressed
  509. %7|1609342022.186|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to
  510. %7|1609342022.186|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN
  511. %3|1609342022.186|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  512. %7|1609342022.186|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  513. %7|1609342022.186|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 1 buffers
  514. %7|1609342022.186|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  515. %7|1609342022.186|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  516. %7|1609342022.186|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  517. %7|1609342022.186|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  518. %7|1609342022.186|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  519. %7|1609342022.186|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  520. %7|1609342022.186|RECONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Delaying next reconnect by 739ms
  521. %7|1609342022.186|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  522. %7|1609342022.186|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  523. %7|1609342022.186|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 44ms: lookup controller
  524. %7|1609342022.456|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  525. %7|1609342022.926|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  526. %7|1609342022.926|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  527. %7|1609342022.926|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  528. %7|1609342022.926|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  529. %7|1609342022.926|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  530. %7|1609342022.926|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: lookup controller
  531. %7|1609342022.927|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  532. %7|1609342022.927|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv6#[::1]:9092
  533. %7|1609342022.927|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#4)
  534. %7|1609342022.927|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  535. %7|1609342022.927|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  536. %7|1609342022.927|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  537. %7|1609342022.927|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 4)
  538. %7|1609342022.927|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  539. %7|1609342022.927|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  540. %7|1609342022.927|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: lookup controller
  541. %7|1609342022.930|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 3ms in state APIVERSION_QUERY) (_TRANSPORT): identical to last error: error log suppressed
  542. %7|1609342022.930|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to
  543. %7|1609342022.930|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN
  544. %3|1609342022.930|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  545. %7|1609342022.930|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  546. %7|1609342022.930|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 1 buffers
  547. %7|1609342022.930|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  548. %7|1609342022.930|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  549. %7|1609342022.930|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  550. %7|1609342022.930|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  551. %7|1609342022.930|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  552. %7|1609342022.930|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  553. %7|1609342022.930|RECONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Delaying next reconnect by 3116ms
  554. %7|1609342022.931|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Success
  555. %7|1609342022.931|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
  556. %7|1609342022.931|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 44ms: lookup controller
  557. %7|1609342023.456|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  558. %7|1609342024.434|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for controller: Local: Timed out
  559. %7|1609342024.434|ADMINFAIL|rdkafka#producer-1| [thrd:main]: Admin CREATETOPICS result error: Failed while waiting for controller: Local: Timed out
  560. %7|1609342024.456|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  561. Exception thrown: 'Confluent.Kafka.KafkaException' in System.Private.CoreLib.dll
  562. %7|1609342025.457|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  563. %7|1609342026.047|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  564. %7|1609342026.047|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  565. %7|1609342026.047|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  566. %7|1609342026.048|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv6#[::1]:9092 (plaintext) with socket 205
  567. %7|1609342026.049|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv6#[::1]:9092
  568. %7|1609342026.049|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#5)
  569. %7|1609342026.049|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  570. %7|1609342026.049|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  571. %7|1609342026.049|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  572. %7|1609342026.049|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 5)
  573. %7|1609342026.051|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 2ms in state APIVERSION_QUERY) (_TRANSPORT): identical to last error: error log suppressed
  574. %7|1609342026.051|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features -ApiVersion to
  575. %7|1609342026.051|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> DOWN
  576. %3|1609342026.051|ERROR|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: 1/1 brokers are down
  577. %7|1609342026.051|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  578. %7|1609342026.051|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 1 buffers
  579. %7|1609342026.051|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
  580. %7|1609342026.051|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
  581. %7|1609342026.051|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT
  582. %7|1609342026.051|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  583. %7|1609342026.051|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
  584. %7|1609342026.051|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  585. %7|1609342026.051|RECONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Delaying next reconnect by 5208ms
  586. %7|1609342026.457|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  587. %7|1609342027.457|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  588. %7|1609342028.458|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  589. %7|1609342029.458|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  590. %7|1609342030.459|CONNECT|rdkafka#producer-1| [thrd:main]: Cluster connection already in progress: no cluster connection
  591. %7|1609342031.259|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
  592. %7|1609342031.259|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
  593. %7|1609342031.259|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  594. %7|1609342031.260|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 205
  595. %7|1609342031.260|CONNECT|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092
  596. %7|1609342031.260|CONNECTED|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#6)
  597. %7|1609342031.260|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
  598. %7|1609342031.260|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
  599. %7|1609342031.260|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  600. %7|1609342031.260|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 6)
  601. %7|1609342031.416|RECV|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 344 bytes, CorrId 6, rtt 155.50ms)
  602. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support:
  603. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Produce (0) Versions 0..8
  604. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Fetch (1) Versions 0..11
  605. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Offset (2) Versions 0..5
  606. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Metadata (3) Versions 0..9
  607. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..4
  608. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..2
  609. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..6
  610. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
  611. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
  612. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..7
  613. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey FindCoordinator (10) Versions 0..3
  614. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..7
  615. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
  616. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..4
  617. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
  618. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
  619. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..3
  620. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
  621. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
  622. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..5
  623. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..4
  624. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..1
  625. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..3
  626. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
  627. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..1
  628. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..1
  629. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..1
  630. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
  631. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
  632. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..2
  633. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..2
  634. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..2
  635. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..2
  636. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..1
  637. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..1
  638. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..1
  639. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
  640. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..2
  641. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..2
  642. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
  643. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
  644. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..2
  645. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
  646. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-43? (43) Versions 0..2
  647. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-44? (44) Versions 0..1
  648. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-45? (45) Versions 0..0
  649. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-46? (46) Versions 0..0
  650. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Unknown-47? (47) Versions 0..0
  651. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
  652. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
  653. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1
  654. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
  655. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
  656. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2
  657. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
  658. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion
  659. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
  660. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator
  661. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
  662. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
  663. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
  664. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
  665. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
  666. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
  667. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
  668. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer
  669. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
  670. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
  671. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime
  672. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
  673. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl
  674. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
  675. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake
  676. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
  677. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4
  678. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
  679. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime
  680. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
  681. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer
  682. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
  683. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
  684. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD
  685. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
  686. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
  687. %7|1609342031.416|APIVERSION|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslAuthReq
  688. %7|1609342031.416|FEATURE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
  689. %7|1609342031.416|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
  690. %7|1609342031.416|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
  691. %7|1609342031.416|METADATA|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
  692. %7|1609342031.416|SEND|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 7)
  693. %7|1609342031.457|RECV|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v4, 61 bytes, CorrId 7, rtt 41.02ms)
  694. %7|1609342031.457|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
  695. %7|1609342031.457|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: ClusterId: fCcD_y62RAapaITdsBTsNw, ControllerId: 0
  696. %7|1609342031.457|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
  697. %7|1609342031.457|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: 127.0.0.1:9092 NodeId 0
  698. %7|1609342031.457|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 127.0.0.1:9092/0: Enabled low-latency ops queue wake-ups
  699. %7|1609342031.457|BROKER|rdkafka#producer-1| [thrd:main]: 127.0.0.1:9092/0: Added new broker with NodeId 0
  700. %7|1609342031.457|CLUSTERID|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "fCcD_y62RAapaITdsBTsNw"
  701. %7|1609342031.457|CONTROLLERID|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0
  702. %7|1609342031.457|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
  703. %7|1609342031.457|BRKMAIN|rdkafka#producer-1| [thrd:127.0.0.1:9092/0]: 127.0.0.1:9092/0: Enter main broker thread
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement