API tools faq
paste
Advertisement
Guest User

Confluent error

a guest
Jan 20th, 2018
173
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 12.10 KB | None | 0 0
raw download clone embed print report
  1. [2018-01-20 16:34:27,411] ERROR Failed to reconfigure connector's tasks, retrying after backoff: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:922)
  2. java.lang.UnsupportedClassVersionError: com/datamountaineer/kcql/Kcql
  3. at com.datamountaineer.streamreactor.connect.config.base.traits.KcqlSettings$class.getKCQL(KcqlSettings.scala:37)
  4. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig.getKCQL(MqttConfig.scala:77)
  5. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$.apply(MqttSourceSettings.scala:65)
  6. at com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector.taskConfigs(MqttSourceConnector.scala:48)
  7. at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:271)
  8. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnector(DistributedHerder.java:963)
  9. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnectorTasksWithRetry(DistributedHerder.java:914)
  10. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$900(DistributedHerder.java:100)
  11. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:927)
  12. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:924)
  13. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:249)
  14. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:199)
  15. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:473)
  16. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  17. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1152)
  18. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622)
  19. at java.lang.Thread.run(Thread.java:748)
  20. [2018-01-20 16:34:27,411] ERROR Unexpected error during connector task reconfiguration: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:933)
  21. [2018-01-20 16:34:27,411] ERROR Task reconfiguration for mqtt-source2 failed unexpectedly, this connector will not be properly reconfigured unless manually triggered. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:934)
  22. [2018-01-20 16:34:27,661] INFO SourceConnectorConfig values:
  23. connector.class = com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
  24. key.converter = null
  25. name = mqtt-source2
  26. tasks.max = 1
  27. transforms = null
  28. value.converter = null
  29. (org.apache.kafka.connect.runtime.SourceConnectorConfig:223)
  30. [2018-01-20 16:34:27,661] INFO EnrichedConnectorConfig values:
  31. connector.class = com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
  32. key.converter = null
  33. name = mqtt-source2
  34. tasks.max = 1
  35. transforms = null
  36. value.converter = null
  37. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  38. [2018-01-20 16:34:27,661] INFO MqttSourceConfig values:
  39. connect.mqtt.clean = true
  40. connect.mqtt.client.id = dm_source_id
  41. connect.mqtt.converter.throw.on.error = true
  42. connect.mqtt.error.policy = THROW
  43. connect.mqtt.hosts = tcp://127.0.0.1:1883
  44. connect.mqtt.kcql = INSERT INTO kavro2 SELECT * FROM /mavro2 WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.AvroConverter`
  45. connect.mqtt.keep.alive = 5000
  46. connect.mqtt.max.retries = 20
  47. connect.mqtt.password = null
  48. connect.mqtt.retry.interval = 60000
  49. connect.mqtt.service.quality = 1
  50. connect.mqtt.ssl.ca.cert = null
  51. connect.mqtt.ssl.cert = null
  52. connect.mqtt.ssl.key = null
  53. connect.mqtt.timeout = 3000
  54. connect.mqtt.username = null
  55. connect.progress.enabled = false
  56. (com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig:223)
  57. [2018-01-20 16:34:27,662] ERROR Failed to reconfigure connector's tasks, retrying after backoff: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:922)
  58. java.lang.UnsupportedClassVersionError: com/datamountaineer/kcql/Kcql
  59. at com.datamountaineer.streamreactor.connect.config.base.traits.KcqlSettings$class.getKCQL(KcqlSettings.scala:37)
  60. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig.getKCQL(MqttConfig.scala:77)
  61. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$.apply(MqttSourceSettings.scala:65)
  62. at com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector.taskConfigs(MqttSourceConnector.scala:48)
  63. at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:271)
  64. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnector(DistributedHerder.java:963)
  65. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnectorTasksWithRetry(DistributedHerder.java:914)
  66. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$900(DistributedHerder.java:100)
  67. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:927)
  68. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:924)
  69. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:249)
  70. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:199)
  71. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:473)
  72. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  73. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1152)
  74. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622)
  75. at java.lang.Thread.run(Thread.java:748)
  76. [2018-01-20 16:34:27,662] ERROR Unexpected error during connector task reconfiguration: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:933)
  77. [2018-01-20 16:34:27,662] ERROR Task reconfiguration for mqtt-source2 failed unexpectedly, this connector will not be properly reconfigured unless manually triggered. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:934)
  78. [2018-01-20 16:34:27,912] INFO SourceConnectorConfig values:
  79. connector.class = com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
  80. key.converter = null
  81. name = mqtt-source2
  82. tasks.max = 1
  83. transforms = null
  84. value.converter = null
  85. (org.apache.kafka.connect.runtime.SourceConnectorConfig:223)
  86. [2018-01-20 16:34:27,912] INFO EnrichedConnectorConfig values:
  87. connector.class = com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector
  88. key.converter = null
  89. name = mqtt-source2
  90. tasks.max = 1
  91. transforms = null
  92. value.converter = null
  93. (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:223)
  94. [2018-01-20 16:34:27,913] INFO MqttSourceConfig values:
  95. connect.mqtt.clean = true
  96. connect.mqtt.client.id = dm_source_id
  97. connect.mqtt.converter.throw.on.error = true
  98. connect.mqtt.error.policy = THROW
  99. connect.mqtt.hosts = tcp://127.0.0.1:1883
  100. connect.mqtt.kcql = INSERT INTO kavro2 SELECT * FROM /mavro2 WITHCONVERTER=`com.datamountaineer.streamreactor.connect.converters.source.AvroConverter`
  101. connect.mqtt.keep.alive = 5000
  102. connect.mqtt.max.retries = 20
  103. connect.mqtt.password = null
  104. connect.mqtt.retry.interval = 60000
  105. connect.mqtt.service.quality = 1
  106. connect.mqtt.ssl.ca.cert = null
  107. connect.mqtt.ssl.cert = null
  108. connect.mqtt.ssl.key = null
  109. connect.mqtt.timeout = 3000
  110. connect.mqtt.username = null
  111. connect.progress.enabled = false
  112. (com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig:223)
  113. [2018-01-20 16:34:27,913] ERROR Failed to reconfigure connector's tasks, retrying after backoff: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:922)
  114. java.lang.UnsupportedClassVersionError: com/datamountaineer/kcql/Kcql
  115. at com.datamountaineer.streamreactor.connect.config.base.traits.KcqlSettings$class.getKCQL(KcqlSettings.scala:37)
  116. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig.getKCQL(MqttConfig.scala:77)
  117. at com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$.apply(MqttSourceSettings.scala:65)
  118. at com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector.taskConfigs(MqttSourceConnector.scala:48)
  119. at org.apache.kafka.connect.runtime.Worker.connectorTaskConfigs(Worker.java:271)
  120. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnector(DistributedHerder.java:963)
  121. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.reconfigureConnectorTasksWithRetry(DistributedHerder.java:914)
  122. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$900(DistributedHerder.java:100)
  123. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:927)
  124. at org.apache.kafka.connect.runtime.distributed.DistributedHerder$17$1.call(DistributedHerder.java:924)
  125. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:249)
  126. at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:199)
  127. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:473)
  128. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  129. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1152)
  130. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622)
  131. at java.lang.Thread.run(Thread.java:748)
  132. [2018-01-20 16:34:27,913] ERROR Unexpected error during connector task reconfiguration: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:933)
  133. [2018-01-20 16:34:27,913] ERROR Task reconfiguration for mqtt-source2 failed unexpectedly, this connector will not be properly reconfigured unless manually triggered. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:934)
  134. [2018-01-20 16:34:27,951] INFO Removed connector mqtt-source2 due to null configuration. This is usually intentional and does not indicate an issue. (org.apache.kafka.connect.storage.KafkaConfigBackingStore:513)
  135. [2018-01-20 16:34:27,951] INFO Connector mqtt-source2 config removed (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1043)
  136. [2018-01-20 16:34:28,454] INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1187)
  137. [2018-01-20 16:34:28,455] INFO Stopping connector mqtt-source2 (org.apache.kafka.connect.runtime.Worker:301)
  138. [2018-01-20 16:34:28,455] INFO 127.0.0.1 - - [20/Jan/2018:16:34:27 +0000] "DELETE /connectors/mqtt-source2 HTTP/1.1" 204 - 510 (org.apache.kafka.connect.runtime.rest.RestServer:60)
  139. [2018-01-20 16:34:28,455] INFO Stopped connector mqtt-source2 (org.apache.kafka.connect.runtime.Worker:317)
  140. [2018-01-20 16:34:28,458] INFO Finished stopping tasks in preparation for rebalance (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1217)
  141. [2018-01-20 16:34:28,459] INFO (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:432)
  142. [2018-01-20 16:34:28,464] INFO Successfully joined group connect-cluster with generation 5 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:399)
  143. [2018-01-20 16:34:28,464] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-73eddfa6-23ff-417e-b2bc-dbfdfa5dee59', leaderUrl='http://10.132.0.2:8083/', offset=6, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1166)
  144. [2018-01-20 16:34:28,464] INFO Starting connectors and tasks using config offset 6 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:815)
  145. [2018-01-20 16:34:28,464] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:825)
  146. [2018-01-20 16:34:28,465] INFO Skipping reconfiguration of connector mqtt-source2 since it is not running (org.apache.kafka.connect.runtime.distributed.DistributedHerder:948)
  147. [2018-01-20 16:34:28,465] ERROR Unexpected error during connector task reconfiguration: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:933)
  148. [2018-01-20 16:34:28,465] ERROR Task reconfiguration for mqtt-source2 failed unexpectedly, this connector will not be properly reconfigured unless manually triggered. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:934)
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!