API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Apr 24th, 2018
263
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 26.72 KB | None | 0 0
raw download clone embed print report
  1. bootstrap.servers=localhost:9092
  2. key.converter=org.apache.kafka.connect.json.JsonConverter
  3. key.converter.schemas.enable=true
  4. value.converter=org.apache.kafka.connect.json.JsonConverter
  5. value.converter.schemas.enable=true
  6. key.converter=io.confluent.connect.avro.AvroConverter
  7. key.converter.schema.registry.url=http://localhost:8081
  8. value.converter=io.confluent.connect.avro.AvroConverter
  9. value.converter.schema.registry.url=http://localhost:8081
  10. internal.key.converter=org.apache.kafka.connect.json.JsonConverter
  11. internal.value.converter=org.apache.kafka.connect.json.JsonConverter
  12. internal.key.converter.schemas.enable=false
  13. internal.value.converter.schemas.enable=false
  14. offset.storage.file.filename=/tmp/connect.offsets
  15. rest.port=8084
  16. plugin.path=/confluent-4.1.0/share/java
  17.  
  18. name=XXX_SOURCE
  19. connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
  20. tasks.max=10
  21. batch.max.rows=1000
  22. connection.url=jdbc:as400://<IP>;<DATABASE>;
  23. connection.user=<USER>
  24. connection.password=<PASSWORD>
  25. query=SELECT * FROM (SELECT c.*, TIMESTAMP_FORMAT(cast(mod(CAST(MSDAST AS INT),10000) * 10000 + CAST(MSDAST AS INT) / 1000000 * 100 + mod(CAST(MSDAST AS INT) / 10000, 100) AS varchar(30)) || ' ' || CASE WHEN CAST(MSTIST AS INT) / 10000 >= 10 THEN cast(CAST(MSTIST AS INT) / 10000 AS varchar(30)) ELSE '0' || cast(CAST(MSTIST AS INT) / 10000 AS varchar(30)) END || right(cast(mod(CAST(MSTIST AS INT), 100000) AS varchar(30)),4),'YYYYMMDD HH24MISS') AS DATEADDED FROM <DATABASE>.<TABLE> c) d
  26. mode=timestamp
  27. timestamp.column.name=DATEADDED
  28. topic.prefix=XXX_TOPIC
  29. poll.interval.ms=60000
  30.  
  31. bin]$ sudo ./connect-standalone /kafka/salesforce-schema.properties /kafka/crmmastp.properties
  32. [2018-04-24 16:11:06,301] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:67)
  33. (org.apache.kafka.connect.runtime.WorkerInfo:71)
  34. [2018-04-24 16:11:06,315] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:76)
  35. [2018-04-24 16:11:06,333] INFO Loading plugin from: /confluent-4.1.0/share/java/confluent-control-center (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  36. [2018-04-24 16:11:08,282] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/confluent-control-center/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  37. [2018-04-24 16:11:08,298] INFO Loading plugin from: /confluent-4.1.0/share/java/schema-registry (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  38. [2018-04-24 16:11:09,110] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/schema-registry/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  39. [2018-04-24 16:11:09,122] INFO Loading plugin from: /confluent-4.1.0/share/java/confluent-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  40. [2018-04-24 16:11:09,175] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/confluent-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  41. [2018-04-24 16:11:09,176] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-ibmmq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  42. [2018-04-24 16:11:09,268] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-ibmmq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  43. [2018-04-24 16:11:09,269] INFO Added plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  44. [2018-04-24 16:11:09,269] INFO Added plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  45. [2018-04-24 16:11:09,269] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-storage-common (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  46. [2018-04-24 16:11:11,966] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-storage-common/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  47. [2018-04-24 16:11:11,966] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  48. [2018-04-24 16:11:11,966] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  49. [2018-04-24 16:11:12,110] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  50. [2018-04-24 16:11:14,672] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  51. [2018-04-24 16:11:14,672] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  52. [2018-04-24 16:11:14,706] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  53. [2018-04-24 16:11:15,672] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  54. [2018-04-24 16:11:15,672] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  55. [2018-04-24 16:11:15,672] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  56. [2018-04-24 16:11:15,679] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-rest (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  57. [2018-04-24 16:11:16,218] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-rest/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  58. [2018-04-24 16:11:16,224] INFO Loading plugin from: /confluent-4.1.0/share/java/confluent-support-metrics (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  59. [2018-04-24 16:11:16,286] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/confluent-support-metrics/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  60. [2018-04-24 16:11:16,287] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-replicator (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  61. [2018-04-24 16:11:16,735] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-replicator/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  62. [2018-04-24 16:11:16,735] INFO Added plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  63. [2018-04-24 16:11:16,735] INFO Added plugin 'io.confluent.connect.replicator.util.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  64. [2018-04-24 16:11:16,735] INFO Loading plugin from: /confluent-4.1.0/share/java/confluent-security (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  65. [2018-04-24 16:11:16,736] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/confluent-security/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  66. [2018-04-24 16:11:16,736] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-serde-tools (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  67. [2018-04-24 16:11:16,828] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-serde-tools/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  68. [2018-04-24 16:11:16,829] INFO Loading plugin from: /confluent-4.1.0/share/java/ksql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  69. [2018-04-24 16:11:17,714] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/ksql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  70. [2018-04-24 16:11:17,723] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  71. [2018-04-24 16:11:19,648] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  72. [2018-04-24 16:11:19,649] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  73. [2018-04-24 16:11:19,649] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  74. [2018-04-24 16:11:19,688] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-jms (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  75. [2018-04-24 16:11:19,798] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-jms/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  76. [2018-04-24 16:11:19,799] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  77. [2018-04-24 16:11:19,934] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  78. [2018-04-24 16:11:19,934] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  79. [2018-04-24 16:11:19,936] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  80. [2018-04-24 16:11:20,290] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  81. [2018-04-24 16:11:20,290] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  82. [2018-04-24 16:11:20,290] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  83. [2018-04-24 16:11:20,333] INFO Loading plugin from: /confluent-4.1.0/share/java/confluent-rebalancer (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  84. [2018-04-24 16:11:21,037] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/confluent-rebalancer/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  85. [2018-04-24 16:11:21,051] INFO Loading plugin from: /confluent-4.1.0/share/java/monitoring-interceptors (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  86. [2018-04-24 16:11:21,254] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/monitoring-interceptors/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  87. [2018-04-24 16:11:21,255] INFO Loading plugin from: /confluent-4.1.0/share/java/camus (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  88. [2018-04-24 16:11:21,691] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/camus/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  89. [2018-04-24 16:11:21,699] INFO Loading plugin from: /confluent-4.1.0/share/java/kafka-connect-activemq (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  90. [2018-04-24 16:11:21,785] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/kafka-connect-activemq/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  91. [2018-04-24 16:11:21,785] INFO Added plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
  92. [2018-04-24 16:11:21,786] INFO Loading plugin from: /confluent-4.1.0/share/java/rest-utils (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
  93. [2018-04-24 16:11:21,907] INFO Registered loader: PluginClassLoader{pluginLocation=file:/confluent-4.1.0/share/java/rest-utils/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  94. [2018-04-24 16:11:24,179] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
  95. [2018-04-24 16:11:24,180] INFO Added aliases 'ActiveMQSourceConnector' and 'ActiveMQSource' to plugin 'io.confluent.connect.activemq.ActiveMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  96. [2018-04-24 16:11:24,181] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  97. [2018-04-24 16:11:24,181] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  98. [2018-04-24 16:11:24,181] INFO Added aliases 'IbmMQSourceConnector' and 'IbmMQSource' to plugin 'io.confluent.connect.ibm.mq.IbmMQSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  99. [2018-04-24 16:11:24,181] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  100. [2018-04-24 16:11:24,181] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  101. [2018-04-24 16:11:24,182] INFO Added aliases 'JmsSourceConnector' and 'JmsSource' to plugin 'io.confluent.connect.jms.JmsSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  102. [2018-04-24 16:11:24,182] INFO Added aliases 'ReplicatorSourceConnector' and 'ReplicatorSource' to plugin 'io.confluent.connect.replicator.ReplicatorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  103. [2018-04-24 16:11:24,182] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  104. [2018-04-24 16:11:24,182] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  105. [2018-04-24 16:11:24,183] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  106. [2018-04-24 16:11:24,183] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  107. [2018-04-24 16:11:24,183] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  108. [2018-04-24 16:11:24,183] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  109. [2018-04-24 16:11:24,186] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  110. [2018-04-24 16:11:24,186] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  111. [2018-04-24 16:11:24,186] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  112. [2018-04-24 16:11:24,186] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  113. [2018-04-24 16:11:24,187] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  114. [2018-04-24 16:11:24,187] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  115. [2018-04-24 16:11:24,187] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
  116. [2018-04-24 16:11:24,187] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
  117. [2018-04-24 16:11:24,188] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
  118. [2018-04-24 16:11:24,188] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
  119. [2018-04-24 16:11:24,189] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
  120. [2018-04-24 16:11:24,202] INFO StandaloneConfig values:
  121. access.control.allow.methods =
  122. access.control.allow.origin =
  123. bootstrap.servers = [localhost:9092]
  124. header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
  125. internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
  126. internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
  127. key.converter = class io.confluent.connect.avro.AvroConverter
  128. listeners = null
  129. metric.reporters = []
  130. metrics.num.samples = 2
  131. metrics.recording.level = INFO
  132. metrics.sample.window.ms = 30000
  133. offset.flush.interval.ms = 60000
  134. offset.flush.timeout.ms = 5000
  135. offset.storage.file.filename = /tmp/connect.offsets
  136. plugin.path = [/confluent-4.1.0/share/java]
  137. rest.advertised.host.name = null
  138. rest.advertised.listener = null
  139. rest.advertised.port = null
  140. rest.host.name = null
  141. rest.port = 8084
  142. ssl.client.auth = none
  143. task.shutdown.graceful.timeout.ms = 5000
  144. value.converter = class io.confluent.connect.avro.AvroConverter
  145. (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:279)
  146. [2018-04-24 16:11:24,202] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
  147. [2018-04-24 16:11:24,208] INFO AdminClientConfig values:
  148. bootstrap.servers = [localhost:9092]
  149. client.id =
  150. connections.max.idle.ms = 300000
  151. metadata.max.age.ms = 300000
  152. metric.reporters = []
  153. metrics.num.samples = 2
  154. metrics.recording.level = INFO
  155. metrics.sample.window.ms = 30000
  156. receive.buffer.bytes = 65536
  157. reconnect.backoff.max.ms = 1000
  158. reconnect.backoff.ms = 50
  159. request.timeout.ms = 120000
  160. retries = 5
  161. retry.backoff.ms = 100
  162. sasl.jaas.config = null
  163. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  164. sasl.kerberos.min.time.before.relogin = 60000
  165. sasl.kerberos.service.name = null
  166. sasl.kerberos.ticket.renew.jitter = 0.05
  167. sasl.kerberos.ticket.renew.window.factor = 0.8
  168. sasl.mechanism = GSSAPI
  169. security.protocol = PLAINTEXT
  170. send.buffer.bytes = 131072
  171. ssl.cipher.suites = null
  172. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  173. ssl.endpoint.identification.algorithm = null
  174. ssl.key.password = null
  175. ssl.keymanager.algorithm = SunX509
  176. ssl.keystore.location = null
  177. ssl.keystore.password = null
  178. ssl.keystore.type = JKS
  179. ssl.protocol = TLS
  180. ssl.provider = null
  181. ssl.secure.random.implementation = null
  182. ssl.trustmanager.algorithm = PKIX
  183. ssl.truststore.location = null
  184. ssl.truststore.password = null
  185. ssl.truststore.type = JKS
  186. (org.apache.kafka.clients.admin.AdminClientConfig:279)
  187. [2018-04-24 16:11:24,291] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  188. [2018-04-24 16:11:24,292] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  189. [2018-04-24 16:11:24,292] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  190. [2018-04-24 16:11:24,292] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  191. [2018-04-24 16:11:24,292] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  192. [2018-04-24 16:11:24,292] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  193. [2018-04-24 16:11:24,294] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  194. [2018-04-24 16:11:24,294] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  195. [2018-04-24 16:11:24,294] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  196. [2018-04-24 16:11:24,294] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  197. [2018-04-24 16:11:24,294] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  198. [2018-04-24 16:11:24,294] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  199. [2018-04-24 16:11:24,294] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
  200. [2018-04-24 16:11:24,295] INFO Kafka version : 1.1.0-cp1 (org.apache.kafka.common.utils.AppInfoParser:109)
  201. [2018-04-24 16:11:24,295] INFO Kafka commitId : 93e03414f72c2485 (org.apache.kafka.common.utils.AppInfoParser:110)
  202. [2018-04-24 16:11:24,498] INFO Cluster ID: 7_19QWuYTY-rSypibzffYg (org.apache.kafka.clients.Metadata:265)
  203. [2018-04-24 16:11:24,503] INFO Kafka cluster ID: 7_19QWuYTY-rSypibzffYg (org.apache.kafka.connect.util.ConnectUtils:59)
  204. [2018-04-24 16:11:24,520] INFO Logging initialized @18849ms (org.eclipse.jetty.util.log:186)
  205. [2018-04-24 16:11:24,546] INFO Added connector for http://:8084 (org.apache.kafka.connect.runtime.rest.RestServer:110)
  206. [2018-04-24 16:11:24,976] INFO Advertised URI: http://192.168.217.92:8084/ (org.apache.kafka.connect.runtime.rest.RestServer:248)
  207. [2018-04-24 16:11:24,981] INFO Kafka version : 1.1.0-cp1 (org.apache.kafka.common.utils.AppInfoParser:109)
  208. [2018-04-24 16:11:24,981] INFO Kafka commitId : 93e03414f72c2485 (org.apache.kafka.common.utils.AppInfoParser:110)
  209. [2018-04-24 16:11:25,086] INFO JsonConverterConfig values:
  210. converter.type = key
  211. schemas.cache.size = 1000
  212. schemas.enable = false
  213. (org.apache.kafka.connect.json.JsonConverterConfig:279)
  214. [2018-04-24 16:11:25,087] INFO JsonConverterConfig values:
  215. converter.type = value
  216. schemas.cache.size = 1000
  217. schemas.enable = false
  218. (org.apache.kafka.connect.json.JsonConverterConfig:279)
  219. [2018-04-24 16:11:25,094] INFO Kafka Connect standalone worker initialization took 18791ms (org.apache.kafka.connect.cli.ConnectStandalone:92)
  220. [2018-04-24 16:11:25,094] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:49)
  221. [2018-04-24 16:11:25,094] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)
  222. [2018-04-24 16:11:25,094] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:139)
  223. [2018-04-24 16:11:25,094] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:59)
  224. [2018-04-24 16:11:25,098] INFO Worker started (org.apache.kafka.connect.runtime.Worker:144)
  225. [2018-04-24 16:11:25,098] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)
  226. [2018-04-24 16:11:25,099] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:155)
  227. [2018-04-24 16:11:25,186] INFO jetty-9.2.24.v20180105 (org.eclipse.jetty.server.Server:327)
  228. Apr 24, 2018 4:11:25 PM org.glassfish.jersey.internal.Errors logErrors
  229. WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
  230. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
  231. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
  232. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
  233. [2018-04-24 16:11:25,792] INFO Started o.e.j.s.ServletContextHandler@61ae0d43{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)
  234. [2018-04-24 16:11:25,801] INFO Started http_8084@51bddd98{HTTP/1.1}{0.0.0.0:8084} (org.eclipse.jetty.server.ServerConnector:266)
  235. [2018-04-24 16:11:25,801] INFO Started @20130ms (org.eclipse.jetty.server.Server:379)
  236. [2018-04-24 16:11:25,802] INFO Advertised URI: http://192.168.217.92:8084/ (org.apache.kafka.connect.runtime.rest.RestServer:248)
  237. [2018-04-24 16:11:25,802] INFO REST server listening at http://192.168.217.92:8084/, advertising URL http://192.168.217.92:8084/ (org.apache.kafka.connect.runtime.rest.RestServer:207)
  238. [2018-04-24 16:11:25,802] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)
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!