API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Dec 20th, 2017
207
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 157.65 KB | None | 0 0
raw download clone embed print report
  1. kafka_1 | 2017-12-20 09:01:13,214 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-28 with initial high watermark 0
  2. kafka_1 | 2017-12-20 09:01:13,214 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-28 broker=1] __consumer_offsets-28 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  3. kafka_1 | 2017-12-20 09:01:13,217 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-38 with initial high watermark 0
  4. kafka_1 | 2017-12-20 09:01:13,217 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-38 broker=1] __consumer_offsets-38 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  5. kafka_1 | 2017-12-20 09:01:13,218 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition my_connect_offsets-10 with initial high watermark 0
  6. kafka_1 | 2017-12-20 09:01:13,218 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition my_connect_offsets-10 broker=1] my_connect_offsets-10 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  7. kafka_1 | 2017-12-20 09:01:13,225 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-35 with initial high watermark 0
  8. kafka_1 | 2017-12-20 09:01:13,225 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-35 broker=1] __consumer_offsets-35 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  9. kafka_1 | 2017-12-20 09:01:13,227 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition my_connect_offsets-7 with initial high watermark 0
  10. kafka_1 | 2017-12-20 09:01:13,227 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition my_connect_offsets-7 broker=1] my_connect_offsets-7 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  11. kafka_1 | 2017-12-20 09:01:13,230 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-44 with initial high watermark 0
  12. kafka_1 | 2017-12-20 09:01:13,230 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-44 broker=1] __consumer_offsets-44 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  13. kafka_1 | 2017-12-20 09:01:13,235 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-6 with initial high watermark 0
  14. kafka_1 | 2017-12-20 09:01:13,235 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-6 broker=1] __consumer_offsets-6 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  15. kafka_1 | 2017-12-20 09:01:13,238 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-25 with initial high watermark 0
  16. kafka_1 | 2017-12-20 09:01:13,239 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-25 broker=1] __consumer_offsets-25 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  17. kafka_1 | 2017-12-20 09:01:13,244 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-16 with initial high watermark 41
  18. kafka_1 | 2017-12-20 09:01:13,244 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-16 broker=1] __consumer_offsets-16 starts at Leader Epoch 14 from offset 41. Previous Leader Epoch was: -1
  19. kafka_1 | 2017-12-20 09:01:13,246 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition connect-status-4 with initial high watermark 0
  20. kafka_1 | 2017-12-20 09:01:13,246 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition connect-status-4 broker=1] connect-status-4 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  21. kafka_1 | 2017-12-20 09:01:13,249 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-22 with initial high watermark 0
  22. kafka_1 | 2017-12-20 09:01:13,249 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-22 broker=1] __consumer_offsets-22 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  23. kafka_1 | 2017-12-20 09:01:13,255 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-41 with initial high watermark 0
  24. kafka_1 | 2017-12-20 09:01:13,255 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-41 broker=1] __consumer_offsets-41 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  25. kafka_1 | 2017-12-20 09:01:13,258 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition my_connect_offsets-4 with initial high watermark 0
  26. kafka_1 | 2017-12-20 09:01:13,259 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition my_connect_offsets-4 broker=1] my_connect_offsets-4 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  27. kafka_1 | 2017-12-20 09:01:13,267 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-32 with initial high watermark 0
  28. kafka_1 | 2017-12-20 09:01:13,267 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-32 broker=1] __consumer_offsets-32 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  29. kafka_1 | 2017-12-20 09:01:13,270 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-3 with initial high watermark 0
  30. kafka_1 | 2017-12-20 09:01:13,271 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-3 broker=1] __consumer_offsets-3 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  31. kafka_1 | 2017-12-20 09:01:13,279 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition __consumer_offsets-13 with initial high watermark 0
  32. kafka_1 | 2017-12-20 09:01:13,279 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition __consumer_offsets-13 broker=1] __consumer_offsets-13 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  33. kafka_1 | 2017-12-20 09:01:13,283 - INFO [kafka-request-handler-0:Logging$class@72] - Replica loaded for partition my_connect_offsets-23 with initial high watermark 0
  34. kafka_1 | 2017-12-20 09:01:13,284 - INFO [kafka-request-handler-0:Logging$class@72] - [Partition my_connect_offsets-23 broker=1] my_connect_offsets-23 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1
  35. kafka_1 | 2017-12-20 09:01:13,318 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-25
  36. kafka_1 | 2017-12-20 09:01:13,329 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-31
  37. kafka_1 | 2017-12-20 09:01:13,330 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-37
  38. kafka_1 | 2017-12-20 09:01:13,331 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-43
  39. kafka_1 | 2017-12-20 09:01:13,332 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-49
  40. kafka_1 | 2017-12-20 09:01:13,333 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-44
  41. kafka_1 | 2017-12-20 09:01:13,333 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-1
  42. kafka_1 | 2017-12-20 09:01:13,334 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-7
  43. kafka_1 | 2017-12-20 09:01:13,335 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-13
  44. kafka_1 | 2017-12-20 09:01:13,336 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-19
  45. kafka_1 | 2017-12-20 09:01:13,336 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-2
  46. kafka_1 | 2017-12-20 09:01:13,337 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-8
  47. kafka_1 | 2017-12-20 09:01:13,338 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-25 in 19 milliseconds.
  48. kafka_1 | 2017-12-20 09:01:13,338 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-14
  49. kafka_1 | 2017-12-20 09:01:13,344 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-20
  50. kafka_1 | 2017-12-20 09:01:13,344 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-26
  51. kafka_1 | 2017-12-20 09:01:13,344 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-32
  52. kafka_1 | 2017-12-20 09:01:13,345 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-38
  53. kafka_1 | 2017-12-20 09:01:13,345 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-3
  54. kafka_1 | 2017-12-20 09:01:13,346 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-9
  55. kafka_1 | 2017-12-20 09:01:13,345 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-31 in 6 milliseconds.
  56. kafka_1 | 2017-12-20 09:01:13,346 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-15
  57. kafka_1 | 2017-12-20 09:01:13,347 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-21
  58. kafka_1 | 2017-12-20 09:01:13,346 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-37 in 0 milliseconds.
  59. kafka_1 | 2017-12-20 09:01:13,347 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-27
  60. kafka_1 | 2017-12-20 09:01:13,348 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-33
  61. kafka_1 | 2017-12-20 09:01:13,348 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-43 in 1 milliseconds.
  62. kafka_1 | 2017-12-20 09:01:13,348 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-39
  63. kafka_1 | 2017-12-20 09:01:13,351 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-45
  64. kafka_1 | 2017-12-20 09:01:13,354 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-22
  65. kafka_1 | 2017-12-20 09:01:13,354 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-28
  66. kafka_1 | 2017-12-20 09:01:13,354 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-34
  67. kafka_1 | 2017-12-20 09:01:13,355 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-40
  68. kafka_1 | 2017-12-20 09:01:13,357 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-46
  69. kafka_1 | 2017-12-20 09:01:13,357 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-41
  70. kafka_1 | 2017-12-20 09:01:13,358 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-47
  71. kafka_1 | 2017-12-20 09:01:13,358 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-4
  72. kafka_1 | 2017-12-20 09:01:13,358 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-10
  73. kafka_1 | 2017-12-20 09:01:13,359 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-16
  74. kafka_1 | 2017-12-20 09:01:13,359 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-5
  75. kafka_1 | 2017-12-20 09:01:13,359 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-11
  76. kafka_1 | 2017-12-20 09:01:13,363 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-17
  77. kafka_1 | 2017-12-20 09:01:13,363 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-23
  78. kafka_1 | 2017-12-20 09:01:13,363 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-29
  79. kafka_1 | 2017-12-20 09:01:13,364 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-35
  80. kafka_1 | 2017-12-20 09:01:13,368 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-0
  81. kafka_1 | 2017-12-20 09:01:13,368 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-6
  82. kafka_1 | 2017-12-20 09:01:13,369 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-12
  83. kafka_1 | 2017-12-20 09:01:13,369 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-18
  84. kafka_1 | 2017-12-20 09:01:13,369 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-24
  85. kafka_1 | 2017-12-20 09:01:13,369 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-30
  86. kafka_1 | 2017-12-20 09:01:13,370 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-36
  87. kafka_1 | 2017-12-20 09:01:13,371 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-42
  88. kafka_1 | 2017-12-20 09:01:13,371 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-48
  89. kafka_1 | 2017-12-20 09:01:13,457 - INFO [kafka-request-handler-2:Logging$class@72] - [ReplicaFetcherManager on broker 1] Removed fetcher for partitions __consumer_offsets-22,my_connect_offsets-7,__consumer_offsets-30,my_connect_offsets-15,__consumer_offsets-8,__consumer_offsets-21,__consumer_offsets-4,__consumer_offsets-27,__consumer_offsets-7,__consumer_offsets-9,__consumer_offsets-46,my_connect_offsets-20,__consumer_offsets-25,my_connect_offsets-12,connect-status-4,__consumer_offsets-35,my_connect_offsets-2,__consumer_offsets-41,__consumer_offsets-33,my_connect_offsets-22,__consumer_offsets-23,__consumer_offsets-49,my_connect_offsets-1,my_connect_offsets-11,my_connect_offsets-24,__consumer_offsets-47,__consumer_offsets-16,__consumer_offsets-28,my_connect_offsets-19,__consumer_offsets-31,__consumer_offsets-36,connect-status-3,__consumer_offsets-42,__consumer_offsets-3,__consumer_offsets-18,__consumer_offsets-37,my_connect_offsets-16,__consumer_offsets-15,__consumer_offsets-24,my_connect_configs-0,my_connect_offsets-18,connect-status-2,my_connect_offsets-10,__consumer_offsets-38,__consumer_offsets-17,my_connect_offsets-23,__consumer_offsets-48,__consumer_offsets-19,__consumer_offsets-11,__consumer_offsets-13,__consumer_offsets-2,__consumer_offsets-43,__consumer_offsets-6,my_connect_offsets-5,__consumer_offsets-14,my_connect_offsets-13,my_connect_offsets-4,my_connect_offsets-17,my_connect_offsets-6,my_connect_offsets-3,my_connect_offsets-21,my_connect_offsets-14,connect-status-0,__consumer_offsets-20,__consumer_offsets-0,__consumer_offsets-44,customers-0,__consumer_offsets-39,__consumer_offsets-12,__consumer_offsets-45,__consumer_offsets-1,__consumer_offsets-5,__consumer_offsets-26,__consumer_offsets-29,connect-status-1,__consumer_offsets-34,__consumer_offsets-10,__consumer_offsets-32,__consumer_offsets-40,my_connect_offsets-0,my_connect_offsets-8,my_connect_offsets-9
  90. kafka_1 | 2017-12-20 09:01:13,457 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-0 broker=1] __consumer_offsets-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  91. kafka_1 | 2017-12-20 09:01:13,459 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition connect-status-1 broker=1] connect-status-1 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  92. kafka_1 | 2017-12-20 09:01:13,460 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-29 broker=1] __consumer_offsets-29 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  93. kafka_1 | 2017-12-20 09:01:13,461 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-48 broker=1] __consumer_offsets-48 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  94. kafka_1 | 2017-12-20 09:01:13,463 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-1 broker=1] my_connect_offsets-1 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  95. kafka_1 | 2017-12-20 09:01:13,471 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-10 broker=1] __consumer_offsets-10 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  96. kafka_1 | 2017-12-20 09:01:13,472 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_configs-0 broker=1] my_connect_configs-0 starts at Leader Epoch 15 from offset 16. Previous Leader Epoch was: 14
  97. kafka_1 | 2017-12-20 09:01:13,472 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-20 broker=1] my_connect_offsets-20 starts at Leader Epoch 15 from offset 9. Previous Leader Epoch was: 14
  98. kafka_1 | 2017-12-20 09:01:13,473 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-45 broker=1] __consumer_offsets-45 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  99. kafka_1 | 2017-12-20 09:01:13,474 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-26 broker=1] __consumer_offsets-26 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  100. kafka_1 | 2017-12-20 09:01:13,475 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-7 broker=1] __consumer_offsets-7 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  101. kafka_1 | 2017-12-20 09:01:13,476 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-17 broker=1] my_connect_offsets-17 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  102. kafka_1 | 2017-12-20 09:01:13,478 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-42 broker=1] __consumer_offsets-42 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  103. kafka_1 | 2017-12-20 09:01:13,478 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupCoordinator 1]: Loading group metadata for 1 with generation 39
  104. kafka_1 | 2017-12-20 09:01:13,478 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-24 broker=1] my_connect_offsets-24 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  105. kafka_1 | 2017-12-20 09:01:13,480 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-4 broker=1] __consumer_offsets-4 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  106. kafka_1 | 2017-12-20 09:01:13,480 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-49 in 131 milliseconds.
  107. kafka_1 | 2017-12-20 09:01:13,480 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-14 broker=1] my_connect_offsets-14 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  108. kafka_1 | 2017-12-20 09:01:13,481 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-23 broker=1] __consumer_offsets-23 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  109. kafka_1 | 2017-12-20 09:01:13,481 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-5 broker=1] my_connect_offsets-5 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  110. kafka_1 | 2017-12-20 09:01:13,481 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-44 in 1 milliseconds.
  111. kafka_1 | 2017-12-20 09:01:13,482 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-1 in 1 milliseconds.
  112. kafka_1 | 2017-12-20 09:01:13,482 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-7 in 0 milliseconds.
  113. kafka_1 | 2017-12-20 09:01:13,483 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-13 in 0 milliseconds.
  114. kafka_1 | 2017-12-20 09:01:13,483 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-19 in 0 milliseconds.
  115. kafka_1 | 2017-12-20 09:01:13,486 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-11 broker=1] my_connect_offsets-11 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  116. kafka_1 | 2017-12-20 09:01:13,490 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-2 in 0 milliseconds.
  117. kafka_1 | 2017-12-20 09:01:13,490 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-21 broker=1] my_connect_offsets-21 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  118. kafka_1 | 2017-12-20 09:01:13,491 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-2 broker=1] my_connect_offsets-2 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  119. kafka_1 | 2017-12-20 09:01:13,491 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-8 in 1 milliseconds.
  120. kafka_1 | 2017-12-20 09:01:13,491 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-1 broker=1] __consumer_offsets-1 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  121. kafka_1 | 2017-12-20 09:01:13,491 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-14 in 0 milliseconds.
  122. kafka_1 | 2017-12-20 09:01:13,492 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-20 in 0 milliseconds.
  123. kafka_1 | 2017-12-20 09:01:13,492 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-26 in 0 milliseconds.
  124. kafka_1 | 2017-12-20 09:01:13,493 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-32 in 0 milliseconds.
  125. kafka_1 | 2017-12-20 09:01:13,492 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-20 broker=1] __consumer_offsets-20 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  126. kafka_1 | 2017-12-20 09:01:13,495 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-39 broker=1] __consumer_offsets-39 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  127. kafka_1 | 2017-12-20 09:01:13,493 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-38 in 0 milliseconds.
  128. kafka_1 | 2017-12-20 09:01:13,495 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-3 in 0 milliseconds.
  129. kafka_1 | 2017-12-20 09:01:13,495 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-9 in 0 milliseconds.
  130. kafka_1 | 2017-12-20 09:01:13,495 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-17 broker=1] __consumer_offsets-17 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  131. kafka_1 | 2017-12-20 09:01:13,497 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-36 broker=1] __consumer_offsets-36 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  132. kafka_1 | 2017-12-20 09:01:13,497 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-8 broker=1] my_connect_offsets-8 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  133. kafka_1 | 2017-12-20 09:01:13,498 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-18 broker=1] my_connect_offsets-18 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  134. kafka_1 | 2017-12-20 09:01:13,499 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-14 broker=1] __consumer_offsets-14 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  135. kafka_1 | 2017-12-20 09:01:13,496 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-15 in 0 milliseconds.
  136. kafka_1 | 2017-12-20 09:01:13,500 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-21 in 0 milliseconds.
  137. kafka_1 | 2017-12-20 09:01:13,500 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-27 in 0 milliseconds.
  138. kafka_1 | 2017-12-20 09:01:13,501 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-33 in 0 milliseconds.
  139. kafka_1 | 2017-12-20 09:01:13,502 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-39 in 0 milliseconds.
  140. kafka_1 | 2017-12-20 09:01:13,503 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-45 in 1 milliseconds.
  141. kafka_1 | 2017-12-20 09:01:13,503 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-22 in 0 milliseconds.
  142. kafka_1 | 2017-12-20 09:01:13,504 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-28 in 0 milliseconds.
  143. kafka_1 | 2017-12-20 09:01:13,505 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-34 in 1 milliseconds.
  144. kafka_1 | 2017-12-20 09:01:13,506 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-40 in 0 milliseconds.
  145. kafka_1 | 2017-12-20 09:01:13,504 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-33 broker=1] __consumer_offsets-33 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  146. kafka_1 | 2017-12-20 09:01:13,507 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-15 broker=1] my_connect_offsets-15 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  147. kafka_1 | 2017-12-20 09:01:13,507 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-49 broker=1] __consumer_offsets-49 starts at Leader Epoch 15 from offset 39. Previous Leader Epoch was: 14
  148. kafka_1 | 2017-12-20 09:01:13,509 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-12 broker=1] my_connect_offsets-12 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  149. kafka_1 | 2017-12-20 09:01:13,508 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-46 in 2 milliseconds.
  150. kafka_1 | 2017-12-20 09:01:13,509 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-41 in 0 milliseconds.
  151. kafka_1 | 2017-12-20 09:01:13,511 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-11 broker=1] __consumer_offsets-11 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  152. kafka_1 | 2017-12-20 09:01:13,511 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition connect-status-2 broker=1] connect-status-2 starts at Leader Epoch 15 from offset 35. Previous Leader Epoch was: 14
  153. kafka_1 | 2017-12-20 09:01:13,512 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-30 broker=1] __consumer_offsets-30 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  154. kafka_1 | 2017-12-20 09:01:13,513 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-46 broker=1] __consumer_offsets-46 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  155. kafka_1 | 2017-12-20 09:01:13,511 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-47 in 1 milliseconds.
  156. kafka_1 | 2017-12-20 09:01:13,514 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-4 in 0 milliseconds.
  157. kafka_1 | 2017-12-20 09:01:13,515 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-10 in 0 milliseconds.
  158. kafka_1 | 2017-12-20 09:01:13,519 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-27 broker=1] __consumer_offsets-27 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  159. kafka_1 | 2017-12-20 09:01:13,519 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-9 broker=1] my_connect_offsets-9 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  160. kafka_1 | 2017-12-20 09:01:13,519 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-8 broker=1] __consumer_offsets-8 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  161. kafka_1 | 2017-12-20 09:01:13,521 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-6 broker=1] my_connect_offsets-6 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  162. kafka_1 | 2017-12-20 09:01:13,522 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-24 broker=1] __consumer_offsets-24 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  163. kafka_1 | 2017-12-20 09:01:13,522 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-43 broker=1] __consumer_offsets-43 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  164. kafka_1 | 2017-12-20 09:01:13,523 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-5 broker=1] __consumer_offsets-5 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  165. kafka_1 | 2017-12-20 09:01:13,524 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-22 broker=1] my_connect_offsets-22 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  166. kafka_1 | 2017-12-20 09:01:13,525 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-3 broker=1] my_connect_offsets-3 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  167. kafka_1 | 2017-12-20 09:01:13,525 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-21 broker=1] __consumer_offsets-21 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  168. kafka_1 | 2017-12-20 09:01:13,527 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-2 broker=1] __consumer_offsets-2 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  169. kafka_1 | 2017-12-20 09:01:13,527 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-40 broker=1] __consumer_offsets-40 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  170. kafka_1 | 2017-12-20 09:01:13,528 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-37 broker=1] __consumer_offsets-37 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  171. kafka_1 | 2017-12-20 09:01:13,528 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-18 broker=1] __consumer_offsets-18 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  172. kafka_1 | 2017-12-20 09:01:13,529 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-19 broker=1] my_connect_offsets-19 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  173. kafka_1 | 2017-12-20 09:01:13,530 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-0 broker=1] my_connect_offsets-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  174. kafka_1 | 2017-12-20 09:01:13,531 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-16 broker=1] my_connect_offsets-16 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  175. kafka_1 | 2017-12-20 09:01:13,532 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-15 broker=1] __consumer_offsets-15 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  176. kafka_1 | 2017-12-20 09:01:13,532 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-34 broker=1] __consumer_offsets-34 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  177. kafka_1 | 2017-12-20 09:01:13,532 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-12 broker=1] __consumer_offsets-12 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  178. kafka_1 | 2017-12-20 09:01:13,533 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-31 broker=1] __consumer_offsets-31 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  179. kafka_1 | 2017-12-20 09:01:13,535 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition connect-status-3 broker=1] connect-status-3 starts at Leader Epoch 15 from offset 114. Previous Leader Epoch was: 14
  180. kafka_1 | 2017-12-20 09:01:13,535 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition customers-0 broker=1] customers-0 starts at Leader Epoch 12 from offset 51. Previous Leader Epoch was: 11
  181. kafka_1 | 2017-12-20 09:01:13,536 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-13 broker=1] my_connect_offsets-13 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  182. kafka_1 | 2017-12-20 09:01:13,536 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-9 broker=1] __consumer_offsets-9 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  183. kafka_1 | 2017-12-20 09:01:13,537 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition connect-status-0 broker=1] connect-status-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  184. kafka_1 | 2017-12-20 09:01:13,537 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-47 broker=1] __consumer_offsets-47 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  185. kafka_1 | 2017-12-20 09:01:13,538 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-19 broker=1] __consumer_offsets-19 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  186. kafka_1 | 2017-12-20 09:01:13,539 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-28 broker=1] __consumer_offsets-28 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  187. kafka_1 | 2017-12-20 09:01:13,540 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-38 broker=1] __consumer_offsets-38 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  188. kafka_1 | 2017-12-20 09:01:13,540 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-10 broker=1] my_connect_offsets-10 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  189. kafka_1 | 2017-12-20 09:01:13,542 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-35 broker=1] __consumer_offsets-35 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  190. kafka_1 | 2017-12-20 09:01:13,542 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-7 broker=1] my_connect_offsets-7 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  191. kafka_1 | 2017-12-20 09:01:13,542 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-44 broker=1] __consumer_offsets-44 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  192. kafka_1 | 2017-12-20 09:01:13,543 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-6 broker=1] __consumer_offsets-6 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  193. kafka_1 | 2017-12-20 09:01:13,544 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-25 broker=1] __consumer_offsets-25 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  194. kafka_1 | 2017-12-20 09:01:13,544 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-16 broker=1] __consumer_offsets-16 starts at Leader Epoch 15 from offset 41. Previous Leader Epoch was: 14
  195. kafka_1 | 2017-12-20 09:01:13,545 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition connect-status-4 broker=1] connect-status-4 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  196. kafka_1 | 2017-12-20 09:01:13,545 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-22 broker=1] __consumer_offsets-22 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  197. kafka_1 | 2017-12-20 09:01:13,546 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-41 broker=1] __consumer_offsets-41 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  198. kafka_1 | 2017-12-20 09:01:13,547 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-4 broker=1] my_connect_offsets-4 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  199. kafka_1 | 2017-12-20 09:01:13,548 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-32 broker=1] __consumer_offsets-32 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  200. kafka_1 | 2017-12-20 09:01:13,548 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupCoordinator 1]: Loading group metadata for connect-jdbc-sink with generation 36
  201. kafka_1 | 2017-12-20 09:01:13,549 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-16 in 33 milliseconds.
  202. kafka_1 | 2017-12-20 09:01:13,549 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-3 broker=1] __consumer_offsets-3 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  203. kafka_1 | 2017-12-20 09:01:13,549 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-5 in 0 milliseconds.
  204. kafka_1 | 2017-12-20 09:01:13,550 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-11 in 0 milliseconds.
  205. kafka_1 | 2017-12-20 09:01:13,550 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition __consumer_offsets-13 broker=1] __consumer_offsets-13 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  206. kafka_1 | 2017-12-20 09:01:13,550 - INFO [kafka-request-handler-2:Logging$class@72] - [Partition my_connect_offsets-23 broker=1] my_connect_offsets-23 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14
  207. kafka_1 | 2017-12-20 09:01:13,551 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-17 in 1 milliseconds.
  208. kafka_1 | 2017-12-20 09:01:13,553 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-23 in 1 milliseconds.
  209. kafka_1 | 2017-12-20 09:01:13,553 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-29 in 0 milliseconds.
  210. kafka_1 | 2017-12-20 09:01:13,553 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-35 in 0 milliseconds.
  211. kafka_1 | 2017-12-20 09:01:13,554 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-0 in 0 milliseconds.
  212. kafka_1 | 2017-12-20 09:01:13,555 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-6 in 0 milliseconds.
  213. kafka_1 | 2017-12-20 09:01:13,556 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-12 in 0 milliseconds.
  214. kafka_1 | 2017-12-20 09:01:13,556 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-18 in 0 milliseconds.
  215. kafka_1 | 2017-12-20 09:01:13,557 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-24 in 1 milliseconds.
  216. kafka_1 | 2017-12-20 09:01:13,557 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-30 in 0 milliseconds.
  217. kafka_1 | 2017-12-20 09:01:13,558 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-36 in 0 milliseconds.
  218. kafka_1 | 2017-12-20 09:01:13,559 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-42 in 0 milliseconds.
  219. kafka_1 | 2017-12-20 09:01:13,560 - INFO [group-metadata-manager-0:Logging$class@72] - [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-48 in 1 milliseconds.
  220. connect_1 | 2017-12-20 09:01:13,888 INFO || Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  221. connect_1 | 2017-12-20 09:01:13,888 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  222. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  223. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  224. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  225. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  226. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  227. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  228. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  229. connect_1 | 2017-12-20 09:01:13,889 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  230. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  231. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  232. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  233. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  234. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  235. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  236. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  237. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  238. connect_1 | 2017-12-20 09:01:13,890 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  239. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  240. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  241. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  242. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  243. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  244. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  245. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  246. connect_1 | 2017-12-20 09:01:13,891 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  247. connect_1 | 2017-12-20 09:01:13,892 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  248. connect_1 | 2017-12-20 09:01:13,892 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  249. connect_1 | 2017-12-20 09:01:13,892 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  250. connect_1 | 2017-12-20 09:01:13,892 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  251. connect_1 | 2017-12-20 09:01:13,892 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  252. connect_1 | 2017-12-20 09:01:13,893 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  253. connect_1 | 2017-12-20 09:01:13,893 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  254. connect_1 | 2017-12-20 09:01:13,893 INFO || Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  255. connect_1 | 2017-12-20 09:01:13,894 INFO || Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  256. connect_1 | 2017-12-20 09:01:13,894 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  257. connect_1 | 2017-12-20 09:01:13,894 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  258. connect_1 | 2017-12-20 09:01:13,894 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  259. connect_1 | 2017-12-20 09:01:13,895 INFO || Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  260. connect_1 | 2017-12-20 09:01:13,895 INFO || Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  261. connect_1 | 2017-12-20 09:01:13,895 INFO || Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  262. connect_1 | 2017-12-20 09:01:13,895 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  263. connect_1 | 2017-12-20 09:01:13,895 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  264. connect_1 | 2017-12-20 09:01:13,896 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  265. connect_1 | 2017-12-20 09:01:13,896 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  266. connect_1 | 2017-12-20 09:01:13,896 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  267. connect_1 | 2017-12-20 09:01:13,896 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  268. connect_1 | 2017-12-20 09:01:13,896 INFO || Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  269. connect_1 | 2017-12-20 09:01:13,897 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  270. connect_1 | 2017-12-20 09:01:13,897 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  271. connect_1 | 2017-12-20 09:01:13,898 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  272. connect_1 | 2017-12-20 09:01:13,898 INFO || Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  273. connect_1 | 2017-12-20 09:01:13,899 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  274. connect_1 | 2017-12-20 09:01:13,899 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  275. connect_1 | 2017-12-20 09:01:13,899 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
  276. connect_1 | 2017-12-20 09:01:13,915 INFO || DistributedConfig values:
  277. connect_1 | access.control.allow.methods =
  278. connect_1 | access.control.allow.origin =
  279. connect_1 | bootstrap.servers = [kafka:9092]
  280. connect_1 | client.id =
  281. connect_1 | config.storage.replication.factor = 1
  282. connect_1 | config.storage.topic = my_connect_configs
  283. connect_1 | connections.max.idle.ms = 540000
  284. connect_1 | group.id = 1
  285. connect_1 | heartbeat.interval.ms = 3000
  286. connect_1 | internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
  287. connect_1 | internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
  288. connect_1 | key.converter = class org.apache.kafka.connect.json.JsonConverter
  289. connect_1 | metadata.max.age.ms = 300000
  290. connect_1 | metric.reporters = []
  291. connect_1 | metrics.num.samples = 2
  292. connect_1 | metrics.sample.window.ms = 30000
  293. connect_1 | offset.flush.interval.ms = 60000
  294. connect_1 | offset.flush.timeout.ms = 5000
  295. connect_1 | offset.storage.partitions = 25
  296. connect_1 | offset.storage.replication.factor = 1
  297. connect_1 | offset.storage.topic = my_connect_offsets
  298. connect_1 | plugin.path = [/kafka/connect]
  299. connect_1 | rebalance.timeout.ms = 60000
  300. connect_1 | receive.buffer.bytes = 32768
  301. connect_1 | reconnect.backoff.max.ms = 1000
  302. connect_1 | reconnect.backoff.ms = 50
  303. connect_1 | request.timeout.ms = 40000
  304. connect_1 | rest.advertised.host.name = 172.19.0.5
  305. connect_1 | rest.advertised.port = 8083
  306. connect_1 | rest.host.name = 172.19.0.5
  307. connect_1 | rest.port = 8083
  308. connect_1 | retry.backoff.ms = 100
  309. connect_1 | sasl.jaas.config = null
  310. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  311. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  312. connect_1 | sasl.kerberos.service.name = null
  313. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  314. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  315. connect_1 | sasl.mechanism = GSSAPI
  316. connect_1 | security.protocol = PLAINTEXT
  317. connect_1 | send.buffer.bytes = 131072
  318. connect_1 | session.timeout.ms = 10000
  319. connect_1 | ssl.cipher.suites = null
  320. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  321. connect_1 | ssl.endpoint.identification.algorithm = null
  322. connect_1 | ssl.key.password = null
  323. connect_1 | ssl.keymanager.algorithm = SunX509
  324. connect_1 | ssl.keystore.location = null
  325. connect_1 | ssl.keystore.password = null
  326. connect_1 | ssl.keystore.type = JKS
  327. connect_1 | ssl.protocol = TLS
  328. connect_1 | ssl.provider = null
  329. connect_1 | ssl.secure.random.implementation = null
  330. connect_1 | ssl.trustmanager.algorithm = PKIX
  331. connect_1 | ssl.truststore.location = null
  332. connect_1 | ssl.truststore.password = null
  333. connect_1 | ssl.truststore.type = JKS
  334. connect_1 | status.storage.partitions = 5
  335. connect_1 | status.storage.replication.factor = 1
  336. connect_1 | status.storage.topic = connect-status
  337. connect_1 | task.shutdown.graceful.timeout.ms = 10000
  338. connect_1 | value.converter = class org.apache.kafka.connect.json.JsonConverter
  339. connect_1 | worker.sync.timeout.ms = 3000
  340. connect_1 | worker.unsync.backoff.ms = 300000
  341. connect_1 | [org.apache.kafka.connect.runtime.distributed.DistributedConfig]
  342. connect_1 | 2017-12-20 09:01:14,027 INFO || Logging initialized @5805ms [org.eclipse.jetty.util.log]
  343. connect_1 | 2017-12-20 09:01:14,233 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  344. connect_1 | 2017-12-20 09:01:14,233 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  345. connect_1 | 2017-12-20 09:01:14,237 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect]
  346. connect_1 | 2017-12-20 09:01:14,238 INFO || Starting REST server [org.apache.kafka.connect.runtime.rest.RestServer]
  347. connect_1 | 2017-12-20 09:01:14,242 INFO || Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  348. connect_1 | 2017-12-20 09:01:14,243 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker]
  349. connect_1 | 2017-12-20 09:01:14,243 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore]
  350. connect_1 | 2017-12-20 09:01:14,244 INFO || Starting KafkaBasedLog with topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog]
  351. connect_1 | 2017-12-20 09:01:14,247 INFO || AdminClientConfig values:
  352. connect_1 | bootstrap.servers = [kafka:9092]
  353. connect_1 | client.id =
  354. connect_1 | connections.max.idle.ms = 300000
  355. connect_1 | metadata.max.age.ms = 300000
  356. connect_1 | metric.reporters = []
  357. connect_1 | metrics.num.samples = 2
  358. connect_1 | metrics.recording.level = INFO
  359. connect_1 | metrics.sample.window.ms = 30000
  360. connect_1 | receive.buffer.bytes = 65536
  361. connect_1 | reconnect.backoff.max.ms = 1000
  362. connect_1 | reconnect.backoff.ms = 50
  363. connect_1 | request.timeout.ms = 120000
  364. connect_1 | retries = 5
  365. connect_1 | retry.backoff.ms = 100
  366. connect_1 | sasl.jaas.config = null
  367. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  368. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  369. connect_1 | sasl.kerberos.service.name = null
  370. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  371. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  372. connect_1 | sasl.mechanism = GSSAPI
  373. connect_1 | security.protocol = PLAINTEXT
  374. connect_1 | send.buffer.bytes = 131072
  375. connect_1 | ssl.cipher.suites = null
  376. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  377. connect_1 | ssl.endpoint.identification.algorithm = null
  378. connect_1 | ssl.key.password = null
  379. connect_1 | ssl.keymanager.algorithm = SunX509
  380. connect_1 | ssl.keystore.location = null
  381. connect_1 | ssl.keystore.password = null
  382. connect_1 | ssl.keystore.type = JKS
  383. connect_1 | ssl.protocol = TLS
  384. connect_1 | ssl.provider = null
  385. connect_1 | ssl.secure.random.implementation = null
  386. connect_1 | ssl.trustmanager.algorithm = PKIX
  387. connect_1 | ssl.truststore.location = null
  388. connect_1 | ssl.truststore.password = null
  389. connect_1 | ssl.truststore.type = JKS
  390. connect_1 | [org.apache.kafka.clients.admin.AdminClientConfig]
  391. connect_1 | 2017-12-20 09:01:14,272 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  392. connect_1 | 2017-12-20 09:01:14,272 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  393. connect_1 | 2017-12-20 09:01:14,273 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  394. connect_1 | 2017-12-20 09:01:14,273 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  395. connect_1 | 2017-12-20 09:01:14,273 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  396. connect_1 | 2017-12-20 09:01:14,274 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  397. connect_1 | 2017-12-20 09:01:14,274 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  398. connect_1 | 2017-12-20 09:01:14,275 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  399. connect_1 | 2017-12-20 09:01:14,275 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  400. connect_1 | 2017-12-20 09:01:14,275 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  401. connect_1 | 2017-12-20 09:01:14,275 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  402. connect_1 | 2017-12-20 09:01:14,276 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  403. connect_1 | 2017-12-20 09:01:14,277 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  404. connect_1 | 2017-12-20 09:01:14,277 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  405. connect_1 | 2017-12-20 09:01:14,278 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  406. connect_1 | 2017-12-20 09:01:14,279 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  407. connect_1 | 2017-12-20 09:01:14,279 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  408. connect_1 | 2017-12-20 09:01:14,279 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  409. connect_1 | 2017-12-20 09:01:14,279 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  410. connect_1 | 2017-12-20 09:01:14,280 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  411. connect_1 | 2017-12-20 09:01:14,280 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  412. connect_1 | 2017-12-20 09:01:14,280 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  413. connect_1 | 2017-12-20 09:01:14,280 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  414. connect_1 | 2017-12-20 09:01:14,281 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  415. connect_1 | 2017-12-20 09:01:14,281 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  416. connect_1 | 2017-12-20 09:01:14,310 INFO || jetty-9.2.15.v20160210 [org.eclipse.jetty.server.Server]
  417. kafka_1 | 2017-12-20 09:01:14,474 - INFO [kafka-request-handler-5:Logging$class@80] - [Admin Manager on Broker 1]: Error processing create topic request for topic my_connect_offsets with arguments (numPartitions=25, replicationFactor=1, replicasAssignments={}, configs={cleanup.policy=compact})
  418. kafka_1 | org.apache.kafka.common.errors.TopicExistsException: Topic 'my_connect_offsets' already exists.
  419. connect_1 | 2017-12-20 09:01:14,510 INFO || ProducerConfig values:
  420. connect_1 | acks = all
  421. connect_1 | batch.size = 16384
  422. connect_1 | bootstrap.servers = [kafka:9092]
  423. connect_1 | buffer.memory = 33554432
  424. connect_1 | client.id =
  425. connect_1 | compression.type = none
  426. connect_1 | connections.max.idle.ms = 540000
  427. connect_1 | enable.idempotence = false
  428. connect_1 | interceptor.classes = null
  429. connect_1 | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  430. connect_1 | linger.ms = 0
  431. connect_1 | max.block.ms = 60000
  432. connect_1 | max.in.flight.requests.per.connection = 1
  433. connect_1 | max.request.size = 1048576
  434. connect_1 | metadata.max.age.ms = 300000
  435. connect_1 | metric.reporters = []
  436. connect_1 | metrics.num.samples = 2
  437. connect_1 | metrics.recording.level = INFO
  438. connect_1 | metrics.sample.window.ms = 30000
  439. connect_1 | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  440. connect_1 | receive.buffer.bytes = 32768
  441. connect_1 | reconnect.backoff.max.ms = 1000
  442. connect_1 | reconnect.backoff.ms = 50
  443. connect_1 | request.timeout.ms = 30000
  444. connect_1 | retries = 2147483647
  445. connect_1 | retry.backoff.ms = 100
  446. connect_1 | sasl.jaas.config = null
  447. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  448. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  449. connect_1 | sasl.kerberos.service.name = null
  450. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  451. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  452. connect_1 | sasl.mechanism = GSSAPI
  453. connect_1 | security.protocol = PLAINTEXT
  454. connect_1 | send.buffer.bytes = 131072
  455. connect_1 | ssl.cipher.suites = null
  456. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  457. connect_1 | ssl.endpoint.identification.algorithm = null
  458. connect_1 | ssl.key.password = null
  459. connect_1 | ssl.keymanager.algorithm = SunX509
  460. connect_1 | ssl.keystore.location = null
  461. connect_1 | ssl.keystore.password = null
  462. connect_1 | ssl.keystore.type = JKS
  463. connect_1 | ssl.protocol = TLS
  464. connect_1 | ssl.provider = null
  465. connect_1 | ssl.secure.random.implementation = null
  466. connect_1 | ssl.trustmanager.algorithm = PKIX
  467. connect_1 | ssl.truststore.location = null
  468. connect_1 | ssl.truststore.password = null
  469. connect_1 | ssl.truststore.type = JKS
  470. connect_1 | transaction.timeout.ms = 60000
  471. connect_1 | transactional.id = null
  472. connect_1 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  473. connect_1 | [org.apache.kafka.clients.producer.ProducerConfig]
  474. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  475. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  476. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  477. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  478. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  479. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  480. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  481. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  482. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  483. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  484. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  485. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  486. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  487. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  488. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  489. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  490. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  491. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  492. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  493. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  494. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  495. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  496. connect_1 | 2017-12-20 09:01:14,548 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  497. connect_1 | 2017-12-20 09:01:14,549 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  498. connect_1 | 2017-12-20 09:01:14,549 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  499. connect_1 | 2017-12-20 09:01:14,553 INFO || ConsumerConfig values:
  500. connect_1 | auto.commit.interval.ms = 5000
  501. connect_1 | auto.offset.reset = earliest
  502. connect_1 | bootstrap.servers = [kafka:9092]
  503. connect_1 | check.crcs = true
  504. connect_1 | client.id =
  505. connect_1 | connections.max.idle.ms = 540000
  506. connect_1 | enable.auto.commit = false
  507. connect_1 | exclude.internal.topics = true
  508. connect_1 | fetch.max.bytes = 52428800
  509. connect_1 | fetch.max.wait.ms = 500
  510. connect_1 | fetch.min.bytes = 1
  511. connect_1 | group.id = 1
  512. connect_1 | heartbeat.interval.ms = 3000
  513. connect_1 | interceptor.classes = null
  514. connect_1 | internal.leave.group.on.close = true
  515. connect_1 | isolation.level = read_uncommitted
  516. connect_1 | key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  517. connect_1 | max.partition.fetch.bytes = 1048576
  518. connect_1 | max.poll.interval.ms = 300000
  519. connect_1 | max.poll.records = 500
  520. connect_1 | metadata.max.age.ms = 300000
  521. connect_1 | metric.reporters = []
  522. connect_1 | metrics.num.samples = 2
  523. connect_1 | metrics.recording.level = INFO
  524. connect_1 | metrics.sample.window.ms = 30000
  525. connect_1 | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  526. connect_1 | receive.buffer.bytes = 65536
  527. connect_1 | reconnect.backoff.max.ms = 1000
  528. connect_1 | reconnect.backoff.ms = 50
  529. connect_1 | request.timeout.ms = 305000
  530. connect_1 | retry.backoff.ms = 100
  531. connect_1 | sasl.jaas.config = null
  532. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  533. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  534. connect_1 | sasl.kerberos.service.name = null
  535. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  536. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  537. connect_1 | sasl.mechanism = GSSAPI
  538. connect_1 | security.protocol = PLAINTEXT
  539. connect_1 | send.buffer.bytes = 131072
  540. connect_1 | session.timeout.ms = 10000
  541. connect_1 | ssl.cipher.suites = null
  542. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  543. connect_1 | ssl.endpoint.identification.algorithm = null
  544. connect_1 | ssl.key.password = null
  545. connect_1 | ssl.keymanager.algorithm = SunX509
  546. connect_1 | ssl.keystore.location = null
  547. connect_1 | ssl.keystore.password = null
  548. connect_1 | ssl.keystore.type = JKS
  549. connect_1 | ssl.protocol = TLS
  550. connect_1 | ssl.provider = null
  551. connect_1 | ssl.secure.random.implementation = null
  552. connect_1 | ssl.trustmanager.algorithm = PKIX
  553. connect_1 | ssl.truststore.location = null
  554. connect_1 | ssl.truststore.password = null
  555. connect_1 | ssl.truststore.type = JKS
  556. connect_1 | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  557. connect_1 | [org.apache.kafka.clients.consumer.ConsumerConfig]
  558. connect_1 | 2017-12-20 09:01:14,583 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  559. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  560. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  561. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  562. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  563. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  564. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  565. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  566. connect_1 | 2017-12-20 09:01:14,595 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  567. connect_1 | 2017-12-20 09:01:14,596 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  568. connect_1 | 2017-12-20 09:01:14,598 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  569. connect_1 | 2017-12-20 09:01:14,598 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  570. connect_1 | 2017-12-20 09:01:14,598 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  571. connect_1 | 2017-12-20 09:01:14,598 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  572. connect_1 | 2017-12-20 09:01:14,599 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  573. connect_1 | 2017-12-20 09:01:14,599 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  574. connect_1 | 2017-12-20 09:01:14,599 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  575. connect_1 | 2017-12-20 09:01:14,599 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  576. connect_1 | 2017-12-20 09:01:14,600 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  577. connect_1 | 2017-12-20 09:01:14,600 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  578. connect_1 | 2017-12-20 09:01:14,600 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  579. connect_1 | 2017-12-20 09:01:14,600 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  580. connect_1 | 2017-12-20 09:01:14,601 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  581. connect_1 | 2017-12-20 09:01:14,601 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  582. connect_1 | 2017-12-20 09:01:14,677 INFO || Discovered coordinator 172.19.0.4:9092 (id: 2147483646 rack: null) for group 1. [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  583. connect_1 | 2017-12-20 09:01:14,779 INFO || Finished reading KafkaBasedLog for topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog]
  584. connect_1 | 2017-12-20 09:01:14,779 INFO || Started KafkaBasedLog for topic my_connect_offsets [org.apache.kafka.connect.util.KafkaBasedLog]
  585. connect_1 | 2017-12-20 09:01:14,779 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore]
  586. connect_1 | 2017-12-20 09:01:14,780 INFO || Worker started [org.apache.kafka.connect.runtime.Worker]
  587. connect_1 | 2017-12-20 09:01:14,781 INFO || Starting KafkaBasedLog with topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog]
  588. connect_1 | 2017-12-20 09:01:14,782 INFO || AdminClientConfig values:
  589. connect_1 | bootstrap.servers = [kafka:9092]
  590. connect_1 | client.id =
  591. connect_1 | connections.max.idle.ms = 300000
  592. connect_1 | metadata.max.age.ms = 300000
  593. connect_1 | metric.reporters = []
  594. connect_1 | metrics.num.samples = 2
  595. connect_1 | metrics.recording.level = INFO
  596. connect_1 | metrics.sample.window.ms = 30000
  597. connect_1 | receive.buffer.bytes = 65536
  598. connect_1 | reconnect.backoff.max.ms = 1000
  599. connect_1 | reconnect.backoff.ms = 50
  600. connect_1 | request.timeout.ms = 120000
  601. connect_1 | retries = 5
  602. connect_1 | retry.backoff.ms = 100
  603. connect_1 | sasl.jaas.config = null
  604. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  605. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  606. connect_1 | sasl.kerberos.service.name = null
  607. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  608. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  609. connect_1 | sasl.mechanism = GSSAPI
  610. connect_1 | security.protocol = PLAINTEXT
  611. connect_1 | send.buffer.bytes = 131072
  612. connect_1 | ssl.cipher.suites = null
  613. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  614. connect_1 | ssl.endpoint.identification.algorithm = null
  615. connect_1 | ssl.key.password = null
  616. connect_1 | ssl.keymanager.algorithm = SunX509
  617. connect_1 | ssl.keystore.location = null
  618. connect_1 | ssl.keystore.password = null
  619. connect_1 | ssl.keystore.type = JKS
  620. connect_1 | ssl.protocol = TLS
  621. connect_1 | ssl.provider = null
  622. connect_1 | ssl.secure.random.implementation = null
  623. connect_1 | ssl.trustmanager.algorithm = PKIX
  624. connect_1 | ssl.truststore.location = null
  625. connect_1 | ssl.truststore.password = null
  626. connect_1 | ssl.truststore.type = JKS
  627. connect_1 | [org.apache.kafka.clients.admin.AdminClientConfig]
  628. connect_1 | 2017-12-20 09:01:14,792 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  629. connect_1 | 2017-12-20 09:01:14,793 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  630. connect_1 | 2017-12-20 09:01:14,793 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  631. connect_1 | 2017-12-20 09:01:14,794 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  632. connect_1 | 2017-12-20 09:01:14,794 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  633. connect_1 | 2017-12-20 09:01:14,794 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  634. connect_1 | 2017-12-20 09:01:14,794 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  635. connect_1 | 2017-12-20 09:01:14,794 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  636. connect_1 | 2017-12-20 09:01:14,795 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  637. connect_1 | 2017-12-20 09:01:14,795 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  638. connect_1 | 2017-12-20 09:01:14,795 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  639. connect_1 | 2017-12-20 09:01:14,795 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  640. connect_1 | 2017-12-20 09:01:14,795 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  641. connect_1 | 2017-12-20 09:01:14,796 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  642. connect_1 | 2017-12-20 09:01:14,796 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  643. connect_1 | 2017-12-20 09:01:14,796 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  644. connect_1 | 2017-12-20 09:01:14,797 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  645. connect_1 | 2017-12-20 09:01:14,797 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  646. connect_1 | 2017-12-20 09:01:14,797 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  647. connect_1 | 2017-12-20 09:01:14,798 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  648. connect_1 | 2017-12-20 09:01:14,798 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  649. connect_1 | 2017-12-20 09:01:14,798 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  650. connect_1 | 2017-12-20 09:01:14,798 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  651. connect_1 | 2017-12-20 09:01:14,799 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  652. connect_1 | 2017-12-20 09:01:14,799 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  653. kafka_1 | 2017-12-20 09:01:14,899 - INFO [kafka-request-handler-3:Logging$class@80] - [Admin Manager on Broker 1]: Error processing create topic request for topic connect-status with arguments (numPartitions=5, replicationFactor=1, replicasAssignments={}, configs={cleanup.policy=compact})
  654. kafka_1 | org.apache.kafka.common.errors.TopicExistsException: Topic 'connect-status' already exists.
  655. connect_1 | 2017-12-20 09:01:14,906 INFO || ProducerConfig values:
  656. connect_1 | acks = all
  657. connect_1 | batch.size = 16384
  658. connect_1 | bootstrap.servers = [kafka:9092]
  659. connect_1 | buffer.memory = 33554432
  660. connect_1 | client.id =
  661. connect_1 | compression.type = none
  662. connect_1 | connections.max.idle.ms = 540000
  663. connect_1 | enable.idempotence = false
  664. connect_1 | interceptor.classes = null
  665. connect_1 | key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  666. connect_1 | linger.ms = 0
  667. connect_1 | max.block.ms = 60000
  668. connect_1 | max.in.flight.requests.per.connection = 1
  669. connect_1 | max.request.size = 1048576
  670. connect_1 | metadata.max.age.ms = 300000
  671. connect_1 | metric.reporters = []
  672. connect_1 | metrics.num.samples = 2
  673. connect_1 | metrics.recording.level = INFO
  674. connect_1 | metrics.sample.window.ms = 30000
  675. connect_1 | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  676. connect_1 | receive.buffer.bytes = 32768
  677. connect_1 | reconnect.backoff.max.ms = 1000
  678. connect_1 | reconnect.backoff.ms = 50
  679. connect_1 | request.timeout.ms = 30000
  680. connect_1 | retries = 0
  681. connect_1 | retry.backoff.ms = 100
  682. connect_1 | sasl.jaas.config = null
  683. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  684. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  685. connect_1 | sasl.kerberos.service.name = null
  686. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  687. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  688. connect_1 | sasl.mechanism = GSSAPI
  689. connect_1 | security.protocol = PLAINTEXT
  690. connect_1 | send.buffer.bytes = 131072
  691. connect_1 | ssl.cipher.suites = null
  692. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  693. connect_1 | ssl.endpoint.identification.algorithm = null
  694. connect_1 | ssl.key.password = null
  695. connect_1 | ssl.keymanager.algorithm = SunX509
  696. connect_1 | ssl.keystore.location = null
  697. connect_1 | ssl.keystore.password = null
  698. connect_1 | ssl.keystore.type = JKS
  699. connect_1 | ssl.protocol = TLS
  700. connect_1 | ssl.provider = null
  701. connect_1 | ssl.secure.random.implementation = null
  702. connect_1 | ssl.trustmanager.algorithm = PKIX
  703. connect_1 | ssl.truststore.location = null
  704. connect_1 | ssl.truststore.password = null
  705. connect_1 | ssl.truststore.type = JKS
  706. connect_1 | transaction.timeout.ms = 60000
  707. connect_1 | transactional.id = null
  708. connect_1 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  709. connect_1 | [org.apache.kafka.clients.producer.ProducerConfig]
  710. connect_1 | 2017-12-20 09:01:14,913 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  711. connect_1 | 2017-12-20 09:01:14,914 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  712. connect_1 | 2017-12-20 09:01:14,914 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  713. connect_1 | 2017-12-20 09:01:14,914 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  714. connect_1 | 2017-12-20 09:01:14,915 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  715. connect_1 | 2017-12-20 09:01:14,915 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  716. connect_1 | 2017-12-20 09:01:14,915 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  717. connect_1 | 2017-12-20 09:01:14,915 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  718. connect_1 | 2017-12-20 09:01:14,915 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  719. connect_1 | 2017-12-20 09:01:14,916 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  720. connect_1 | 2017-12-20 09:01:14,916 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  721. connect_1 | 2017-12-20 09:01:14,916 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  722. connect_1 | 2017-12-20 09:01:14,916 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  723. connect_1 | 2017-12-20 09:01:14,917 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  724. connect_1 | 2017-12-20 09:01:14,917 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  725. connect_1 | 2017-12-20 09:01:14,917 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  726. connect_1 | 2017-12-20 09:01:14,917 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  727. connect_1 | 2017-12-20 09:01:14,918 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  728. connect_1 | 2017-12-20 09:01:14,918 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  729. connect_1 | 2017-12-20 09:01:14,918 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  730. connect_1 | 2017-12-20 09:01:14,918 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  731. connect_1 | 2017-12-20 09:01:14,919 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  732. connect_1 | 2017-12-20 09:01:14,919 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  733. connect_1 | 2017-12-20 09:01:14,919 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  734. connect_1 | 2017-12-20 09:01:14,919 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  735. connect_1 | 2017-12-20 09:01:14,920 INFO || ConsumerConfig values:
  736. connect_1 | auto.commit.interval.ms = 5000
  737. connect_1 | auto.offset.reset = earliest
  738. connect_1 | bootstrap.servers = [kafka:9092]
  739. connect_1 | check.crcs = true
  740. connect_1 | client.id =
  741. connect_1 | connections.max.idle.ms = 540000
  742. connect_1 | enable.auto.commit = false
  743. connect_1 | exclude.internal.topics = true
  744. connect_1 | fetch.max.bytes = 52428800
  745. connect_1 | fetch.max.wait.ms = 500
  746. connect_1 | fetch.min.bytes = 1
  747. connect_1 | group.id = 1
  748. connect_1 | heartbeat.interval.ms = 3000
  749. connect_1 | interceptor.classes = null
  750. connect_1 | internal.leave.group.on.close = true
  751. connect_1 | isolation.level = read_uncommitted
  752. connect_1 | key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  753. connect_1 | max.partition.fetch.bytes = 1048576
  754. connect_1 | max.poll.interval.ms = 300000
  755. connect_1 | max.poll.records = 500
  756. connect_1 | metadata.max.age.ms = 300000
  757. connect_1 | metric.reporters = []
  758. connect_1 | metrics.num.samples = 2
  759. connect_1 | metrics.recording.level = INFO
  760. connect_1 | metrics.sample.window.ms = 30000
  761. connect_1 | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  762. connect_1 | receive.buffer.bytes = 65536
  763. connect_1 | reconnect.backoff.max.ms = 1000
  764. connect_1 | reconnect.backoff.ms = 50
  765. connect_1 | request.timeout.ms = 305000
  766. connect_1 | retry.backoff.ms = 100
  767. connect_1 | sasl.jaas.config = null
  768. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  769. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  770. connect_1 | sasl.kerberos.service.name = null
  771. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  772. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  773. connect_1 | sasl.mechanism = GSSAPI
  774. connect_1 | security.protocol = PLAINTEXT
  775. connect_1 | send.buffer.bytes = 131072
  776. connect_1 | session.timeout.ms = 10000
  777. connect_1 | ssl.cipher.suites = null
  778. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  779. connect_1 | ssl.endpoint.identification.algorithm = null
  780. connect_1 | ssl.key.password = null
  781. connect_1 | ssl.keymanager.algorithm = SunX509
  782. connect_1 | ssl.keystore.location = null
  783. connect_1 | ssl.keystore.password = null
  784. connect_1 | ssl.keystore.type = JKS
  785. connect_1 | ssl.protocol = TLS
  786. connect_1 | ssl.provider = null
  787. connect_1 | ssl.secure.random.implementation = null
  788. connect_1 | ssl.trustmanager.algorithm = PKIX
  789. connect_1 | ssl.truststore.location = null
  790. connect_1 | ssl.truststore.password = null
  791. connect_1 | ssl.truststore.type = JKS
  792. connect_1 | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  793. connect_1 | [org.apache.kafka.clients.consumer.ConsumerConfig]
  794. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  795. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  796. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  797. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  798. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  799. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  800. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  801. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  802. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  803. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  804. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  805. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  806. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  807. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  808. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  809. connect_1 | 2017-12-20 09:01:14,924 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  810. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  811. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  812. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  813. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  814. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  815. connect_1 | 2017-12-20 09:01:14,925 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  816. connect_1 | 2017-12-20 09:01:14,925 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  817. connect_1 | 2017-12-20 09:01:14,925 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  818. connect_1 | 2017-12-20 09:01:14,965 INFO || Discovered coordinator 172.19.0.4:9092 (id: 2147483646 rack: null) for group 1. [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  819. connect_1 | 2017-12-20 09:01:15,057 INFO || Finished reading KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog]
  820. connect_1 | 2017-12-20 09:01:15,057 INFO || Started KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog]
  821. connect_1 | 2017-12-20 09:01:15,057 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
  822. connect_1 | 2017-12-20 09:01:15,057 INFO || Starting KafkaBasedLog with topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog]
  823. connect_1 | 2017-12-20 09:01:15,057 INFO || AdminClientConfig values:
  824. connect_1 | bootstrap.servers = [kafka:9092]
  825. connect_1 | client.id =
  826. connect_1 | connections.max.idle.ms = 300000
  827. connect_1 | metadata.max.age.ms = 300000
  828. connect_1 | metric.reporters = []
  829. connect_1 | metrics.num.samples = 2
  830. connect_1 | metrics.recording.level = INFO
  831. connect_1 | metrics.sample.window.ms = 30000
  832. connect_1 | receive.buffer.bytes = 65536
  833. connect_1 | reconnect.backoff.max.ms = 1000
  834. connect_1 | reconnect.backoff.ms = 50
  835. connect_1 | request.timeout.ms = 120000
  836. connect_1 | retries = 5
  837. connect_1 | retry.backoff.ms = 100
  838. connect_1 | sasl.jaas.config = null
  839. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  840. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  841. connect_1 | sasl.kerberos.service.name = null
  842. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  843. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  844. connect_1 | sasl.mechanism = GSSAPI
  845. connect_1 | security.protocol = PLAINTEXT
  846. connect_1 | send.buffer.bytes = 131072
  847. connect_1 | ssl.cipher.suites = null
  848. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  849. connect_1 | ssl.endpoint.identification.algorithm = null
  850. connect_1 | ssl.key.password = null
  851. connect_1 | ssl.keymanager.algorithm = SunX509
  852. connect_1 | ssl.keystore.location = null
  853. connect_1 | ssl.keystore.password = null
  854. connect_1 | ssl.keystore.type = JKS
  855. connect_1 | ssl.protocol = TLS
  856. connect_1 | ssl.provider = null
  857. connect_1 | ssl.secure.random.implementation = null
  858. connect_1 | ssl.trustmanager.algorithm = PKIX
  859. connect_1 | ssl.truststore.location = null
  860. connect_1 | ssl.truststore.password = null
  861. connect_1 | ssl.truststore.type = JKS
  862. connect_1 | [org.apache.kafka.clients.admin.AdminClientConfig]
  863. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  864. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  865. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  866. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  867. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  868. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  869. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  870. connect_1 | 2017-12-20 09:01:15,058 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  871. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  872. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  873. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  874. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  875. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  876. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  877. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  878. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  879. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  880. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  881. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  882. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  883. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  884. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  885. connect_1 | 2017-12-20 09:01:15,059 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig]
  886. connect_1 | 2017-12-20 09:01:15,059 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  887. connect_1 | 2017-12-20 09:01:15,059 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  888. connect_1 | Dec 20, 2017 9:01:15 AM org.glassfish.jersey.internal.Errors logErrors
  889. connect_1 | WARNING: The following warnings have been detected: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
  890. connect_1 | WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
  891. connect_1 | WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
  892. connect_1 | WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
  893. connect_1 |
  894. connect_1 | 2017-12-20 09:01:15,153 INFO || Started o.e.j.s.ServletContextHandler@5df0e5f0{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler]
  895. connect_1 | 2017-12-20 09:01:15,163 INFO || Started ServerConnector@5125f46e{HTTP/1.1}{172.19.0.5:8083} [org.eclipse.jetty.server.ServerConnector]
  896. connect_1 | 2017-12-20 09:01:15,163 INFO || Started @6942ms [org.eclipse.jetty.server.Server]
  897. connect_1 | 2017-12-20 09:01:15,164 INFO || REST server listening at http://172.19.0.5:8083/, advertising URL http://172.19.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer]
  898. connect_1 | 2017-12-20 09:01:15,164 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect]
  899. kafka_1 | 2017-12-20 09:01:15,165 - INFO [kafka-request-handler-3:Logging$class@80] - [Admin Manager on Broker 1]: Error processing create topic request for topic my_connect_configs with arguments (numPartitions=1, replicationFactor=1, replicasAssignments={}, configs={cleanup.policy=compact})
  900. kafka_1 | org.apache.kafka.common.errors.TopicExistsException: Topic 'my_connect_configs' already exists.
  901. connect_1 | 2017-12-20 09:01:15,167 INFO || ProducerConfig values:
  902. connect_1 | acks = all
  903. connect_1 | batch.size = 16384
  904. connect_1 | bootstrap.servers = [kafka:9092]
  905. connect_1 | buffer.memory = 33554432
  906. connect_1 | client.id =
  907. connect_1 | compression.type = none
  908. connect_1 | connections.max.idle.ms = 540000
  909. connect_1 | enable.idempotence = false
  910. connect_1 | interceptor.classes = null
  911. connect_1 | key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  912. connect_1 | linger.ms = 0
  913. connect_1 | max.block.ms = 60000
  914. connect_1 | max.in.flight.requests.per.connection = 1
  915. connect_1 | max.request.size = 1048576
  916. connect_1 | metadata.max.age.ms = 300000
  917. connect_1 | metric.reporters = []
  918. connect_1 | metrics.num.samples = 2
  919. connect_1 | metrics.recording.level = INFO
  920. connect_1 | metrics.sample.window.ms = 30000
  921. connect_1 | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  922. connect_1 | receive.buffer.bytes = 32768
  923. connect_1 | reconnect.backoff.max.ms = 1000
  924. connect_1 | reconnect.backoff.ms = 50
  925. connect_1 | request.timeout.ms = 30000
  926. connect_1 | retries = 2147483647
  927. connect_1 | retry.backoff.ms = 100
  928. connect_1 | sasl.jaas.config = null
  929. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  930. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  931. connect_1 | sasl.kerberos.service.name = null
  932. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  933. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  934. connect_1 | sasl.mechanism = GSSAPI
  935. connect_1 | security.protocol = PLAINTEXT
  936. connect_1 | send.buffer.bytes = 131072
  937. connect_1 | ssl.cipher.suites = null
  938. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  939. connect_1 | ssl.endpoint.identification.algorithm = null
  940. connect_1 | ssl.key.password = null
  941. connect_1 | ssl.keymanager.algorithm = SunX509
  942. connect_1 | ssl.keystore.location = null
  943. connect_1 | ssl.keystore.password = null
  944. connect_1 | ssl.keystore.type = JKS
  945. connect_1 | ssl.protocol = TLS
  946. connect_1 | ssl.provider = null
  947. connect_1 | ssl.secure.random.implementation = null
  948. connect_1 | ssl.trustmanager.algorithm = PKIX
  949. connect_1 | ssl.truststore.location = null
  950. connect_1 | ssl.truststore.password = null
  951. connect_1 | ssl.truststore.type = JKS
  952. connect_1 | transaction.timeout.ms = 60000
  953. connect_1 | transactional.id = null
  954. connect_1 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  955. connect_1 | [org.apache.kafka.clients.producer.ProducerConfig]
  956. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  957. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  958. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  959. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  960. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  961. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  962. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  963. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  964. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  965. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  966. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  967. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  968. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  969. connect_1 | 2017-12-20 09:01:15,175 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  970. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  971. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  972. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  973. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  974. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  975. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  976. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  977. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  978. connect_1 | 2017-12-20 09:01:15,176 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig]
  979. connect_1 | 2017-12-20 09:01:15,176 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  980. connect_1 | 2017-12-20 09:01:15,176 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  981. connect_1 | 2017-12-20 09:01:15,177 INFO || ConsumerConfig values:
  982. connect_1 | auto.commit.interval.ms = 5000
  983. connect_1 | auto.offset.reset = earliest
  984. connect_1 | bootstrap.servers = [kafka:9092]
  985. connect_1 | check.crcs = true
  986. connect_1 | client.id =
  987. connect_1 | connections.max.idle.ms = 540000
  988. connect_1 | enable.auto.commit = false
  989. connect_1 | exclude.internal.topics = true
  990. connect_1 | fetch.max.bytes = 52428800
  991. connect_1 | fetch.max.wait.ms = 500
  992. connect_1 | fetch.min.bytes = 1
  993. connect_1 | group.id = 1
  994. connect_1 | heartbeat.interval.ms = 3000
  995. connect_1 | interceptor.classes = null
  996. connect_1 | internal.leave.group.on.close = true
  997. connect_1 | isolation.level = read_uncommitted
  998. connect_1 | key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  999. connect_1 | max.partition.fetch.bytes = 1048576
  1000. connect_1 | max.poll.interval.ms = 300000
  1001. connect_1 | max.poll.records = 500
  1002. connect_1 | metadata.max.age.ms = 300000
  1003. connect_1 | metric.reporters = []
  1004. connect_1 | metrics.num.samples = 2
  1005. connect_1 | metrics.recording.level = INFO
  1006. connect_1 | metrics.sample.window.ms = 30000
  1007. connect_1 | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  1008. connect_1 | receive.buffer.bytes = 65536
  1009. connect_1 | reconnect.backoff.max.ms = 1000
  1010. connect_1 | reconnect.backoff.ms = 50
  1011. connect_1 | request.timeout.ms = 305000
  1012. connect_1 | retry.backoff.ms = 100
  1013. connect_1 | sasl.jaas.config = null
  1014. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1015. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  1016. connect_1 | sasl.kerberos.service.name = null
  1017. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  1018. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  1019. connect_1 | sasl.mechanism = GSSAPI
  1020. connect_1 | security.protocol = PLAINTEXT
  1021. connect_1 | send.buffer.bytes = 131072
  1022. connect_1 | session.timeout.ms = 10000
  1023. connect_1 | ssl.cipher.suites = null
  1024. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1025. connect_1 | ssl.endpoint.identification.algorithm = null
  1026. connect_1 | ssl.key.password = null
  1027. connect_1 | ssl.keymanager.algorithm = SunX509
  1028. connect_1 | ssl.keystore.location = null
  1029. connect_1 | ssl.keystore.password = null
  1030. connect_1 | ssl.keystore.type = JKS
  1031. connect_1 | ssl.protocol = TLS
  1032. connect_1 | ssl.provider = null
  1033. connect_1 | ssl.secure.random.implementation = null
  1034. connect_1 | ssl.trustmanager.algorithm = PKIX
  1035. connect_1 | ssl.truststore.location = null
  1036. connect_1 | ssl.truststore.password = null
  1037. connect_1 | ssl.truststore.type = JKS
  1038. connect_1 | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  1039. connect_1 | [org.apache.kafka.clients.consumer.ConsumerConfig]
  1040. connect_1 | 2017-12-20 09:01:15,180 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1041. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1042. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1043. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1044. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1045. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1046. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1047. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1048. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1049. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1050. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1051. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1052. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1053. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1054. connect_1 | 2017-12-20 09:01:15,181 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1055. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1056. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'internal.key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1057. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1058. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1059. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1060. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'internal.value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1061. connect_1 | 2017-12-20 09:01:15,182 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig]
  1062. connect_1 | 2017-12-20 09:01:15,182 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  1063. connect_1 | 2017-12-20 09:01:15,183 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  1064. connect_1 | 2017-12-20 09:01:15,201 INFO || Discovered coordinator 172.19.0.4:9092 (id: 2147483646 rack: null) for group 1. [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1065. connect_1 | 2017-12-20 09:01:15,212 INFO || Removed connector customer-connector due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
  1066. connect_1 | 2017-12-20 09:01:15,213 INFO || Removed connector customer-connector due to null configuration. This is usually intentional and does not indicate an issue. [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
  1067. connect_1 | 2017-12-20 09:01:15,218 INFO || Finished reading KafkaBasedLog for topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog]
  1068. connect_1 | 2017-12-20 09:01:15,218 INFO || Started KafkaBasedLog for topic my_connect_configs [org.apache.kafka.connect.util.KafkaBasedLog]
  1069. connect_1 | 2017-12-20 09:01:15,218 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore]
  1070. connect_1 | 2017-12-20 09:01:15,218 INFO || Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1071. connect_1 | 2017-12-20 09:01:15,223 INFO || Discovered coordinator 172.19.0.4:9092 (id: 2147483646 rack: null) for group 1. [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1072. connect_1 | 2017-12-20 09:01:15,227 INFO || (Re-)joining group 1 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1073. kafka_1 | 2017-12-20 09:01:15,238 - INFO [kafka-request-handler-0:Logging$class@72] - [GroupCoordinator 1]: Preparing to rebalance group 1 with old generation 39 (__consumer_offsets-49)
  1074. kafka_1 | 2017-12-20 09:01:15,244 - INFO [executor-Rebalance:Logging$class@72] - [GroupCoordinator 1]: Stabilized group 1 generation 40 (__consumer_offsets-49)
  1075. kafka_1 | 2017-12-20 09:01:15,255 - INFO [kafka-request-handler-1:Logging$class@72] - [GroupCoordinator 1]: Assignment received from leader for group 1 for generation 40
  1076. kafka_1 | 2017-12-20 09:01:15,269 - INFO [kafka-request-handler-1:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:15, offset:39}, Current: {epoch:14, offset37} for Partition: __consumer_offsets-49. Cache now contains 15 entries.
  1077. connect_1 | 2017-12-20 09:01:15,297 INFO || Successfully joined group 1 with generation 40 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1078. connect_1 | 2017-12-20 09:01:15,297 INFO || Joined group and got assignment: Assignment{error=0, leader='connect-1-abac49d6-6e86-49c0-959a-9843d67bf716', leaderUrl='http://172.19.0.5:8083/', offset=16, connectorIds=[jdbc-sink, customer-connector], taskIds=[jdbc-sink-0, customer-connector-0]} [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1079. connect_1 | 2017-12-20 09:01:15,298 WARN || Catching up to assignment's config offset. [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1080. connect_1 | 2017-12-20 09:01:15,298 INFO || Current config state offset -1 is behind group assignment 16, reading to end of config log [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1081. connect_1 | 2017-12-20 09:01:15,711 INFO || Finished reading to end of log and updated config snapshot, new config log offset: 16 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1082. connect_1 | 2017-12-20 09:01:15,712 INFO || Starting connectors and tasks using config offset 16 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1083. connect_1 | 2017-12-20 09:01:15,713 INFO || Starting connector jdbc-sink [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1084. connect_1 | 2017-12-20 09:01:15,713 INFO || Starting task jdbc-sink-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1085. connect_1 | 2017-12-20 09:01:15,714 INFO || Creating task jdbc-sink-0 [org.apache.kafka.connect.runtime.Worker]
  1086. connect_1 | 2017-12-20 09:01:15,713 INFO || Starting connector customer-connector [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1087. connect_1 | 2017-12-20 09:01:15,715 INFO || Starting task customer-connector-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1088. connect_1 | 2017-12-20 09:01:15,715 INFO || Creating task customer-connector-0 [org.apache.kafka.connect.runtime.Worker]
  1089. connect_1 | 2017-12-20 09:01:15,715 INFO || ConnectorConfig values:
  1090. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1091. connect_1 | key.converter = null
  1092. connect_1 | name = jdbc-sink
  1093. connect_1 | tasks.max = 1
  1094. connect_1 | transforms = [unwrap]
  1095. connect_1 | value.converter = null
  1096. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig]
  1097. connect_1 | 2017-12-20 09:01:15,715 INFO || ConnectorConfig values:
  1098. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1099. connect_1 | key.converter = null
  1100. connect_1 | name = customer-connector
  1101. connect_1 | tasks.max = 1
  1102. connect_1 | transforms = [route]
  1103. connect_1 | value.converter = null
  1104. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig]
  1105. connect_1 | 2017-12-20 09:01:15,715 INFO || ConnectorConfig values:
  1106. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1107. connect_1 | key.converter = null
  1108. connect_1 | name = jdbc-sink
  1109. connect_1 | tasks.max = 1
  1110. connect_1 | transforms = [unwrap]
  1111. connect_1 | value.converter = null
  1112. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig]
  1113. connect_1 | 2017-12-20 09:01:15,716 INFO || ConnectorConfig values:
  1114. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1115. connect_1 | key.converter = null
  1116. connect_1 | name = customer-connector
  1117. connect_1 | tasks.max = 1
  1118. connect_1 | transforms = [route]
  1119. connect_1 | value.converter = null
  1120. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig]
  1121. connect_1 | 2017-12-20 09:01:15,719 INFO || EnrichedConnectorConfig values:
  1122. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1123. connect_1 | key.converter = null
  1124. connect_1 | name = customer-connector
  1125. connect_1 | tasks.max = 1
  1126. connect_1 | transforms = [route]
  1127. connect_1 | transforms.route.regex = ([^.]+)\.([^.]+)\.([^.]+)
  1128. connect_1 | transforms.route.replacement = $3
  1129. connect_1 | transforms.route.type = class org.apache.kafka.connect.transforms.RegexRouter
  1130. connect_1 | value.converter = null
  1131. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1132. connect_1 | 2017-12-20 09:01:15,719 INFO || Creating connector customer-connector of type io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker]
  1133. connect_1 | 2017-12-20 09:01:15,719 INFO || EnrichedConnectorConfig values:
  1134. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1135. connect_1 | key.converter = null
  1136. connect_1 | name = customer-connector
  1137. connect_1 | tasks.max = 1
  1138. connect_1 | transforms = [route]
  1139. connect_1 | transforms.route.regex = ([^.]+)\.([^.]+)\.([^.]+)
  1140. connect_1 | transforms.route.replacement = $3
  1141. connect_1 | transforms.route.type = class org.apache.kafka.connect.transforms.RegexRouter
  1142. connect_1 | value.converter = null
  1143. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1144. connect_1 | 2017-12-20 09:01:15,721 INFO || Instantiated connector customer-connector with version 0.6.2 of type class io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker]
  1145. connect_1 | 2017-12-20 09:01:15,732 INFO || TaskConfig values:
  1146. connect_1 | task.class = class io.debezium.connector.postgresql.PostgresConnectorTask
  1147. connect_1 | [org.apache.kafka.connect.runtime.TaskConfig]
  1148. connect_1 | 2017-12-20 09:01:15,732 INFO || Instantiated task customer-connector-0 with version 0.6.2 of type io.debezium.connector.postgresql.PostgresConnectorTask [org.apache.kafka.connect.runtime.Worker]
  1149. connect_1 | 2017-12-20 09:01:15,735 INFO || ProducerConfig values:
  1150. connect_1 | acks = all
  1151. connect_1 | batch.size = 16384
  1152. connect_1 | bootstrap.servers = [kafka:9092]
  1153. connect_1 | buffer.memory = 33554432
  1154. connect_1 | client.id =
  1155. connect_1 | compression.type = none
  1156. connect_1 | connections.max.idle.ms = 540000
  1157. connect_1 | enable.idempotence = false
  1158. connect_1 | interceptor.classes = null
  1159. connect_1 | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1160. connect_1 | linger.ms = 0
  1161. connect_1 | max.block.ms = 9223372036854775807
  1162. connect_1 | max.in.flight.requests.per.connection = 1
  1163. connect_1 | max.request.size = 1048576
  1164. connect_1 | metadata.max.age.ms = 300000
  1165. connect_1 | metric.reporters = []
  1166. connect_1 | metrics.num.samples = 2
  1167. connect_1 | metrics.recording.level = INFO
  1168. connect_1 | metrics.sample.window.ms = 30000
  1169. connect_1 | partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  1170. connect_1 | receive.buffer.bytes = 32768
  1171. connect_1 | reconnect.backoff.max.ms = 1000
  1172. connect_1 | reconnect.backoff.ms = 50
  1173. connect_1 | request.timeout.ms = 2147483647
  1174. connect_1 | retries = 2147483647
  1175. connect_1 | retry.backoff.ms = 100
  1176. connect_1 | sasl.jaas.config = null
  1177. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1178. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  1179. connect_1 | sasl.kerberos.service.name = null
  1180. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  1181. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  1182. connect_1 | sasl.mechanism = GSSAPI
  1183. connect_1 | security.protocol = PLAINTEXT
  1184. connect_1 | send.buffer.bytes = 131072
  1185. connect_1 | ssl.cipher.suites = null
  1186. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1187. connect_1 | ssl.endpoint.identification.algorithm = null
  1188. connect_1 | ssl.key.password = null
  1189. connect_1 | ssl.keymanager.algorithm = SunX509
  1190. connect_1 | ssl.keystore.location = null
  1191. connect_1 | ssl.keystore.password = null
  1192. connect_1 | ssl.keystore.type = JKS
  1193. connect_1 | ssl.protocol = TLS
  1194. connect_1 | ssl.provider = null
  1195. connect_1 | ssl.secure.random.implementation = null
  1196. connect_1 | ssl.trustmanager.algorithm = PKIX
  1197. connect_1 | ssl.truststore.location = null
  1198. connect_1 | ssl.truststore.password = null
  1199. connect_1 | ssl.truststore.type = JKS
  1200. connect_1 | transaction.timeout.ms = 60000
  1201. connect_1 | transactional.id = null
  1202. connect_1 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1203. connect_1 | [org.apache.kafka.clients.producer.ProducerConfig]
  1204. connect_1 | 2017-12-20 09:01:15,744 INFO || Finished creating connector customer-connector [org.apache.kafka.connect.runtime.Worker]
  1205. connect_1 | 2017-12-20 09:01:15,749 INFO || SourceConnectorConfig values:
  1206. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1207. connect_1 | key.converter = null
  1208. kafka_1 | 2017-12-20 09:01:15,749 - INFO [kafka-request-handler-3:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:15, offset:114}, Current: {epoch:14, offset108} for Partition: connect-status-3. Cache now contains 12 entries.
  1209. connect_1 | name = customer-connector
  1210. connect_1 | tasks.max = 1
  1211. connect_1 | transforms = [route]
  1212. connect_1 | value.converter = null
  1213. connect_1 | [org.apache.kafka.connect.runtime.SourceConnectorConfig]
  1214. connect_1 | 2017-12-20 09:01:15,750 INFO || EnrichedConnectorConfig values:
  1215. connect_1 | connector.class = io.debezium.connector.postgresql.PostgresConnector
  1216. connect_1 | key.converter = null
  1217. connect_1 | name = customer-connector
  1218. connect_1 | tasks.max = 1
  1219. connect_1 | transforms = [route]
  1220. connect_1 | transforms.route.regex = ([^.]+)\.([^.]+)\.([^.]+)
  1221. connect_1 | transforms.route.replacement = $3
  1222. connect_1 | transforms.route.type = class org.apache.kafka.connect.transforms.RegexRouter
  1223. connect_1 | value.converter = null
  1224. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1225. connect_1 | 2017-12-20 09:01:15,762 INFO || EnrichedConnectorConfig values:
  1226. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1227. connect_1 | key.converter = null
  1228. connect_1 | name = jdbc-sink
  1229. connect_1 | tasks.max = 1
  1230. connect_1 | transforms = [unwrap]
  1231. connect_1 | transforms.unwrap.drop.deletes = true
  1232. connect_1 | transforms.unwrap.drop.tombstones = true
  1233. connect_1 | transforms.unwrap.type = class io.debezium.transforms.UnwrapFromEnvelope
  1234. connect_1 | value.converter = null
  1235. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1236. connect_1 | 2017-12-20 09:01:15,763 INFO || EnrichedConnectorConfig values:
  1237. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1238. connect_1 | key.converter = null
  1239. connect_1 | name = jdbc-sink
  1240. connect_1 | tasks.max = 1
  1241. connect_1 | transforms = [unwrap]
  1242. connect_1 | transforms.unwrap.drop.deletes = true
  1243. connect_1 | transforms.unwrap.drop.tombstones = true
  1244. connect_1 | transforms.unwrap.type = class io.debezium.transforms.UnwrapFromEnvelope
  1245. connect_1 | value.converter = null
  1246. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1247. connect_1 | 2017-12-20 09:01:15,763 INFO || Creating connector jdbc-sink of type io.confluent.connect.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker]
  1248. connect_1 | 2017-12-20 09:01:15,764 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  1249. connect_1 | 2017-12-20 09:01:15,764 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  1250. connect_1 | 2017-12-20 09:01:15,765 INFO || TaskConfig values:
  1251. connect_1 | task.class = class io.confluent.connect.jdbc.sink.JdbcSinkTask
  1252. connect_1 | [org.apache.kafka.connect.runtime.TaskConfig]
  1253. connect_1 | 2017-12-20 09:01:15,765 INFO || Instantiated task jdbc-sink-0 with version null of type io.confluent.connect.jdbc.sink.JdbcSinkTask [org.apache.kafka.connect.runtime.Worker]
  1254. connect_1 | 2017-12-20 09:01:15,766 INFO || Instantiated connector jdbc-sink with version 3.3.0 of type class io.confluent.connect.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker]
  1255. connect_1 | 2017-12-20 09:01:15,768 INFO || Finished creating connector jdbc-sink [org.apache.kafka.connect.runtime.Worker]
  1256. connect_1 | 2017-12-20 09:01:15,771 INFO || SinkConnectorConfig values:
  1257. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1258. connect_1 | key.converter = null
  1259. connect_1 | name = jdbc-sink
  1260. connect_1 | tasks.max = 1
  1261. connect_1 | topics = [customers]
  1262. connect_1 | transforms = [unwrap]
  1263. connect_1 | value.converter = null
  1264. connect_1 | [org.apache.kafka.connect.runtime.SinkConnectorConfig]
  1265. connect_1 | 2017-12-20 09:01:15,772 INFO || EnrichedConnectorConfig values:
  1266. connect_1 | connector.class = io.confluent.connect.jdbc.JdbcSinkConnector
  1267. connect_1 | key.converter = null
  1268. connect_1 | name = jdbc-sink
  1269. connect_1 | tasks.max = 1
  1270. connect_1 | topics = [customers]
  1271. connect_1 | transforms = [unwrap]
  1272. connect_1 | transforms.unwrap.drop.deletes = true
  1273. connect_1 | transforms.unwrap.drop.tombstones = true
  1274. connect_1 | transforms.unwrap.type = class io.debezium.transforms.UnwrapFromEnvelope
  1275. connect_1 | value.converter = null
  1276. connect_1 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig]
  1277. connect_1 | 2017-12-20 09:01:15,773 INFO || Setting task configurations for 1 workers. [io.confluent.connect.jdbc.JdbcSinkConnector]
  1278. connect_1 | 2017-12-20 09:01:15,799 INFO || ConsumerConfig values:
  1279. connect_1 | auto.commit.interval.ms = 5000
  1280. connect_1 | auto.offset.reset = earliest
  1281. connect_1 | bootstrap.servers = [kafka:9092]
  1282. connect_1 | check.crcs = true
  1283. connect_1 | client.id =
  1284. connect_1 | connections.max.idle.ms = 540000
  1285. connect_1 | enable.auto.commit = false
  1286. connect_1 | exclude.internal.topics = true
  1287. connect_1 | fetch.max.bytes = 52428800
  1288. connect_1 | fetch.max.wait.ms = 500
  1289. connect_1 | fetch.min.bytes = 1
  1290. connect_1 | group.id = connect-jdbc-sink
  1291. connect_1 | heartbeat.interval.ms = 3000
  1292. connect_1 | interceptor.classes = null
  1293. connect_1 | internal.leave.group.on.close = true
  1294. connect_1 | isolation.level = read_uncommitted
  1295. connect_1 | key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  1296. connect_1 | max.partition.fetch.bytes = 1048576
  1297. connect_1 | max.poll.interval.ms = 300000
  1298. connect_1 | max.poll.records = 500
  1299. connect_1 | metadata.max.age.ms = 300000
  1300. connect_1 | metric.reporters = []
  1301. connect_1 | metrics.num.samples = 2
  1302. connect_1 | metrics.recording.level = INFO
  1303. connect_1 | metrics.sample.window.ms = 30000
  1304. connect_1 | partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  1305. connect_1 | receive.buffer.bytes = 65536
  1306. connect_1 | reconnect.backoff.max.ms = 1000
  1307. connect_1 | reconnect.backoff.ms = 50
  1308. connect_1 | request.timeout.ms = 305000
  1309. connect_1 | retry.backoff.ms = 100
  1310. connect_1 | sasl.jaas.config = null
  1311. connect_1 | sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1312. connect_1 | sasl.kerberos.min.time.before.relogin = 60000
  1313. connect_1 | sasl.kerberos.service.name = null
  1314. connect_1 | sasl.kerberos.ticket.renew.jitter = 0.05
  1315. connect_1 | sasl.kerberos.ticket.renew.window.factor = 0.8
  1316. connect_1 | sasl.mechanism = GSSAPI
  1317. connect_1 | security.protocol = PLAINTEXT
  1318. connect_1 | send.buffer.bytes = 131072
  1319. connect_1 | session.timeout.ms = 10000
  1320. connect_1 | ssl.cipher.suites = null
  1321. connect_1 | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1322. connect_1 | ssl.endpoint.identification.algorithm = null
  1323. connect_1 | ssl.key.password = null
  1324. connect_1 | ssl.keymanager.algorithm = SunX509
  1325. connect_1 | ssl.keystore.location = null
  1326. connect_1 | ssl.keystore.password = null
  1327. connect_1 | ssl.keystore.type = JKS
  1328. connect_1 | ssl.protocol = TLS
  1329. connect_1 | ssl.provider = null
  1330. connect_1 | ssl.secure.random.implementation = null
  1331. connect_1 | ssl.trustmanager.algorithm = PKIX
  1332. connect_1 | ssl.truststore.location = null
  1333. connect_1 | ssl.truststore.password = null
  1334. connect_1 | ssl.truststore.type = JKS
  1335. connect_1 | value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  1336. connect_1 | [org.apache.kafka.clients.consumer.ConsumerConfig]
  1337. connect_1 | 2017-12-20 09:01:15,813 INFO || Kafka version : 0.11.0.1 [org.apache.kafka.common.utils.AppInfoParser]
  1338. connect_1 | 2017-12-20 09:01:15,813 INFO || Kafka commitId : c2a0d5f9b1f45bf5 [org.apache.kafka.common.utils.AppInfoParser]
  1339. connect_1 | 2017-12-20 09:01:15,824 INFO || Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder]
  1340. connect_1 | 2017-12-20 09:01:15,825 INFO || Starting task [io.confluent.connect.jdbc.sink.JdbcSinkTask]
  1341. kafka_1 | 2017-12-20 09:01:15,825 - INFO [kafka-request-handler-7:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:15, offset:35}, Current: {epoch:14, offset33} for Partition: connect-status-2. Cache now contains 12 entries.
  1342. connect_1 | 2017-12-20 09:01:15,844 INFO || JdbcSinkConfig values:
  1343. connect_1 | auto.create = true
  1344. connect_1 | auto.evolve = false
  1345. connect_1 | batch.size = 3000
  1346. connect_1 | connection.password = null
  1347. connect_1 | connection.url = jdbc:postgresql://postgres:5432/inventory?user=postgresuser&password=postgrespw
  1348. connect_1 | connection.user = null
  1349. connect_1 | fields.whitelist = []
  1350. connect_1 | insert.mode = upsert
  1351. connect_1 | max.retries = 10
  1352. connect_1 | pk.fields = [id]
  1353. connect_1 | pk.mode = record_value
  1354. connect_1 | retry.backoff.ms = 3000
  1355. connect_1 | table.name.format = ${topic}
  1356. connect_1 | [io.confluent.connect.jdbc.sink.JdbcSinkConfig]
  1357. connect_1 | 2017-12-20 09:01:15,856 INFO || Initializing writer using SQL dialect: PostgreSqlDialect [io.confluent.connect.jdbc.sink.JdbcSinkTask]
  1358. connect_1 | 2017-12-20 09:01:15,861 INFO || Sink task WorkerSinkTask{id=jdbc-sink-0} finished initialization and start [org.apache.kafka.connect.runtime.WorkerSinkTask]
  1359. connect_1 | 2017-12-20 09:01:15,875 INFO || Discovered coordinator 172.19.0.4:9092 (id: 2147483646 rack: null) for group connect-jdbc-sink. [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1360. connect_1 | 2017-12-20 09:01:15,889 INFO || Revoking previously assigned partitions [] for group connect-jdbc-sink [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
  1361. connect_1 | 2017-12-20 09:01:15,889 INFO || (Re-)joining group connect-jdbc-sink [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1362. kafka_1 | 2017-12-20 09:01:15,892 - INFO [kafka-request-handler-5:Logging$class@72] - [GroupCoordinator 1]: Preparing to rebalance group connect-jdbc-sink with old generation 36 (__consumer_offsets-16)
  1363. kafka_1 | 2017-12-20 09:01:15,893 - INFO [executor-Rebalance:Logging$class@72] - [GroupCoordinator 1]: Stabilized group connect-jdbc-sink generation 37 (__consumer_offsets-16)
  1364. kafka_1 | 2017-12-20 09:01:15,894 - INFO [kafka-request-handler-2:Logging$class@72] - [GroupCoordinator 1]: Assignment received from leader for group connect-jdbc-sink for generation 37
  1365. kafka_1 | 2017-12-20 09:01:15,895 - INFO [kafka-request-handler-2:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:15, offset:41}, Current: {epoch:14, offset39} for Partition: __consumer_offsets-16. Cache now contains 12 entries.
  1366. connect_1 | 2017-12-20 09:01:15,900 INFO || Successfully joined group connect-jdbc-sink with generation 37 [org.apache.kafka.clients.consumer.internals.AbstractCoordinator]
  1367. connect_1 | 2017-12-20 09:01:15,900 INFO || Setting newly assigned partitions [customers-0] for group connect-jdbc-sink [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator]
  1368. connect_1 | 2017-12-20 09:01:16,000 INFO || Checking table:customers exists for product:PostgreSQL schema:public catalog: [io.confluent.connect.jdbc.sink.DbMetadataQueries]
  1369. connect_1 | 2017-12-20 09:01:16,005 INFO || product:PostgreSQL schema:public catalog:inventory -- table:customers is present [io.confluent.connect.jdbc.sink.DbMetadataQueries]
  1370. connect_1 | 2017-12-20 09:01:16,005 INFO || Querying column metadata for product:PostgreSQL schema:public catalog:inventory table:customers [io.confluent.connect.jdbc.sink.DbMetadataQueries]
  1371. connect_1 | 2017-12-20 09:01:16,415 INFO Postgres|dbserver1|postgres-connector-task user 'moneradbuser' connected to database 'moneradb' on PostgreSQL 9.6.3 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.3 20140911 (Red Hat 4.8.3-9), 64-bit with roles:
  1372. connect_1 | role 'rds_replication' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
  1373. connect_1 | role 'rds_superuser' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
  1374. connect_1 | role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
  1375. connect_1 | role 'moneradbuser' [superuser: false, replication: false, inherit: true, create role: true, create db: true, can log in: true] [io.debezium.connector.postgresql.PostgresConnectorTask]
  1376. connect_1 | 2017-12-20 09:01:16,417 INFO Postgres|dbserver1|postgres-connector-task Found previous offset source_info[server='dbserver1', lsn=1/AC000458, txId=2323, useconds=1513760428454000, snapshot=false] [io.debezium.connector.postgresql.PostgresConnectorTask]
  1377. connect_1 | 2017-12-20 09:01:16,417 INFO Postgres|dbserver1|postgres-connector-task Taking a new snapshot as per configuration [io.debezium.connector.postgresql.PostgresConnectorTask]
  1378. connect_1 | 2017-12-20 09:01:16,454 INFO || Source task WorkerSourceTask{id=customer-connector-0} finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask]
  1379. connect_1 | 2017-12-20 09:01:16,456 INFO Postgres|dbserver1|records-snapshot-producer Step 0: disabling autocommit [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1380. connect_1 | 2017-12-20 09:01:16,457 INFO Postgres|dbserver1|records-snapshot-producer Step 1: starting transaction and refreshing the DB schemas for database 'moneradb' and user 'moneradbuser' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1381. connect_1 | 2017-12-20 09:01:16,911 INFO Postgres|dbserver1|records-snapshot-producer Step 2: locking each of the database tables, waiting a maximum of '10.0' seconds for each lock [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1382. connect_1 | 2017-12-20 09:01:16,966 INFO Postgres|dbserver1|records-snapshot-producer read xlogStart at '1/AC000660' from transaction '2324' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1383. connect_1 | 2017-12-20 09:01:16,966 INFO Postgres|dbserver1|records-snapshot-producer Step 3: reading and exporting the contents of each table [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1384. connect_1 | 2017-12-20 09:01:16,967 INFO Postgres|dbserver1|records-snapshot-producer exporting data from table 'public.customers' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1385. connect_1 | 2017-12-20 09:01:16,983 INFO Postgres|dbserver1|records-snapshot-producer finished exporting '5' records for 'public.customers'; total duration '00:00:00.015' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1386. connect_1 | 2017-12-20 09:01:16,983 INFO Postgres|dbserver1|records-snapshot-producer Step 4: committing transaction '2324' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1387. connect_1 | 2017-12-20 09:01:16,984 INFO Postgres|dbserver1|records-snapshot-producer Step 5: sending the last snapshot record [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1388. connect_1 | 2017-12-20 09:01:16,985 INFO Postgres|dbserver1|records-snapshot-producer Snapshot completed in '00:00:00.534' [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1389. connect_1 | 2017-12-20 09:01:16,986 INFO Postgres|dbserver1|records-snapshot-producer Snapshot finished, continuing streaming changes from 1/AC000660 [io.debezium.connector.postgresql.RecordsSnapshotProducer]
  1390. connect_1 | 2017-12-20 09:01:17,070 INFO Postgres|dbserver1|records-stream-producer REPLICA IDENTITY for 'public.customers' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns [io.debezium.connector.postgresql.PostgresSchema]
  1391. kafka_1 | 2017-12-20 09:01:17,456 - INFO [kafka-request-handler-0:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:12, offset:51}, Current: {epoch:11, offset46} for Partition: customers-0. Cache now contains 7 entries.
  1392. kafka_1 | 2017-12-20 09:02:15,781 - INFO [kafka-request-handler-5:Logging$class@72] - Updated PartitionLeaderEpoch. New: {epoch:15, offset:9}, Current: {epoch:14, offset8} for Partition: my_connect_offsets-20. Cache now contains 7 entries.
  1393. connect_1 | 2017-12-20 09:02:15,786 INFO || Finished WorkerSourceTask{id=customer-connector-0} commitOffsets successfully in 12 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
  1394. connect_1 | 2017-12-20 09:02:15,799 INFO || WorkerSinkTask{id=jdbc-sink-0} Committing offsets asynchronously using sequence number 1: {customers-0=OffsetAndMetadata{offset=56, metadata=''}} [org.apache.kafka.connect.runtime.WorkerSinkTask]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!