API tools faq
paste
Advertisement
mskylsjwg

Untitled

mskylsjwg
Oct 11th, 2017
160
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 129.86 KB | None | 0 0
raw download clone embed print report
  1. [2017-10-11 14:16:55,861] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql/debezium-core-0.6.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  2. [2017-10-11 14:16:55,996] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/debezium-core-0.6.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  3. [2017-10-11 14:16:55,997] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  4. [2017-10-11 14:16:55,997] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  5. [2017-10-11 14:16:55,997] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql/mysql-binlog-connector-java-0.9.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  6. [2017-10-11 14:16:56,010] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/mysql-binlog-connector-java-0.9.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  7. [2017-10-11 14:16:56,010] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql/wkb-1.0.2.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  8. [2017-10-11 14:16:56,013] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/wkb-1.0.2.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  9. [2017-10-11 14:16:56,013] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql/mysql-connector-java-5.1.40.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  10. [2017-10-11 14:16:56,081] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/mysql-connector-java-5.1.40.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  11. [2017-10-11 14:16:56,081] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql/debezium-connector-mysql-0.6.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  12. [2017-10-11 14:16:56,127] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/debezium-connector-mysql-0.6.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  13. [2017-10-11 14:16:56,127] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  14. [2017-10-11 14:16:56,127] INFO Loading plugin from: /usr/local/share/kafka/plugins/debezium-connector-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:176)
  15. [2017-10-11 14:16:56,224] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/share/kafka/plugins/debezium-connector-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  16. [2017-10-11 14:16:58,397] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:199)
  17. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  18. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  19. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  20. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  21. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  22. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  23. [2017-10-11 14:16:58,398] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  24. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  25. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  26. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  27. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  28. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  29. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  30. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  31. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  32. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  33. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  34. [2017-10-11 14:16:58,399] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  35. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  36. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  37. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  38. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  39. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  40. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  41. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  42. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  43. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  44. [2017-10-11 14:16:58,400] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  45. [2017-10-11 14:16:58,401] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  46. [2017-10-11 14:16:58,401] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  47. [2017-10-11 14:16:58,401] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  48. [2017-10-11 14:16:58,401] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:132)
  49. [2017-10-11 14:16:58,401] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  50. [2017-10-11 14:16:58,402] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  51. [2017-10-11 14:16:58,402] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  52. [2017-10-11 14:16:58,402] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  53. [2017-10-11 14:16:58,402] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  54. [2017-10-11 14:16:58,403] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  55. [2017-10-11 14:16:58,403] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  56. [2017-10-11 14:16:58,403] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  57. [2017-10-11 14:16:58,403] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  58. [2017-10-11 14:16:58,403] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  59. [2017-10-11 14:16:58,403] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  60. [2017-10-11 14:16:58,403] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:293)
  61. [2017-10-11 14:16:58,404] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
  62. [2017-10-11 14:16:58,404] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
  63. [2017-10-11 14:16:58,405] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
  64. [2017-10-11 14:16:58,405] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
  65. [2017-10-11 14:16:58,405] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:290)
  66. [2017-10-11 14:16:58,418] INFO DistributedConfig values:
  67. access.control.allow.methods =
  68. access.control.allow.origin =
  69. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  70. client.id =
  71. config.storage.replication.factor = 3
  72. config.storage.topic = connect-configs
  73. connections.max.idle.ms = 540000
  74. group.id = connect-cluster
  75. heartbeat.interval.ms = 3000
  76. internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
  77. internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
  78. key.converter = class org.apache.kafka.connect.json.JsonConverter
  79. metadata.max.age.ms = 300000
  80. metric.reporters = []
  81. metrics.num.samples = 2
  82. metrics.sample.window.ms = 30000
  83. offset.flush.interval.ms = 10000
  84. offset.flush.timeout.ms = 5000
  85. offset.storage.partitions = 25
  86. offset.storage.replication.factor = 3
  87. offset.storage.topic = connect-offsets
  88. plugin.path = [/usr/local/share/kafka/plugins/debezium-connector-mysql, /usr/local/share/kafka/plugins]
  89. rebalance.timeout.ms = 60000
  90. receive.buffer.bytes = 32768
  91. reconnect.backoff.max.ms = 1000
  92. reconnect.backoff.ms = 50
  93. request.timeout.ms = 40000
  94. rest.advertised.host.name = null
  95. rest.advertised.port = null
  96. rest.host.name = null
  97. rest.port = 8086
  98. retry.backoff.ms = 100
  99. sasl.jaas.config = null
  100. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  101. sasl.kerberos.min.time.before.relogin = 60000
  102. sasl.kerberos.service.name = null
  103. sasl.kerberos.ticket.renew.jitter = 0.05
  104. sasl.kerberos.ticket.renew.window.factor = 0.8
  105. sasl.mechanism = GSSAPI
  106. security.protocol = SSL
  107. send.buffer.bytes = 131072
  108. session.timeout.ms = 10000
  109. ssl.cipher.suites = null
  110. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  111. ssl.endpoint.identification.algorithm = null
  112. ssl.key.password = [hidden]
  113. ssl.keymanager.algorithm = SunX509
  114. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  115. ssl.keystore.password = [hidden]
  116. ssl.keystore.type = JKS
  117. ssl.protocol = TLS
  118. ssl.provider = null
  119. ssl.secure.random.implementation = null
  120. ssl.trustmanager.algorithm = PKIX
  121. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  122. ssl.truststore.password = [hidden]
  123. ssl.truststore.type = JKS
  124. status.storage.partitions = 5
  125. status.storage.replication.factor = 3
  126. status.storage.topic = connect-status
  127. task.shutdown.graceful.timeout.ms = 5000
  128. value.converter = class org.apache.kafka.connect.json.JsonConverter
  129. worker.sync.timeout.ms = 3000
  130. worker.unsync.backoff.ms = 300000
  131. (org.apache.kafka.connect.runtime.distributed.DistributedConfig:223)
  132. [2017-10-11 14:16:58,513] INFO Logging initialized @3012ms (org.eclipse.jetty.util.log:186)
  133. [2017-10-11 14:16:58,760] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  134. [2017-10-11 14:16:58,761] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  135. [2017-10-11 14:16:58,764] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:49)
  136. [2017-10-11 14:16:58,764] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:98)
  137. [2017-10-11 14:16:58,765] INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder:192)
  138. [2017-10-11 14:16:58,765] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:144)
  139. [2017-10-11 14:16:58,766] INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:108)
  140. [2017-10-11 14:16:58,766] INFO Starting KafkaBasedLog with topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:124)
  141. [2017-10-11 14:16:58,772] INFO AdminClientConfig values:
  142. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  143. client.id =
  144. connections.max.idle.ms = 300000
  145. metadata.max.age.ms = 300000
  146. metric.reporters = []
  147. metrics.num.samples = 2
  148. metrics.recording.level = INFO
  149. metrics.sample.window.ms = 30000
  150. receive.buffer.bytes = 65536
  151. reconnect.backoff.max.ms = 1000
  152. reconnect.backoff.ms = 50
  153. request.timeout.ms = 120000
  154. retries = 5
  155. retry.backoff.ms = 100
  156. sasl.jaas.config = null
  157. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  158. sasl.kerberos.min.time.before.relogin = 60000
  159. sasl.kerberos.service.name = null
  160. sasl.kerberos.ticket.renew.jitter = 0.05
  161. sasl.kerberos.ticket.renew.window.factor = 0.8
  162. sasl.mechanism = GSSAPI
  163. security.protocol = SSL
  164. send.buffer.bytes = 131072
  165. ssl.cipher.suites = null
  166. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  167. ssl.endpoint.identification.algorithm = null
  168. ssl.key.password = [hidden]
  169. ssl.keymanager.algorithm = SunX509
  170. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  171. ssl.keystore.password = [hidden]
  172. ssl.keystore.type = JKS
  173. ssl.protocol = TLS
  174. ssl.provider = null
  175. ssl.secure.random.implementation = null
  176. ssl.trustmanager.algorithm = PKIX
  177. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  178. ssl.truststore.password = [hidden]
  179. ssl.truststore.type = JKS
  180. (org.apache.kafka.clients.admin.AdminClientConfig:223)
  181. [2017-10-11 14:16:58,790] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  182. [2017-10-11 14:16:58,790] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  183. [2017-10-11 14:16:58,790] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  184. [2017-10-11 14:16:58,790] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  185. [2017-10-11 14:16:58,790] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  186. [2017-10-11 14:16:58,791] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  187. [2017-10-11 14:16:58,791] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  188. [2017-10-11 14:16:58,791] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  189. [2017-10-11 14:16:58,791] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  190. [2017-10-11 14:16:58,791] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  191. [2017-10-11 14:16:58,791] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  192. [2017-10-11 14:16:58,791] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  193. [2017-10-11 14:16:58,792] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  194. [2017-10-11 14:16:58,792] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  195. [2017-10-11 14:16:58,792] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  196. [2017-10-11 14:16:58,792] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  197. [2017-10-11 14:16:58,792] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  198. [2017-10-11 14:16:58,792] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  199. [2017-10-11 14:16:58,792] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  200. [2017-10-11 14:16:58,793] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  201. [2017-10-11 14:16:58,793] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  202. [2017-10-11 14:16:58,793] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  203. [2017-10-11 14:16:58,793] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  204. [2017-10-11 14:16:58,793] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  205. [2017-10-11 14:16:58,793] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  206. [2017-10-11 14:16:58,794] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  207. [2017-10-11 14:16:58,794] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  208. [2017-10-11 14:16:58,794] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  209. [2017-10-11 14:16:58,794] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  210. [2017-10-11 14:16:58,794] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  211. [2017-10-11 14:16:58,794] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  212. [2017-10-11 14:16:58,794] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  213. [2017-10-11 14:16:58,795] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  214. [2017-10-11 14:16:58,795] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  215. [2017-10-11 14:16:58,822] INFO jetty-9.2.15.v20160210 (org.eclipse.jetty.server.Server:327)
  216. [2017-10-11 14:16:59,128] INFO ProducerConfig values:
  217. acks = all
  218. batch.size = 16384
  219. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  220. buffer.memory = 33554432
  221. client.id =
  222. compression.type = none
  223. connections.max.idle.ms = 540000
  224. enable.idempotence = false
  225. interceptor.classes = null
  226. key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  227. linger.ms = 0
  228. max.block.ms = 60000
  229. max.in.flight.requests.per.connection = 1
  230. max.request.size = 1048576
  231. metadata.max.age.ms = 300000
  232. metric.reporters = []
  233. metrics.num.samples = 2
  234. metrics.recording.level = INFO
  235. metrics.sample.window.ms = 30000
  236. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  237. receive.buffer.bytes = 32768
  238. reconnect.backoff.max.ms = 1000
  239. reconnect.backoff.ms = 50
  240. request.timeout.ms = 30000
  241. retries = 2147483647
  242. retry.backoff.ms = 100
  243. sasl.jaas.config = null
  244. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  245. sasl.kerberos.min.time.before.relogin = 60000
  246. sasl.kerberos.service.name = null
  247. sasl.kerberos.ticket.renew.jitter = 0.05
  248. sasl.kerberos.ticket.renew.window.factor = 0.8
  249. sasl.mechanism = GSSAPI
  250. security.protocol = SSL
  251. send.buffer.bytes = 131072
  252. ssl.cipher.suites = null
  253. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  254. ssl.endpoint.identification.algorithm = null
  255. ssl.key.password = [hidden]
  256. ssl.keymanager.algorithm = SunX509
  257. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  258. ssl.keystore.password = [hidden]
  259. ssl.keystore.type = JKS
  260. ssl.protocol = TLS
  261. ssl.provider = null
  262. ssl.secure.random.implementation = null
  263. ssl.trustmanager.algorithm = PKIX
  264. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  265. ssl.truststore.password = [hidden]
  266. ssl.truststore.type = JKS
  267. transaction.timeout.ms = 60000
  268. transactional.id = null
  269. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  270. (org.apache.kafka.clients.producer.ProducerConfig:223)
  271. [2017-10-11 14:16:59,157] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  272. [2017-10-11 14:16:59,158] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  273. [2017-10-11 14:16:59,158] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  274. [2017-10-11 14:16:59,158] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  275. [2017-10-11 14:16:59,158] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  276. [2017-10-11 14:16:59,158] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  277. [2017-10-11 14:16:59,158] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  278. [2017-10-11 14:16:59,158] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  279. [2017-10-11 14:16:59,159] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  280. [2017-10-11 14:16:59,159] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  281. [2017-10-11 14:16:59,159] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  282. [2017-10-11 14:16:59,159] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  283. [2017-10-11 14:16:59,159] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  284. [2017-10-11 14:16:59,159] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  285. [2017-10-11 14:16:59,159] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  286. [2017-10-11 14:16:59,159] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  287. [2017-10-11 14:16:59,160] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  288. [2017-10-11 14:16:59,160] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  289. [2017-10-11 14:16:59,160] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  290. [2017-10-11 14:16:59,160] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  291. [2017-10-11 14:16:59,160] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  292. [2017-10-11 14:16:59,160] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  293. [2017-10-11 14:16:59,160] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  294. [2017-10-11 14:16:59,161] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  295. [2017-10-11 14:16:59,161] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  296. [2017-10-11 14:16:59,161] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  297. [2017-10-11 14:16:59,161] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  298. [2017-10-11 14:16:59,161] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  299. [2017-10-11 14:16:59,161] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  300. [2017-10-11 14:16:59,161] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  301. [2017-10-11 14:16:59,161] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  302. [2017-10-11 14:16:59,161] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  303. [2017-10-11 14:16:59,161] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  304. [2017-10-11 14:16:59,162] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  305. [2017-10-11 14:16:59,162] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  306. [2017-10-11 14:16:59,162] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  307. [2017-10-11 14:16:59,166] INFO Started o.e.j.s.ServletContextHandler@241410c5{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)
  308. [2017-10-11 14:16:59,172] INFO ConsumerConfig values:
  309. auto.commit.interval.ms = 5000
  310. auto.offset.reset = earliest
  311. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  312. check.crcs = true
  313. client.id =
  314. connections.max.idle.ms = 540000
  315. enable.auto.commit = false
  316. exclude.internal.topics = true
  317. fetch.max.bytes = 52428800
  318. fetch.max.wait.ms = 500
  319. fetch.min.bytes = 1
  320. group.id = connect-cluster
  321. heartbeat.interval.ms = 3000
  322. interceptor.classes = null
  323. internal.leave.group.on.close = true
  324. isolation.level = read_uncommitted
  325. key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  326. max.partition.fetch.bytes = 1048576
  327. max.poll.interval.ms = 300000
  328. max.poll.records = 500
  329. metadata.max.age.ms = 300000
  330. metric.reporters = []
  331. metrics.num.samples = 2
  332. metrics.recording.level = INFO
  333. metrics.sample.window.ms = 30000
  334. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  335. receive.buffer.bytes = 65536
  336. reconnect.backoff.max.ms = 1000
  337. reconnect.backoff.ms = 50
  338. request.timeout.ms = 305000
  339. retry.backoff.ms = 100
  340. sasl.jaas.config = null
  341. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  342. sasl.kerberos.min.time.before.relogin = 60000
  343. sasl.kerberos.service.name = null
  344. sasl.kerberos.ticket.renew.jitter = 0.05
  345. sasl.kerberos.ticket.renew.window.factor = 0.8
  346. sasl.mechanism = GSSAPI
  347. security.protocol = SSL
  348. send.buffer.bytes = 131072
  349. session.timeout.ms = 10000
  350. ssl.cipher.suites = null
  351. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  352. ssl.endpoint.identification.algorithm = null
  353. ssl.key.password = [hidden]
  354. ssl.keymanager.algorithm = SunX509
  355. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  356. ssl.keystore.password = [hidden]
  357. ssl.keystore.type = JKS
  358. ssl.protocol = TLS
  359. ssl.provider = null
  360. ssl.secure.random.implementation = null
  361. ssl.trustmanager.algorithm = PKIX
  362. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  363. ssl.truststore.password = [hidden]
  364. ssl.truststore.type = JKS
  365. value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  366. (org.apache.kafka.clients.consumer.ConsumerConfig:223)
  367. [2017-10-11 14:16:59,172] INFO Started ServerConnector@396ab19d{HTTP/1.1}{0.0.0.0:8086} (org.eclipse.jetty.server.ServerConnector:266)
  368. [2017-10-11 14:16:59,172] INFO Started @3672ms (org.eclipse.jetty.server.Server:379)
  369. [2017-10-11 14:16:59,173] INFO REST server listening at http://172.26.18.214:8086/, advertising URL http://172.26.18.214:8086/ (org.apache.kafka.connect.runtime.rest.RestServer:150)
  370. [2017-10-11 14:16:59,173] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)
  371. [2017-10-11 14:16:59,200] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  372. [2017-10-11 14:16:59,200] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  373. [2017-10-11 14:16:59,200] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  374. [2017-10-11 14:16:59,200] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  375. [2017-10-11 14:16:59,200] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  376. [2017-10-11 14:16:59,200] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  377. [2017-10-11 14:16:59,200] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  378. [2017-10-11 14:16:59,201] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  379. [2017-10-11 14:16:59,201] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  380. [2017-10-11 14:16:59,201] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  381. [2017-10-11 14:16:59,201] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  382. [2017-10-11 14:16:59,201] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  383. [2017-10-11 14:16:59,201] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  384. [2017-10-11 14:16:59,201] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  385. [2017-10-11 14:16:59,201] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  386. [2017-10-11 14:16:59,201] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  387. [2017-10-11 14:16:59,201] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  388. [2017-10-11 14:16:59,201] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  389. [2017-10-11 14:16:59,201] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  390. [2017-10-11 14:16:59,201] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  391. [2017-10-11 14:16:59,202] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  392. [2017-10-11 14:16:59,202] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  393. [2017-10-11 14:16:59,202] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  394. [2017-10-11 14:16:59,202] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  395. [2017-10-11 14:16:59,202] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  396. [2017-10-11 14:16:59,202] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  397. [2017-10-11 14:16:59,202] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  398. [2017-10-11 14:16:59,202] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  399. [2017-10-11 14:16:59,202] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  400. [2017-10-11 14:16:59,202] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  401. [2017-10-11 14:16:59,202] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  402. [2017-10-11 14:16:59,202] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  403. [2017-10-11 14:16:59,203] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  404. [2017-10-11 14:16:59,203] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  405. [2017-10-11 14:16:59,203] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  406. [2017-10-11 14:16:59,394] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group connect-cluster. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  407. [2017-10-11 14:16:59,453] INFO Finished reading KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:153)
  408. [2017-10-11 14:16:59,454] INFO Started KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:155)
  409. [2017-10-11 14:16:59,454] INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:110)
  410. [2017-10-11 14:16:59,454] INFO Worker started (org.apache.kafka.connect.runtime.Worker:149)
  411. [2017-10-11 14:16:59,454] INFO Starting KafkaBasedLog with topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:124)
  412. [2017-10-11 14:16:59,455] INFO AdminClientConfig values:
  413. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  414. client.id =
  415. connections.max.idle.ms = 300000
  416. metadata.max.age.ms = 300000
  417. metric.reporters = []
  418. metrics.num.samples = 2
  419. metrics.recording.level = INFO
  420. metrics.sample.window.ms = 30000
  421. receive.buffer.bytes = 65536
  422. reconnect.backoff.max.ms = 1000
  423. reconnect.backoff.ms = 50
  424. request.timeout.ms = 120000
  425. retries = 5
  426. retry.backoff.ms = 100
  427. sasl.jaas.config = null
  428. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  429. sasl.kerberos.min.time.before.relogin = 60000
  430. sasl.kerberos.service.name = null
  431. sasl.kerberos.ticket.renew.jitter = 0.05
  432. sasl.kerberos.ticket.renew.window.factor = 0.8
  433. sasl.mechanism = GSSAPI
  434. security.protocol = SSL
  435. send.buffer.bytes = 131072
  436. ssl.cipher.suites = null
  437. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  438. ssl.endpoint.identification.algorithm = null
  439. ssl.key.password = [hidden]
  440. ssl.keymanager.algorithm = SunX509
  441. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  442. ssl.keystore.password = [hidden]
  443. ssl.keystore.type = JKS
  444. ssl.protocol = TLS
  445. ssl.provider = null
  446. ssl.secure.random.implementation = null
  447. ssl.trustmanager.algorithm = PKIX
  448. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  449. ssl.truststore.password = [hidden]
  450. ssl.truststore.type = JKS
  451. (org.apache.kafka.clients.admin.AdminClientConfig:223)
  452. [2017-10-11 14:16:59,457] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  453. [2017-10-11 14:16:59,457] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  454. [2017-10-11 14:16:59,457] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  455. [2017-10-11 14:16:59,457] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  456. [2017-10-11 14:16:59,457] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  457. [2017-10-11 14:16:59,457] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  458. [2017-10-11 14:16:59,457] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  459. [2017-10-11 14:16:59,457] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  460. [2017-10-11 14:16:59,457] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  461. [2017-10-11 14:16:59,458] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  462. [2017-10-11 14:16:59,458] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  463. [2017-10-11 14:16:59,458] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  464. [2017-10-11 14:16:59,458] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  465. [2017-10-11 14:16:59,458] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  466. [2017-10-11 14:16:59,458] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  467. [2017-10-11 14:16:59,458] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  468. [2017-10-11 14:16:59,458] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  469. [2017-10-11 14:16:59,458] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  470. [2017-10-11 14:16:59,458] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  471. [2017-10-11 14:16:59,458] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  472. [2017-10-11 14:16:59,458] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  473. [2017-10-11 14:16:59,458] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  474. [2017-10-11 14:16:59,458] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  475. [2017-10-11 14:16:59,458] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  476. [2017-10-11 14:16:59,458] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  477. [2017-10-11 14:16:59,459] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  478. [2017-10-11 14:16:59,459] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  479. [2017-10-11 14:16:59,459] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  480. [2017-10-11 14:16:59,459] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  481. [2017-10-11 14:16:59,459] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  482. [2017-10-11 14:16:59,459] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  483. [2017-10-11 14:16:59,459] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  484. [2017-10-11 14:16:59,459] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  485. [2017-10-11 14:16:59,459] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  486. [2017-10-11 14:16:59,628] INFO ProducerConfig values:
  487. acks = all
  488. batch.size = 16384
  489. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  490. buffer.memory = 33554432
  491. client.id =
  492. compression.type = none
  493. connections.max.idle.ms = 540000
  494. enable.idempotence = false
  495. interceptor.classes = null
  496. key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  497. linger.ms = 0
  498. max.block.ms = 60000
  499. max.in.flight.requests.per.connection = 1
  500. max.request.size = 1048576
  501. metadata.max.age.ms = 300000
  502. metric.reporters = []
  503. metrics.num.samples = 2
  504. metrics.recording.level = INFO
  505. metrics.sample.window.ms = 30000
  506. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  507. receive.buffer.bytes = 32768
  508. reconnect.backoff.max.ms = 1000
  509. reconnect.backoff.ms = 50
  510. request.timeout.ms = 30000
  511. retries = 0
  512. retry.backoff.ms = 100
  513. sasl.jaas.config = null
  514. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  515. sasl.kerberos.min.time.before.relogin = 60000
  516. sasl.kerberos.service.name = null
  517. sasl.kerberos.ticket.renew.jitter = 0.05
  518. sasl.kerberos.ticket.renew.window.factor = 0.8
  519. sasl.mechanism = GSSAPI
  520. security.protocol = SSL
  521. send.buffer.bytes = 131072
  522. ssl.cipher.suites = null
  523. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  524. ssl.endpoint.identification.algorithm = null
  525. ssl.key.password = [hidden]
  526. ssl.keymanager.algorithm = SunX509
  527. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  528. ssl.keystore.password = [hidden]
  529. ssl.keystore.type = JKS
  530. ssl.protocol = TLS
  531. ssl.provider = null
  532. ssl.secure.random.implementation = null
  533. ssl.trustmanager.algorithm = PKIX
  534. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  535. ssl.truststore.password = [hidden]
  536. ssl.truststore.type = JKS
  537. transaction.timeout.ms = 60000
  538. transactional.id = null
  539. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  540. (org.apache.kafka.clients.producer.ProducerConfig:223)
  541. [2017-10-11 14:16:59,633] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  542. [2017-10-11 14:16:59,633] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  543. [2017-10-11 14:16:59,633] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  544. [2017-10-11 14:16:59,633] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  545. [2017-10-11 14:16:59,633] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  546. [2017-10-11 14:16:59,634] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  547. [2017-10-11 14:16:59,634] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  548. [2017-10-11 14:16:59,634] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  549. [2017-10-11 14:16:59,634] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  550. [2017-10-11 14:16:59,634] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  551. [2017-10-11 14:16:59,634] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  552. [2017-10-11 14:16:59,634] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  553. [2017-10-11 14:16:59,634] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  554. [2017-10-11 14:16:59,634] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  555. [2017-10-11 14:16:59,635] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  556. [2017-10-11 14:16:59,635] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  557. [2017-10-11 14:16:59,635] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  558. [2017-10-11 14:16:59,635] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  559. [2017-10-11 14:16:59,635] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  560. [2017-10-11 14:16:59,635] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  561. [2017-10-11 14:16:59,635] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  562. [2017-10-11 14:16:59,635] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  563. [2017-10-11 14:16:59,636] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  564. [2017-10-11 14:16:59,636] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  565. [2017-10-11 14:16:59,636] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  566. [2017-10-11 14:16:59,636] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  567. [2017-10-11 14:16:59,636] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  568. [2017-10-11 14:16:59,636] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  569. [2017-10-11 14:16:59,637] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  570. [2017-10-11 14:16:59,637] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  571. [2017-10-11 14:16:59,637] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  572. [2017-10-11 14:16:59,637] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  573. [2017-10-11 14:16:59,637] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  574. [2017-10-11 14:16:59,637] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  575. [2017-10-11 14:16:59,637] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  576. [2017-10-11 14:16:59,637] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  577. [2017-10-11 14:16:59,639] INFO ConsumerConfig values:
  578. auto.commit.interval.ms = 5000
  579. auto.offset.reset = earliest
  580. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  581. check.crcs = true
  582. client.id =
  583. connections.max.idle.ms = 540000
  584. enable.auto.commit = false
  585. exclude.internal.topics = true
  586. fetch.max.bytes = 52428800
  587. fetch.max.wait.ms = 500
  588. fetch.min.bytes = 1
  589. group.id = connect-cluster
  590. heartbeat.interval.ms = 3000
  591. interceptor.classes = null
  592. internal.leave.group.on.close = true
  593. isolation.level = read_uncommitted
  594. key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  595. max.partition.fetch.bytes = 1048576
  596. max.poll.interval.ms = 300000
  597. max.poll.records = 500
  598. metadata.max.age.ms = 300000
  599. metric.reporters = []
  600. metrics.num.samples = 2
  601. metrics.recording.level = INFO
  602. metrics.sample.window.ms = 30000
  603. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  604. receive.buffer.bytes = 65536
  605. reconnect.backoff.max.ms = 1000
  606. reconnect.backoff.ms = 50
  607. request.timeout.ms = 305000
  608. retry.backoff.ms = 100
  609. sasl.jaas.config = null
  610. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  611. sasl.kerberos.min.time.before.relogin = 60000
  612. sasl.kerberos.service.name = null
  613. sasl.kerberos.ticket.renew.jitter = 0.05
  614. sasl.kerberos.ticket.renew.window.factor = 0.8
  615. sasl.mechanism = GSSAPI
  616. security.protocol = SSL
  617. send.buffer.bytes = 131072
  618. session.timeout.ms = 10000
  619. ssl.cipher.suites = null
  620. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  621. ssl.endpoint.identification.algorithm = null
  622. ssl.key.password = [hidden]
  623. ssl.keymanager.algorithm = SunX509
  624. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  625. ssl.keystore.password = [hidden]
  626. ssl.keystore.type = JKS
  627. ssl.protocol = TLS
  628. ssl.provider = null
  629. ssl.secure.random.implementation = null
  630. ssl.trustmanager.algorithm = PKIX
  631. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  632. ssl.truststore.password = [hidden]
  633. ssl.truststore.type = JKS
  634. value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  635. (org.apache.kafka.clients.consumer.ConsumerConfig:223)
  636. [2017-10-11 14:16:59,642] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  637. [2017-10-11 14:16:59,643] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  638. [2017-10-11 14:16:59,643] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  639. [2017-10-11 14:16:59,643] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  640. [2017-10-11 14:16:59,643] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  641. [2017-10-11 14:16:59,643] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  642. [2017-10-11 14:16:59,643] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  643. [2017-10-11 14:16:59,643] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  644. [2017-10-11 14:16:59,643] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  645. [2017-10-11 14:16:59,643] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  646. [2017-10-11 14:16:59,644] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  647. [2017-10-11 14:16:59,644] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  648. [2017-10-11 14:16:59,644] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  649. [2017-10-11 14:16:59,644] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  650. [2017-10-11 14:16:59,644] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  651. [2017-10-11 14:16:59,644] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  652. [2017-10-11 14:16:59,644] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  653. [2017-10-11 14:16:59,644] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  654. [2017-10-11 14:16:59,644] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  655. [2017-10-11 14:16:59,644] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  656. [2017-10-11 14:16:59,645] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  657. [2017-10-11 14:16:59,645] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  658. [2017-10-11 14:16:59,645] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  659. [2017-10-11 14:16:59,645] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  660. [2017-10-11 14:16:59,645] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  661. [2017-10-11 14:16:59,645] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  662. [2017-10-11 14:16:59,645] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  663. [2017-10-11 14:16:59,645] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  664. [2017-10-11 14:16:59,645] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  665. [2017-10-11 14:16:59,645] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  666. [2017-10-11 14:16:59,645] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  667. [2017-10-11 14:16:59,646] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  668. [2017-10-11 14:16:59,646] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  669. [2017-10-11 14:16:59,646] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  670. [2017-10-11 14:16:59,646] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  671. [2017-10-11 14:16:59,825] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group connect-cluster. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  672. [2017-10-11 14:16:59,913] INFO Finished reading KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:153)
  673. [2017-10-11 14:16:59,913] INFO Started KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:155)
  674. [2017-10-11 14:16:59,913] INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:244)
  675. [2017-10-11 14:16:59,913] INFO Starting KafkaBasedLog with topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:124)
  676. [2017-10-11 14:16:59,914] INFO AdminClientConfig values:
  677. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  678. client.id =
  679. connections.max.idle.ms = 300000
  680. metadata.max.age.ms = 300000
  681. metric.reporters = []
  682. metrics.num.samples = 2
  683. metrics.recording.level = INFO
  684. metrics.sample.window.ms = 30000
  685. receive.buffer.bytes = 65536
  686. reconnect.backoff.max.ms = 1000
  687. reconnect.backoff.ms = 50
  688. request.timeout.ms = 120000
  689. retries = 5
  690. retry.backoff.ms = 100
  691. sasl.jaas.config = null
  692. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  693. sasl.kerberos.min.time.before.relogin = 60000
  694. sasl.kerberos.service.name = null
  695. sasl.kerberos.ticket.renew.jitter = 0.05
  696. sasl.kerberos.ticket.renew.window.factor = 0.8
  697. sasl.mechanism = GSSAPI
  698. security.protocol = SSL
  699. send.buffer.bytes = 131072
  700. ssl.cipher.suites = null
  701. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  702. ssl.endpoint.identification.algorithm = null
  703. ssl.key.password = [hidden]
  704. ssl.keymanager.algorithm = SunX509
  705. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  706. ssl.keystore.password = [hidden]
  707. ssl.keystore.type = JKS
  708. ssl.protocol = TLS
  709. ssl.provider = null
  710. ssl.secure.random.implementation = null
  711. ssl.trustmanager.algorithm = PKIX
  712. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  713. ssl.truststore.password = [hidden]
  714. ssl.truststore.type = JKS
  715. (org.apache.kafka.clients.admin.AdminClientConfig:223)
  716. [2017-10-11 14:16:59,916] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  717. [2017-10-11 14:16:59,916] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  718. [2017-10-11 14:16:59,916] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  719. [2017-10-11 14:16:59,916] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  720. [2017-10-11 14:16:59,917] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  721. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  722. [2017-10-11 14:16:59,917] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  723. [2017-10-11 14:16:59,917] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  724. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  725. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  726. [2017-10-11 14:16:59,917] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  727. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  728. [2017-10-11 14:16:59,917] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  729. [2017-10-11 14:16:59,917] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  730. [2017-10-11 14:16:59,917] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  731. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  732. [2017-10-11 14:16:59,917] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  733. [2017-10-11 14:16:59,917] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  734. [2017-10-11 14:16:59,917] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  735. [2017-10-11 14:16:59,917] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  736. [2017-10-11 14:16:59,917] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  737. [2017-10-11 14:16:59,918] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  738. [2017-10-11 14:16:59,918] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  739. [2017-10-11 14:16:59,918] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  740. [2017-10-11 14:16:59,918] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  741. [2017-10-11 14:16:59,918] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  742. [2017-10-11 14:16:59,918] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  743. [2017-10-11 14:16:59,918] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  744. [2017-10-11 14:16:59,918] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  745. [2017-10-11 14:16:59,918] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  746. [2017-10-11 14:16:59,918] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  747. [2017-10-11 14:16:59,918] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  748. [2017-10-11 14:16:59,918] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  749. [2017-10-11 14:16:59,918] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:231)
  750. [2017-10-11 14:17:00,103] INFO ProducerConfig values:
  751. acks = all
  752. batch.size = 16384
  753. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  754. buffer.memory = 33554432
  755. client.id =
  756. compression.type = none
  757. connections.max.idle.ms = 540000
  758. enable.idempotence = false
  759. interceptor.classes = null
  760. key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  761. linger.ms = 0
  762. max.block.ms = 60000
  763. max.in.flight.requests.per.connection = 1
  764. max.request.size = 1048576
  765. metadata.max.age.ms = 300000
  766. metric.reporters = []
  767. metrics.num.samples = 2
  768. metrics.recording.level = INFO
  769. metrics.sample.window.ms = 30000
  770. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  771. receive.buffer.bytes = 32768
  772. reconnect.backoff.max.ms = 1000
  773. reconnect.backoff.ms = 50
  774. request.timeout.ms = 30000
  775. retries = 2147483647
  776. retry.backoff.ms = 100
  777. sasl.jaas.config = null
  778. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  779. sasl.kerberos.min.time.before.relogin = 60000
  780. sasl.kerberos.service.name = null
  781. sasl.kerberos.ticket.renew.jitter = 0.05
  782. sasl.kerberos.ticket.renew.window.factor = 0.8
  783. sasl.mechanism = GSSAPI
  784. security.protocol = SSL
  785. send.buffer.bytes = 131072
  786. ssl.cipher.suites = null
  787. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  788. ssl.endpoint.identification.algorithm = null
  789. ssl.key.password = [hidden]
  790. ssl.keymanager.algorithm = SunX509
  791. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  792. ssl.keystore.password = [hidden]
  793. ssl.keystore.type = JKS
  794. ssl.protocol = TLS
  795. ssl.provider = null
  796. ssl.secure.random.implementation = null
  797. ssl.trustmanager.algorithm = PKIX
  798. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  799. ssl.truststore.password = [hidden]
  800. ssl.truststore.type = JKS
  801. transaction.timeout.ms = 60000
  802. transactional.id = null
  803. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  804. (org.apache.kafka.clients.producer.ProducerConfig:223)
  805. [2017-10-11 14:17:00,107] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  806. [2017-10-11 14:17:00,107] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  807. [2017-10-11 14:17:00,108] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  808. [2017-10-11 14:17:00,108] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  809. [2017-10-11 14:17:00,108] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  810. [2017-10-11 14:17:00,108] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  811. [2017-10-11 14:17:00,108] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  812. [2017-10-11 14:17:00,108] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  813. [2017-10-11 14:17:00,108] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  814. [2017-10-11 14:17:00,108] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  815. [2017-10-11 14:17:00,108] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  816. [2017-10-11 14:17:00,108] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  817. [2017-10-11 14:17:00,109] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  818. [2017-10-11 14:17:00,109] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  819. [2017-10-11 14:17:00,109] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  820. [2017-10-11 14:17:00,109] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  821. [2017-10-11 14:17:00,109] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  822. [2017-10-11 14:17:00,109] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  823. [2017-10-11 14:17:00,109] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  824. [2017-10-11 14:17:00,109] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  825. [2017-10-11 14:17:00,109] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  826. [2017-10-11 14:17:00,109] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  827. [2017-10-11 14:17:00,109] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  828. [2017-10-11 14:17:00,110] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  829. [2017-10-11 14:17:00,110] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  830. [2017-10-11 14:17:00,110] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  831. [2017-10-11 14:17:00,110] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  832. [2017-10-11 14:17:00,110] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  833. [2017-10-11 14:17:00,110] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  834. [2017-10-11 14:17:00,110] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  835. [2017-10-11 14:17:00,110] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  836. [2017-10-11 14:17:00,110] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  837. [2017-10-11 14:17:00,110] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  838. [2017-10-11 14:17:00,110] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:231)
  839. [2017-10-11 14:17:00,111] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  840. [2017-10-11 14:17:00,111] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  841. [2017-10-11 14:17:00,111] INFO ConsumerConfig values:
  842. auto.commit.interval.ms = 5000
  843. auto.offset.reset = earliest
  844. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  845. check.crcs = true
  846. client.id =
  847. connections.max.idle.ms = 540000
  848. enable.auto.commit = false
  849. exclude.internal.topics = true
  850. fetch.max.bytes = 52428800
  851. fetch.max.wait.ms = 500
  852. fetch.min.bytes = 1
  853. group.id = connect-cluster
  854. heartbeat.interval.ms = 3000
  855. interceptor.classes = null
  856. internal.leave.group.on.close = true
  857. isolation.level = read_uncommitted
  858. key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  859. max.partition.fetch.bytes = 1048576
  860. max.poll.interval.ms = 300000
  861. max.poll.records = 500
  862. metadata.max.age.ms = 300000
  863. metric.reporters = []
  864. metrics.num.samples = 2
  865. metrics.recording.level = INFO
  866. metrics.sample.window.ms = 30000
  867. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  868. receive.buffer.bytes = 65536
  869. reconnect.backoff.max.ms = 1000
  870. reconnect.backoff.ms = 50
  871. request.timeout.ms = 305000
  872. retry.backoff.ms = 100
  873. sasl.jaas.config = null
  874. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  875. sasl.kerberos.min.time.before.relogin = 60000
  876. sasl.kerberos.service.name = null
  877. sasl.kerberos.ticket.renew.jitter = 0.05
  878. sasl.kerberos.ticket.renew.window.factor = 0.8
  879. sasl.mechanism = GSSAPI
  880. security.protocol = SSL
  881. send.buffer.bytes = 131072
  882. session.timeout.ms = 10000
  883. ssl.cipher.suites = null
  884. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  885. ssl.endpoint.identification.algorithm = null
  886. ssl.key.password = [hidden]
  887. ssl.keymanager.algorithm = SunX509
  888. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  889. ssl.keystore.password = [hidden]
  890. ssl.keystore.type = JKS
  891. ssl.protocol = TLS
  892. ssl.provider = null
  893. ssl.secure.random.implementation = null
  894. ssl.trustmanager.algorithm = PKIX
  895. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  896. ssl.truststore.password = [hidden]
  897. ssl.truststore.type = JKS
  898. value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  899. (org.apache.kafka.clients.consumer.ConsumerConfig:223)
  900. [2017-10-11 14:17:00,114] WARN The configuration 'producer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  901. [2017-10-11 14:17:00,115] WARN The configuration 'producer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  902. [2017-10-11 14:17:00,115] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  903. [2017-10-11 14:17:00,115] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  904. [2017-10-11 14:17:00,116] WARN The configuration 'consumer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  905. [2017-10-11 14:17:00,116] WARN The configuration 'producer.ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  906. [2017-10-11 14:17:00,116] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  907. [2017-10-11 14:17:00,116] WARN The configuration 'consumer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  908. [2017-10-11 14:17:00,116] WARN The configuration 'consumer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  909. [2017-10-11 14:17:00,116] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  910. [2017-10-11 14:17:00,116] WARN The configuration 'consumer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  911. [2017-10-11 14:17:00,116] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  912. [2017-10-11 14:17:00,116] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  913. [2017-10-11 14:17:00,116] WARN The configuration 'producer.ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  914. [2017-10-11 14:17:00,116] WARN The configuration 'consumer.ssl.truststore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  915. [2017-10-11 14:17:00,117] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  916. [2017-10-11 14:17:00,117] WARN The configuration 'producer.security.protocol' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  917. [2017-10-11 14:17:00,117] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  918. [2017-10-11 14:17:00,117] WARN The configuration 'consumer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  919. [2017-10-11 14:17:00,117] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  920. [2017-10-11 14:17:00,117] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  921. [2017-10-11 14:17:00,117] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  922. [2017-10-11 14:17:00,117] WARN The configuration 'producer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  923. [2017-10-11 14:17:00,117] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  924. [2017-10-11 14:17:00,117] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  925. [2017-10-11 14:17:00,117] WARN The configuration 'producer.ssl.truststore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  926. [2017-10-11 14:17:00,117] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  927. [2017-10-11 14:17:00,118] WARN The configuration 'producer.ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  928. [2017-10-11 14:17:00,118] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  929. [2017-10-11 14:17:00,118] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  930. [2017-10-11 14:17:00,118] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  931. [2017-10-11 14:17:00,118] WARN The configuration 'consumer.ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  932. [2017-10-11 14:17:00,118] WARN The configuration 'consumer.ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:231)
  933. [2017-10-11 14:17:00,118] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  934. [2017-10-11 14:17:00,118] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  935. [2017-10-11 14:17:00,266] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group connect-cluster. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  936. [2017-10-11 14:17:00,297] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  937. [2017-10-11 14:17:00,298] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  938. [2017-10-11 14:17:00,298] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  939. [2017-10-11 14:17:00,299] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  940. [2017-10-11 14:17:00,299] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  941. [2017-10-11 14:17:00,300] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  942. [2017-10-11 14:17:00,300] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  943. [2017-10-11 14:17:00,300] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  944. [2017-10-11 14:17:00,300] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  945. [2017-10-11 14:17:00,301] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  946. [2017-10-11 14:17:00,302] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  947. [2017-10-11 14:17:00,302] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  948. [2017-10-11 14:17:00,303] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  949. [2017-10-11 14:17:00,303] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  950. [2017-10-11 14:17:00,303] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  951. [2017-10-11 14:17:00,304] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  952. [2017-10-11 14:17:00,304] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  953. [2017-10-11 14:17:00,304] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  954. [2017-10-11 14:17:00,305] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  955. [2017-10-11 14:17:00,305] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  956. [2017-10-11 14:17:00,305] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  957. [2017-10-11 14:17:00,305] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  958. [2017-10-11 14:17:00,306] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  959. [2017-10-11 14:17:00,306] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  960. [2017-10-11 14:17:00,306] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  961. [2017-10-11 14:17:00,307] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  962. [2017-10-11 14:17:00,307] INFO Finished reading KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:153)
  963. [2017-10-11 14:17:00,307] INFO Started KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:155)
  964. [2017-10-11 14:17:00,307] INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:249)
  965. [2017-10-11 14:17:00,307] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:196)
  966. [2017-10-11 14:17:00,350] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group connect-cluster. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  967. [2017-10-11 14:17:00,353] INFO (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  968. [2017-10-11 14:17:00,381] INFO Successfully joined group connect-cluster with generation 34 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  969. [2017-10-11 14:17:00,381] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-a2612a99-3fdd-4427-99ea-19667929bdd4', leaderUrl='http://172.26.18.214:8086/', offset=106, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1166)
  970. [2017-10-11 14:17:00,381] WARN Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:741)
  971. [2017-10-11 14:17:00,382] INFO Current config state offset -1 is behind group assignment 106, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:785)
  972. [2017-10-11 14:17:00,798] INFO Finished reading to end of log and updated config snapshot, new config log offset: 106 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:789)
  973. [2017-10-11 14:17:00,798] INFO Starting connectors and tasks using config offset 106 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:815)
  974. [2017-10-11 14:17:00,798] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:825)
  975. [2017-10-11 14:18:57,239] INFO Successfully tested connection for jdbc:mysql://172.26.18.213:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=convertToNull with user 'kafka-connector' (io.debezium.connector.mysql.MySqlConnector:98)
  976. [2017-10-11 14:18:57,315] INFO Connector inventory-connector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1056)
  977. [2017-10-11 14:18:57,818] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1187)
  978. [2017-10-11 14:18:57,818] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217)
  979. [2017-10-11 14:18:57,818] INFO (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  980. [2017-10-11 14:18:57,822] INFO Successfully joined group connect-cluster with generation 35 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  981. [2017-10-11 14:18:57,823] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-a2612a99-3fdd-4427-99ea-19667929bdd4', leaderUrl='http://172.26.18.214:8086/', offset=107, connectorIds=[inventory-connector], taskIds=[inventory-connector-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1166)
  982. [2017-10-11 14:18:57,823] INFO Starting connectors and tasks using config offset 107 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:815)
  983. [2017-10-11 14:18:57,825] INFO Starting connector inventory-connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868)
  984. [2017-10-11 14:18:57,825] INFO Starting task inventory-connector-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:829)
  985. [2017-10-11 14:18:57,825] INFO Creating task inventory-connector-0 (org.apache.kafka.connect.runtime.Worker:358)
  986. [2017-10-11 14:18:57,826] INFO ConnectorConfig values:
  987. connector.class = io.debezium.connector.mysql.MySqlConnector
  988. key.converter = null
  989. name = inventory-connector
  990. tasks.max = 1
  991. transforms = null
  992. value.converter = null
  993. (org.apache.kafka.connect.runtime.ConnectorConfig:223)
  994. [2017-10-11 14:18:57,826] INFO ConnectorConfig values:
  995. connector.class = io.debezium.connector.mysql.MySqlConnector
  996. key.converter = null
  997. name = inventory-connector
  998. tasks.max = 1
  999. transforms = null
  1000. value.converter = null
  1001. (org.apache.kafka.connect.runtime.ConnectorConfig:223)
  1002. [2017-10-11 14:18:57,828] INFO EnrichedConnectorConfig values:
  1003. connector.class = io.debezium.connector.mysql.MySqlConnector
  1004. key.converter = null
  1005. name = inventory-connector
  1006. tasks.max = 1
  1007. transforms = null
  1008. value.converter = null
  1009. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1010. [2017-10-11 14:18:57,828] INFO EnrichedConnectorConfig values:
  1011. connector.class = io.debezium.connector.mysql.MySqlConnector
  1012. key.converter = null
  1013. name = inventory-connector
  1014. tasks.max = 1
  1015. transforms = null
  1016. value.converter = null
  1017. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1018. [2017-10-11 14:18:57,828] INFO Creating connector inventory-connector of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:204)
  1019. [2017-10-11 14:18:57,830] INFO Instantiated connector inventory-connector with version 0.6.0 of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:207)
  1020. [2017-10-11 14:18:57,830] INFO TaskConfig values:
  1021. task.class = class io.debezium.connector.mysql.MySqlConnectorTask
  1022. (org.apache.kafka.connect.runtime.TaskConfig:223)
  1023. [2017-10-11 14:18:57,831] INFO Instantiated task inventory-connector-0 with version 0.6.0 of type io.debezium.connector.mysql.MySqlConnectorTask (org.apache.kafka.connect.runtime.Worker:373)
  1024. [2017-10-11 14:18:57,834] INFO ProducerConfig values:
  1025. acks = all
  1026. batch.size = 16384
  1027. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  1028. buffer.memory = 33554432
  1029. client.id =
  1030. compression.type = none
  1031. connections.max.idle.ms = 540000
  1032. enable.idempotence = false
  1033. interceptor.classes = null
  1034. key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1035. linger.ms = 0
  1036. max.block.ms = 9223372036854775807
  1037. max.in.flight.requests.per.connection = 1
  1038. max.request.size = 1048576
  1039. metadata.max.age.ms = 300000
  1040. metric.reporters = []
  1041. metrics.num.samples = 2
  1042. metrics.recording.level = INFO
  1043. metrics.sample.window.ms = 30000
  1044. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  1045. receive.buffer.bytes = 32768
  1046. reconnect.backoff.max.ms = 1000
  1047. reconnect.backoff.ms = 50
  1048. request.timeout.ms = 2147483647
  1049. retries = 2147483647
  1050. retry.backoff.ms = 100
  1051. sasl.jaas.config = null
  1052. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1053. sasl.kerberos.min.time.before.relogin = 60000
  1054. sasl.kerberos.service.name = null
  1055. sasl.kerberos.ticket.renew.jitter = 0.05
  1056. sasl.kerberos.ticket.renew.window.factor = 0.8
  1057. sasl.mechanism = GSSAPI
  1058. security.protocol = SSL
  1059. send.buffer.bytes = 131072
  1060. ssl.cipher.suites = null
  1061. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1062. ssl.endpoint.identification.algorithm = null
  1063. ssl.key.password = [hidden]
  1064. ssl.keymanager.algorithm = SunX509
  1065. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1066. ssl.keystore.password = [hidden]
  1067. ssl.keystore.type = JKS
  1068. ssl.protocol = TLS
  1069. ssl.provider = null
  1070. ssl.secure.random.implementation = null
  1071. ssl.trustmanager.algorithm = PKIX
  1072. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1073. ssl.truststore.password = [hidden]
  1074. ssl.truststore.type = JKS
  1075. transaction.timeout.ms = 60000
  1076. transactional.id = null
  1077. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1078. (org.apache.kafka.clients.producer.ProducerConfig:223)
  1079. [2017-10-11 14:18:57,839] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1080. [2017-10-11 14:18:57,839] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1081. [2017-10-11 14:18:57,870] INFO 172.31.14.199 - - [11/十月/2017:06:18:56 +0000] "POST /connectors/ HTTP/1.1" 201 2195 1096 (org.apache.kafka.connect.runtime.rest.RestServer:60)
  1082. [2017-10-11 14:18:57,889] INFO Finished creating connector inventory-connector (org.apache.kafka.connect.runtime.Worker:225)
  1083. [2017-10-11 14:18:57,890] INFO SourceConnectorConfig values:
  1084. connector.class = io.debezium.connector.mysql.MySqlConnector
  1085. key.converter = null
  1086. name = inventory-connector
  1087. tasks.max = 1
  1088. transforms = null
  1089. value.converter = null
  1090. (org.apache.kafka.connect.runtime.SourceConnectorConfig:223)
  1091. [2017-10-11 14:18:57,890] INFO EnrichedConnectorConfig values:
  1092. connector.class = io.debezium.connector.mysql.MySqlConnector
  1093. key.converter = null
  1094. name = inventory-connector
  1095. tasks.max = 1
  1096. transforms = null
  1097. value.converter = null
  1098. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1099. [2017-10-11 14:18:57,891] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:825)
  1100. [2017-10-11 14:18:57,894] INFO Removed connector inventory-connector due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  1101. [2017-10-11 14:18:57,895] INFO Connector inventory-connector config removed (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1043)
  1102. [2017-10-11 14:18:57,972] INFO KafkaDatabaseHistory Consumer config: {security.protocol=SSL, enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=inventory-connector-dbhistory, auto.offset.reset=earliest, ssl.truststore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, ssl.keystore.password=********, session.timeout.ms=10000, bootstrap.servers=172.26.18.214:8082, ssl.truststore.password=********, ssl.keystore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, client.id=inventory-connector-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1, ssl.key.password=********} (io.debezium.relational.history.KafkaDatabaseHistory:142)
  1103. [2017-10-11 14:18:57,972] INFO KafkaDatabaseHistory Producer config: {security.protocol=SSL, ssl.keystore.password=********, ssl.truststore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, bootstrap.servers=172.26.18.214:8082, ssl.truststore.password=********, value.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.keystore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, linger.ms=0, client.id=inventory-connector-dbhistory, batch.size=32768, acks=1, ssl.key.password=********} (io.debezium.relational.history.KafkaDatabaseHistory:143)
  1104. [2017-10-11 14:18:57,978] INFO ProducerConfig values:
  1105. acks = 1
  1106. batch.size = 32768
  1107. bootstrap.servers = [172.26.18.214:8082]
  1108. buffer.memory = 1048576
  1109. client.id = inventory-connector-dbhistory
  1110. compression.type = none
  1111. connections.max.idle.ms = 540000
  1112. enable.idempotence = false
  1113. interceptor.classes = null
  1114. key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  1115. linger.ms = 0
  1116. max.block.ms = 60000
  1117. max.in.flight.requests.per.connection = 5
  1118. max.request.size = 1048576
  1119. metadata.max.age.ms = 300000
  1120. metric.reporters = []
  1121. metrics.num.samples = 2
  1122. metrics.recording.level = INFO
  1123. metrics.sample.window.ms = 30000
  1124. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  1125. receive.buffer.bytes = 32768
  1126. reconnect.backoff.max.ms = 1000
  1127. reconnect.backoff.ms = 50
  1128. request.timeout.ms = 30000
  1129. retries = 1
  1130. retry.backoff.ms = 100
  1131. sasl.jaas.config = null
  1132. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1133. sasl.kerberos.min.time.before.relogin = 60000
  1134. sasl.kerberos.service.name = null
  1135. sasl.kerberos.ticket.renew.jitter = 0.05
  1136. sasl.kerberos.ticket.renew.window.factor = 0.8
  1137. sasl.mechanism = GSSAPI
  1138. security.protocol = SSL
  1139. send.buffer.bytes = 131072
  1140. ssl.cipher.suites = null
  1141. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1142. ssl.endpoint.identification.algorithm = null
  1143. ssl.key.password = [hidden]
  1144. ssl.keymanager.algorithm = SunX509
  1145. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1146. ssl.keystore.password = [hidden]
  1147. ssl.keystore.type = JKS
  1148. ssl.protocol = TLS
  1149. ssl.provider = null
  1150. ssl.secure.random.implementation = null
  1151. ssl.trustmanager.algorithm = PKIX
  1152. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1153. ssl.truststore.password = [hidden]
  1154. ssl.truststore.type = JKS
  1155. transaction.timeout.ms = 60000
  1156. transactional.id = null
  1157. value.serializer = class org.apache.kafka.common.serialization.StringSerializer
  1158. (org.apache.kafka.clients.producer.ProducerConfig:223)
  1159. [2017-10-11 14:18:57,981] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1160. [2017-10-11 14:18:57,981] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1161. [2017-10-11 14:18:58,319] INFO Found existing offset: {ts_sec=1507701947, file=mysql-bin.000087, pos=827, gtids=bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847, server_id=1, event=5} (io.debezium.connector.mysql.MySqlConnectorTask:77)
  1162. [2017-10-11 14:18:58,346] INFO ConsumerConfig values:
  1163. auto.commit.interval.ms = 5000
  1164. auto.offset.reset = earliest
  1165. bootstrap.servers = [172.26.18.214:8082]
  1166. check.crcs = true
  1167. client.id = inventory-connector-dbhistory
  1168. connections.max.idle.ms = 540000
  1169. enable.auto.commit = false
  1170. exclude.internal.topics = true
  1171. fetch.max.bytes = 52428800
  1172. fetch.max.wait.ms = 500
  1173. fetch.min.bytes = 1
  1174. group.id = inventory-connector-dbhistory
  1175. heartbeat.interval.ms = 3000
  1176. interceptor.classes = null
  1177. internal.leave.group.on.close = true
  1178. isolation.level = read_uncommitted
  1179. key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  1180. max.partition.fetch.bytes = 1048576
  1181. max.poll.interval.ms = 300000
  1182. max.poll.records = 500
  1183. metadata.max.age.ms = 300000
  1184. metric.reporters = []
  1185. metrics.num.samples = 2
  1186. metrics.recording.level = INFO
  1187. metrics.sample.window.ms = 30000
  1188. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  1189. receive.buffer.bytes = 65536
  1190. reconnect.backoff.max.ms = 1000
  1191. reconnect.backoff.ms = 50
  1192. request.timeout.ms = 305000
  1193. retry.backoff.ms = 100
  1194. sasl.jaas.config = null
  1195. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1196. sasl.kerberos.min.time.before.relogin = 60000
  1197. sasl.kerberos.service.name = null
  1198. sasl.kerberos.ticket.renew.jitter = 0.05
  1199. sasl.kerberos.ticket.renew.window.factor = 0.8
  1200. sasl.mechanism = GSSAPI
  1201. security.protocol = SSL
  1202. send.buffer.bytes = 131072
  1203. session.timeout.ms = 10000
  1204. ssl.cipher.suites = null
  1205. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1206. ssl.endpoint.identification.algorithm = null
  1207. ssl.key.password = [hidden]
  1208. ssl.keymanager.algorithm = SunX509
  1209. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1210. ssl.keystore.password = [hidden]
  1211. ssl.keystore.type = JKS
  1212. ssl.protocol = TLS
  1213. ssl.provider = null
  1214. ssl.secure.random.implementation = null
  1215. ssl.trustmanager.algorithm = PKIX
  1216. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1217. ssl.truststore.password = [hidden]
  1218. ssl.truststore.type = JKS
  1219. value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  1220. (org.apache.kafka.clients.consumer.ConsumerConfig:223)
  1221. [2017-10-11 14:18:58,349] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1222. [2017-10-11 14:18:58,349] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1223. [2017-10-11 14:18:58,379] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group inventory-connector-dbhistory. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  1224. [2017-10-11 14:18:58,381] INFO Revoking previously assigned partitions [] for group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:419)
  1225. [2017-10-11 14:18:58,381] INFO (Re-)joining group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  1226. [2017-10-11 14:18:58,395] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1187)
  1227. [2017-10-11 14:18:58,396] INFO 172.31.14.199 - - [11/十月/2017:06:18:57 +0000] "DELETE /connectors/inventory-connector HTTP/1.1" 204 - 521 (org.apache.kafka.connect.runtime.rest.RestServer:60)
  1228. [2017-10-11 14:18:58,397] INFO Stopping connector inventory-connector (org.apache.kafka.connect.runtime.Worker:301)
  1229. [2017-10-11 14:18:58,397] INFO Stopping task inventory-connector-0 (org.apache.kafka.connect.runtime.Worker:447)
  1230. [2017-10-11 14:18:58,398] INFO Stopped connector inventory-connector (org.apache.kafka.connect.runtime.Worker:317)
  1231. [2017-10-11 14:18:58,411] INFO Successfully joined group inventory-connector-dbhistory with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  1232. [2017-10-11 14:18:58,413] INFO Setting newly assigned partitions [dbhistory.mysqlmaster-2, dbhistory.mysqlmaster-1, dbhistory.mysqlmaster-0] for group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:262)
  1233. [2017-10-11 14:18:58,905] INFO MySQL current GTID set bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5850 does contain the GTID set required by the connector bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlConnectorTask:267)
  1234. [2017-10-11 14:18:58,938] INFO Attempting to generate a filtered GTID set (io.debezium.connector.mysql.MySqlTaskContext:269)
  1235. [2017-10-11 14:18:58,938] INFO GTID set from previous recorded offset: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlTaskContext:270)
  1236. [2017-10-11 14:18:58,939] INFO GTID set available on server: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5850 (io.debezium.connector.mysql.MySqlTaskContext:277)
  1237. [2017-10-11 14:18:58,939] INFO Final merged GTID set to use when connecting to MySQL: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlTaskContext:279)
  1238. [2017-10-11 14:18:58,939] INFO Registering binlog reader with GTID set: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.BinlogReader:179)
  1239. [2017-10-11 14:18:59,032] INFO Connected to MySQL binlog at 172.26.18.213:3306, starting at GTIDs bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 and binlog file 'mysql-bin.000087', pos=827, skipping 5 events plus 0 rows (io.debezium.connector.mysql.BinlogReader:697)
  1240. [2017-10-11 14:18:59,033] INFO Source task WorkerSourceTask{id=inventory-connector-0} finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:143)
  1241. [2017-10-11 14:18:59,033] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:218)
  1242. [2017-10-11 14:18:59,033] INFO Stopping the binlog reader (io.debezium.connector.mysql.ChainedReader:95)
  1243. [2017-10-11 14:18:59,035] INFO Stopped reading binlog after 0 events, no new offset was recorded (io.debezium.connector.mysql.BinlogReader:686)
  1244. [2017-10-11 14:18:59,036] INFO Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:972)
  1245. [2017-10-11 14:18:59,040] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask:241)
  1246. [2017-10-11 14:18:59,040] INFO Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:972)
  1247. [2017-10-11 14:18:59,045] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217)
  1248. [2017-10-11 14:18:59,045] INFO (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  1249. [2017-10-11 14:18:59,048] INFO Successfully joined group connect-cluster with generation 36 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  1250. [2017-10-11 14:18:59,048] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-a2612a99-3fdd-4427-99ea-19667929bdd4', leaderUrl='http://172.26.18.214:8086/', offset=109, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1166)
  1251. [2017-10-11 14:18:59,049] INFO Starting connectors and tasks using config offset 109 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:815)
  1252. [2017-10-11 14:18:59,049] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:825)
  1253. [2017-10-11 14:19:03,861] INFO Successfully tested connection for jdbc:mysql://172.26.18.213:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=convertToNull with user 'kafka-connector' (io.debezium.connector.mysql.MySqlConnector:98)
  1254. [2017-10-11 14:19:03,866] INFO Connector inventory-connector config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1056)
  1255. [2017-10-11 14:19:04,367] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1187)
  1256. [2017-10-11 14:19:04,367] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217)
  1257. [2017-10-11 14:19:04,367] INFO (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  1258. [2017-10-11 14:19:04,369] INFO 172.31.14.199 - - [11/十月/2017:06:19:03 +0000] "POST /connectors/ HTTP/1.1" 201 2195 525 (org.apache.kafka.connect.runtime.rest.RestServer:60)
  1259. [2017-10-11 14:19:04,370] INFO Successfully joined group connect-cluster with generation 37 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  1260. [2017-10-11 14:19:04,370] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-a2612a99-3fdd-4427-99ea-19667929bdd4', leaderUrl='http://172.26.18.214:8086/', offset=110, connectorIds=[inventory-connector], taskIds=[inventory-connector-0]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1166)
  1261. [2017-10-11 14:19:04,371] INFO Starting connectors and tasks using config offset 110 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:815)
  1262. [2017-10-11 14:19:04,371] INFO Starting connector inventory-connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868)
  1263. [2017-10-11 14:19:04,371] INFO Starting task inventory-connector-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:829)
  1264. [2017-10-11 14:19:04,371] INFO Creating task inventory-connector-0 (org.apache.kafka.connect.runtime.Worker:358)
  1265. [2017-10-11 14:19:04,371] INFO ConnectorConfig values:
  1266. connector.class = io.debezium.connector.mysql.MySqlConnector
  1267. key.converter = null
  1268. name = inventory-connector
  1269. tasks.max = 1
  1270. transforms = null
  1271. value.converter = null
  1272. (org.apache.kafka.connect.runtime.ConnectorConfig:223)
  1273. [2017-10-11 14:19:04,372] INFO ConnectorConfig values:
  1274. connector.class = io.debezium.connector.mysql.MySqlConnector
  1275. key.converter = null
  1276. name = inventory-connector
  1277. tasks.max = 1
  1278. transforms = null
  1279. value.converter = null
  1280. (org.apache.kafka.connect.runtime.ConnectorConfig:223)
  1281. [2017-10-11 14:19:04,372] INFO EnrichedConnectorConfig values:
  1282. connector.class = io.debezium.connector.mysql.MySqlConnector
  1283. key.converter = null
  1284. name = inventory-connector
  1285. tasks.max = 1
  1286. transforms = null
  1287. value.converter = null
  1288. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1289. [2017-10-11 14:19:04,372] INFO EnrichedConnectorConfig values:
  1290. connector.class = io.debezium.connector.mysql.MySqlConnector
  1291. key.converter = null
  1292. name = inventory-connector
  1293. tasks.max = 1
  1294. transforms = null
  1295. value.converter = null
  1296. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1297. [2017-10-11 14:19:04,372] INFO Creating connector inventory-connector of type io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:204)
  1298. [2017-10-11 14:19:04,372] INFO TaskConfig values:
  1299. task.class = class io.debezium.connector.mysql.MySqlConnectorTask
  1300. (org.apache.kafka.connect.runtime.TaskConfig:223)
  1301. [2017-10-11 14:19:04,372] INFO Instantiated task inventory-connector-0 with version 0.6.0 of type io.debezium.connector.mysql.MySqlConnectorTask (org.apache.kafka.connect.runtime.Worker:373)
  1302. [2017-10-11 14:19:04,372] INFO Instantiated connector inventory-connector with version 0.6.0 of type class io.debezium.connector.mysql.MySqlConnector (org.apache.kafka.connect.runtime.Worker:207)
  1303. [2017-10-11 14:19:04,373] INFO ProducerConfig values:
  1304. acks = all
  1305. batch.size = 16384
  1306. bootstrap.servers = [kafka-broker-1:8082, kafka-broker-2:8083, kafka-broker-3:8084]
  1307. buffer.memory = 33554432
  1308. client.id =
  1309. compression.type = none
  1310. connections.max.idle.ms = 540000
  1311. enable.idempotence = false
  1312. interceptor.classes = null
  1313. key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1314. linger.ms = 0
  1315. max.block.ms = 9223372036854775807
  1316. max.in.flight.requests.per.connection = 1
  1317. max.request.size = 1048576
  1318. metadata.max.age.ms = 300000
  1319. metric.reporters = []
  1320. metrics.num.samples = 2
  1321. metrics.recording.level = INFO
  1322. metrics.sample.window.ms = 30000
  1323. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  1324. receive.buffer.bytes = 32768
  1325. reconnect.backoff.max.ms = 1000
  1326. reconnect.backoff.ms = 50
  1327. request.timeout.ms = 2147483647
  1328. retries = 2147483647
  1329. retry.backoff.ms = 100
  1330. sasl.jaas.config = null
  1331. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1332. sasl.kerberos.min.time.before.relogin = 60000
  1333. sasl.kerberos.service.name = null
  1334. sasl.kerberos.ticket.renew.jitter = 0.05
  1335. sasl.kerberos.ticket.renew.window.factor = 0.8
  1336. sasl.mechanism = GSSAPI
  1337. security.protocol = SSL
  1338. send.buffer.bytes = 131072
  1339. ssl.cipher.suites = null
  1340. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1341. ssl.endpoint.identification.algorithm = null
  1342. ssl.key.password = [hidden]
  1343. ssl.keymanager.algorithm = SunX509
  1344. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1345. ssl.keystore.password = [hidden]
  1346. ssl.keystore.type = JKS
  1347. ssl.protocol = TLS
  1348. ssl.provider = null
  1349. ssl.secure.random.implementation = null
  1350. ssl.trustmanager.algorithm = PKIX
  1351. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1352. ssl.truststore.password = [hidden]
  1353. ssl.truststore.type = JKS
  1354. transaction.timeout.ms = 60000
  1355. transactional.id = null
  1356. value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
  1357. (org.apache.kafka.clients.producer.ProducerConfig:223)
  1358. [2017-10-11 14:19:04,373] INFO Finished creating connector inventory-connector (org.apache.kafka.connect.runtime.Worker:225)
  1359. [2017-10-11 14:19:04,373] INFO SourceConnectorConfig values:
  1360. connector.class = io.debezium.connector.mysql.MySqlConnector
  1361. key.converter = null
  1362. name = inventory-connector
  1363. tasks.max = 1
  1364. transforms = null
  1365. value.converter = null
  1366. (org.apache.kafka.connect.runtime.SourceConnectorConfig:223)
  1367. [2017-10-11 14:19:04,374] INFO EnrichedConnectorConfig values:
  1368. connector.class = io.debezium.connector.mysql.MySqlConnector
  1369. key.converter = null
  1370. name = inventory-connector
  1371. tasks.max = 1
  1372. transforms = null
  1373. value.converter = null
  1374. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  1375. [2017-10-11 14:19:04,378] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1376. [2017-10-11 14:19:04,378] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1377. [2017-10-11 14:19:04,379] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:825)
  1378. [2017-10-11 14:19:04,384] INFO KafkaDatabaseHistory Consumer config: {security.protocol=SSL, enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=inventory-connector-dbhistory, auto.offset.reset=earliest, ssl.truststore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, ssl.keystore.password=********, session.timeout.ms=10000, bootstrap.servers=172.26.18.214:8082, ssl.truststore.password=********, ssl.keystore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, client.id=inventory-connector-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1, ssl.key.password=********} (io.debezium.relational.history.KafkaDatabaseHistory:142)
  1379. [2017-10-11 14:19:04,384] INFO KafkaDatabaseHistory Producer config: {security.protocol=SSL, ssl.keystore.password=********, ssl.truststore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, bootstrap.servers=172.26.18.214:8082, ssl.truststore.password=********, value.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.keystore.location=/home/test/private/ssl/kafka3/kafka.client.keystore.jks, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, linger.ms=0, client.id=inventory-connector-dbhistory, batch.size=32768, acks=1, ssl.key.password=********} (io.debezium.relational.history.KafkaDatabaseHistory:143)
  1380. [2017-10-11 14:19:04,384] INFO ProducerConfig values:
  1381. acks = 1
  1382. batch.size = 32768
  1383. bootstrap.servers = [172.26.18.214:8082]
  1384. buffer.memory = 1048576
  1385. client.id = inventory-connector-dbhistory
  1386. compression.type = none
  1387. connections.max.idle.ms = 540000
  1388. enable.idempotence = false
  1389. interceptor.classes = null
  1390. key.serializer = class org.apache.kafka.common.serialization.StringSerializer
  1391. linger.ms = 0
  1392. max.block.ms = 60000
  1393. max.in.flight.requests.per.connection = 5
  1394. max.request.size = 1048576
  1395. metadata.max.age.ms = 300000
  1396. metric.reporters = []
  1397. metrics.num.samples = 2
  1398. metrics.recording.level = INFO
  1399. metrics.sample.window.ms = 30000
  1400. partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
  1401. receive.buffer.bytes = 32768
  1402. reconnect.backoff.max.ms = 1000
  1403. reconnect.backoff.ms = 50
  1404. request.timeout.ms = 30000
  1405. retries = 1
  1406. retry.backoff.ms = 100
  1407. sasl.jaas.config = null
  1408. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1409. sasl.kerberos.min.time.before.relogin = 60000
  1410. sasl.kerberos.service.name = null
  1411. sasl.kerberos.ticket.renew.jitter = 0.05
  1412. sasl.kerberos.ticket.renew.window.factor = 0.8
  1413. sasl.mechanism = GSSAPI
  1414. security.protocol = SSL
  1415. send.buffer.bytes = 131072
  1416. ssl.cipher.suites = null
  1417. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1418. ssl.endpoint.identification.algorithm = null
  1419. ssl.key.password = [hidden]
  1420. ssl.keymanager.algorithm = SunX509
  1421. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1422. ssl.keystore.password = [hidden]
  1423. ssl.keystore.type = JKS
  1424. ssl.protocol = TLS
  1425. ssl.provider = null
  1426. ssl.secure.random.implementation = null
  1427. ssl.trustmanager.algorithm = PKIX
  1428. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1429. ssl.truststore.password = [hidden]
  1430. ssl.truststore.type = JKS
  1431. transaction.timeout.ms = 60000
  1432. transactional.id = null
  1433. value.serializer = class org.apache.kafka.common.serialization.StringSerializer
  1434. (org.apache.kafka.clients.producer.ProducerConfig:223)
  1435. [2017-10-11 14:19:04,388] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1436. [2017-10-11 14:19:04,388] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1437. [2017-10-11 14:19:04,841] INFO Found existing offset: {ts_sec=1507701947, file=mysql-bin.000087, pos=827, gtids=bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847, server_id=1, event=5} (io.debezium.connector.mysql.MySqlConnectorTask:77)
  1438. [2017-10-11 14:19:04,852] INFO ConsumerConfig values:
  1439. auto.commit.interval.ms = 5000
  1440. auto.offset.reset = earliest
  1441. bootstrap.servers = [172.26.18.214:8082]
  1442. check.crcs = true
  1443. client.id = inventory-connector-dbhistory
  1444. connections.max.idle.ms = 540000
  1445. enable.auto.commit = false
  1446. exclude.internal.topics = true
  1447. fetch.max.bytes = 52428800
  1448. fetch.max.wait.ms = 500
  1449. fetch.min.bytes = 1
  1450. group.id = inventory-connector-dbhistory
  1451. heartbeat.interval.ms = 3000
  1452. interceptor.classes = null
  1453. internal.leave.group.on.close = true
  1454. isolation.level = read_uncommitted
  1455. key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  1456. max.partition.fetch.bytes = 1048576
  1457. max.poll.interval.ms = 300000
  1458. max.poll.records = 500
  1459. metadata.max.age.ms = 300000
  1460. metric.reporters = []
  1461. metrics.num.samples = 2
  1462. metrics.recording.level = INFO
  1463. metrics.sample.window.ms = 30000
  1464. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  1465. receive.buffer.bytes = 65536
  1466. reconnect.backoff.max.ms = 1000
  1467. reconnect.backoff.ms = 50
  1468. request.timeout.ms = 305000
  1469. retry.backoff.ms = 100
  1470. sasl.jaas.config = null
  1471. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  1472. sasl.kerberos.min.time.before.relogin = 60000
  1473. sasl.kerberos.service.name = null
  1474. sasl.kerberos.ticket.renew.jitter = 0.05
  1475. sasl.kerberos.ticket.renew.window.factor = 0.8
  1476. sasl.mechanism = GSSAPI
  1477. security.protocol = SSL
  1478. send.buffer.bytes = 131072
  1479. session.timeout.ms = 10000
  1480. ssl.cipher.suites = null
  1481. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  1482. ssl.endpoint.identification.algorithm = null
  1483. ssl.key.password = [hidden]
  1484. ssl.keymanager.algorithm = SunX509
  1485. ssl.keystore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1486. ssl.keystore.password = [hidden]
  1487. ssl.keystore.type = JKS
  1488. ssl.protocol = TLS
  1489. ssl.provider = null
  1490. ssl.secure.random.implementation = null
  1491. ssl.trustmanager.algorithm = PKIX
  1492. ssl.truststore.location = /home/test/private/ssl/kafka3/kafka.client.keystore.jks
  1493. ssl.truststore.password = [hidden]
  1494. ssl.truststore.type = JKS
  1495. value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  1496. (org.apache.kafka.clients.consumer.ConsumerConfig:223)
  1497. [2017-10-11 14:19:04,856] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser:83)
  1498. [2017-10-11 14:19:04,856] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser:84)
  1499. [2017-10-11 14:19:04,887] INFO Discovered coordinator 172.26.18.214:8084 (id: 2147483644 rack: null) for group inventory-connector-dbhistory. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:597)
  1500. [2017-10-11 14:19:04,889] INFO Revoking previously assigned partitions [] for group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:419)
  1501. [2017-10-11 14:19:04,889] INFO (Re-)joining group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  1502. [2017-10-11 14:19:04,917] INFO Successfully joined group inventory-connector-dbhistory with generation 3 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  1503. [2017-10-11 14:19:04,917] INFO Setting newly assigned partitions [dbhistory.mysqlmaster-2, dbhistory.mysqlmaster-1, dbhistory.mysqlmaster-0] for group inventory-connector-dbhistory (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:262)
  1504. [2017-10-11 14:19:05,390] INFO MySQL current GTID set bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5850 does contain the GTID set required by the connector bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlConnectorTask:267)
  1505. [2017-10-11 14:19:05,394] INFO Attempting to generate a filtered GTID set (io.debezium.connector.mysql.MySqlTaskContext:269)
  1506. [2017-10-11 14:19:05,394] INFO GTID set from previous recorded offset: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlTaskContext:270)
  1507. [2017-10-11 14:19:05,394] INFO GTID set available on server: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5850 (io.debezium.connector.mysql.MySqlTaskContext:277)
  1508. [2017-10-11 14:19:05,395] INFO Final merged GTID set to use when connecting to MySQL: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.MySqlTaskContext:279)
  1509. [2017-10-11 14:19:05,395] INFO Registering binlog reader with GTID set: bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 (io.debezium.connector.mysql.BinlogReader:179)
  1510. [2017-10-11 14:19:05,480] INFO Connected to MySQL binlog at 172.26.18.213:3306, starting at GTIDs bf4621fb-d242-11e6-8e9f-1866daecd09c:1-5847 and binlog file 'mysql-bin.000087', pos=827, skipping 5 events plus 0 rows (io.debezium.connector.mysql.BinlogReader:697)
  1511. [2017-10-11 14:19:05,480] INFO Source task WorkerSourceTask{id=inventory-connector-0} finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:143)
  1512. [2017-10-11 14:19:14,459] INFO Finished WorkerSourceTask{id=inventory-connector-0} commitOffsets successfully in 80 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:373)
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!