/usr/bin/control-center-start /tmp/control-center.properties
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6d0b1575-5796-4ad8-ace5-a490a35391a9%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
Hi Vadim,That seems to be a bug in the way the script finds it's own directory. I'll file a JIRA for that. In the mean, you can work around it by running the start script from it's absolute path./usr/bin/control-center-start /tmp/control-center.properties
On Wed, Jul 20, 2016 at 10:41 AM, Vadim Dzyuban <vadim....@gmail.com> wrote:
I installed confluent 3 on centos 7 + java 8, followed the instructions at http://docs.confluent.io/3.0.0/control-center/docs/quickstart.htmlSuccessfully started zookeeper, kafka, schema registry, kafka connect, but starting control center gives an error:./bin/control-center-start /tmp/control-center.propertiesError: Could not find or load main class kafka.admin.TopicCommandCreating topic _confluent-monitoring with 1 partitions and replication factor of 1...Error: Could not find or load main class kafka.admin.TopicCommandAny help will be appreciatedThanksVadim Dzyuban
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
~# tail -f /var/log/control-center.log
[2016-07-22 15:41:16,566] WARN file=dist/index.html length=311 (io.confluent.controlcenter.rest.StaticFileResource:77)
[2016-07-22 15:41:16,767] WARN file=dist/app.js length=1836368 (io.confluent.controlcenter.rest.StaticFileResource:77)
[2016-07-22 15:41:16,775] WARN file=dist/app.css length=167621 (io.confluent.controlcenter.rest.StaticFileResource:77)
[2016-07-22 15:41:17,097] WARN checking license failure: Unable to process JOSE object (cause: org.jose4j.lang.JoseException: Invalid JOSE Compact Serialization. Expecting either 3 or 5 parts for JWS or JWE respectively but was 1.): (io.confluent.license.LicenseModule:39)
[2016-07-22 15:40:04,311] WARN The configuration producer.interceptor.classes = io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration config.storage.topic = connect-configs was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration status.storage.topic = connect-statuses was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration internal.key.converter.schemas.enable = false was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration value.converter.schema.registry.url = http://localhost:8081 was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration internal.key.converter = org.apache.kafka.connect.json.JsonConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration internal.value.converter.schemas.enable = false was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration consumer.interceptor.classes = io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration internal.value.converter = org.apache.kafka.connect.json.JsonConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration offset.storage.topic = connect-offsets was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration value.converter = io.confluent.connect.avro.AvroConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration key.converter = io.confluent.connect.avro.AvroConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
[2016-07-22 15:40:04,311] WARN The configuration key.converter.schema.registry.url = http://localhost:8081 was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:186)
$ jstack -l 9118
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6d0b1575-5796-4ad8-ace5-a490a35391a9%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f64032fe-3030-4066-9da4-5af13f151589%40googlegroups.com.
root@1b089dc4b52b:/var/log# jps -l1602 jdk.jcmd/sun.tools.jps.Jps117 io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain182 io.confluent.controlcenter.ControlCenter9 org.apache.zookeeper.server.quorum.QuorumPeerMain173 org.apache.kafka.connect.cli.ConnectDistributed46 io.confluent.support.metrics.SupportedKafkaroot@1b089dc4b52b:/var/log# jstack 1822016-07-23 01:46:52Full thread dump OpenJDK 64-Bit Server VM (25.91-b14 mixed mode):
"Attach Listener" #26 daemon prio=9 os_prio=0 tid=0x00007f1268001000 nid=0x674 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"main-EventThread" #25 daemon prio=5 os_prio=0 tid=0x00007f12a4d22000 nid=0x541 waiting on condition [0x00007f1252263000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d56e1d40> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
"main-SendThread(localhost:2181)" #24 daemon prio=5 os_prio=0 tid=0x00007f12a4d20000 nid=0x540 runnable [0x00007f1252364000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d56e1d88> (a sun.nio.ch.Util$2) - locked <0x00000000d56e1da0> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d55fddb0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
"ZkClient-EventThread-23-localhost:2181" #23 daemon prio=5 os_prio=0 tid=0x00007f12a4d06000 nid=0x53f waiting on condition [0x00007f1252465000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d56e1db8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
"main-EventThread" #21 daemon prio=5 os_prio=0 tid=0x00007f12a4c14000 nid=0x53e waiting on condition [0x00007f1252566000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51bdb20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
"main-SendThread(localhost:2181)" #20 daemon prio=5 os_prio=0 tid=0x00007f12a4bac000 nid=0x53d runnable [0x00007f1252667000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51bde38> (a sun.nio.ch.Util$2) - locked <0x00000000d51bde20> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190108> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
"ZkClient-EventThread-19-localhost:2181" #19 daemon prio=5 os_prio=0 tid=0x00007f12a4baa800 nid=0x53c waiting on condition [0x00007f1252768000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51bdf28> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
"kafka-producer-network-thread | _confluent-controlcenter-0-1-StreamThread-2-producer" #18 daemon prio=5 os_prio=0 tid=0x00007f12a4ba8000 nid=0x53b runnable [0x00007f1252869000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51be2b8> (a sun.nio.ch.Util$2) - locked <0x00000000d51be2a0> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190198> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.kafka.common.network.Selector.select(Selector.java:454) at org.apache.kafka.common.network.Selector.poll(Selector.java:277) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134) at java.lang.Thread.run(Thread.java:745)
"main-EventThread" #16 daemon prio=5 os_prio=0 tid=0x00007f12a4b66000 nid=0x53a waiting on condition [0x00007f1252b6a000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51c0238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
"main-SendThread(localhost:2181)" #15 daemon prio=5 os_prio=0 tid=0x00007f12a4b67800 nid=0x539 runnable [0x00007f1252c6b000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51c0568> (a sun.nio.ch.Util$2) - locked <0x00000000d51c0550> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190270> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
"ZkClient-EventThread-14-localhost:2181" #14 daemon prio=5 os_prio=0 tid=0x00007f12a4b60800 nid=0x538 waiting on condition [0x00007f1252d6c000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51c0688> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
"kafka-producer-network-thread | _confluent-controlcenter-0-1-StreamThread-1-producer" #13 daemon prio=5 os_prio=0 tid=0x00007f12a4b1e800 nid=0x537 runnable [0x00007f1252e6d000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51c0a18> (a sun.nio.ch.Util$2) - locked <0x00000000d51c0a00> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190300> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.kafka.common.network.Selector.select(Selector.java:454) at org.apache.kafka.common.network.Selector.poll(Selector.java:277) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134) at java.lang.Thread.run(Thread.java:745)
"RMI TCP Accept-0" #11 daemon prio=5 os_prio=0 tid=0x00007f12a4707000 nid=0x535 runnable [0x00007f1253a69000] java.lang.Thread.State: RUNNABLE at java.net.PlainSocketImpl.socketAccept(Native Method) at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409) at java.net.ServerSocket.implAccept(ServerSocket.java:545) at java.net.ServerSocket.accept(ServerSocket.java:513) at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372) at java.lang.Thread.run(Thread.java:745)
"Service Thread" #9 daemon prio=9 os_prio=0 tid=0x00007f12a4102800 nid=0x534 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"C1 CompilerThread2" #8 daemon prio=9 os_prio=0 tid=0x00007f12a40f7800 nid=0x533 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"C2 CompilerThread1" #7 daemon prio=9 os_prio=0 tid=0x00007f12a40f3000 nid=0x532 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"C2 CompilerThread0" #6 daemon prio=9 os_prio=0 tid=0x00007f12a40f0800 nid=0x531 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"Signal Dispatcher" #5 daemon prio=9 os_prio=0 tid=0x00007f12a40ee800 nid=0x530 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"Surrogate Locker Thread (Concurrent GC)" #4 daemon prio=9 os_prio=0 tid=0x00007f12a40ec800 nid=0x52f waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
"Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f12a40c6800 nid=0x52e in Object.wait() [0x00007f128c2fb000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000d4fd9430> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) - locked <0x00000000d4fd9430> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
"Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f12a40c1800 nid=0x52d in Object.wait() [0x00007f128c3fc000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000d4faccc0> (a java.lang.ref.Reference$Lock) at java.lang.Object.wait(Object.java:502) at java.lang.ref.Reference.tryHandlePending(Reference.java:191) - locked <0x00000000d4faccc0> (a java.lang.ref.Reference$Lock) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
"main" #1 prio=5 os_prio=0 tid=0x00007f12a400e800 nid=0x526 runnable [0x00007f12aae19000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) at java.net.SocketInputStream.read(SocketInputStream.java:170) at java.net.SocketInputStream.read(SocketInputStream.java:141) at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) at java.io.BufferedInputStream.read1(BufferedInputStream.java:286) at java.io.BufferedInputStream.read(BufferedInputStream.java:345) - locked <0x00000000c199f9a0> (a java.io.BufferedInputStream) at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:704) at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:647) at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1536) - locked <0x00000000c19a7f48> (a sun.net.www.protocol.http.HttpURLConnection) at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1441) - locked <0x00000000c19a7f48> (a sun.net.www.protocol.http.HttpURLConnection) at java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480) at org.glassfish.jersey.client.HttpUrlConnector._apply(HttpUrlConnector.java:335) at org.glassfish.jersey.client.HttpUrlConnector.apply(HttpUrlConnector.java:242) at org.glassfish.jersey.client.ClientRuntime.invoke(ClientRuntime.java:254) at org.glassfish.jersey.client.JerseyInvocation$3.call(JerseyInvocation.java:709) at org.glassfish.jersey.internal.Errors.process(Errors.java:315) at org.glassfish.jersey.internal.Errors.process(Errors.java:297) at org.glassfish.jersey.internal.Errors.process(Errors.java:228) at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:444) at org.glassfish.jersey.client.JerseyInvocation.invoke(JerseyInvocation.java:705) at io.confluent.controlcenter.connect.ConnectService.getConnectorPlugins(ConnectService.java:83) at io.confluent.controlcenter.connect.ConnectService.<init>(ConnectService.java:48) at io.confluent.controlcenter.connect.ConnectService$$FastClassByGuice$$89f5f123.newInstance(<generated>) at com.google.inject.internal.cglib.reflect.$FastConstructor.newInstance(FastConstructor.java:40) at com.google.inject.internal.DefaultConstructionProxyFactory$1.newInstance(DefaultConstructionProxyFactory.java:61) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:105) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:46) at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1103) at com.google.inject.internal.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:40) at com.google.inject.internal.SingletonScope$1.get(SingletonScope.java:145) at com.google.inject.internal.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:41) at com.google.inject.internal.SingleParameterInjector.inject(SingleParameterInjector.java:38) at com.google.inject.internal.SingleParameterInjector.getAll(SingleParameterInjector.java:62) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:104) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.SingleParameterInjector.inject(SingleParameterInjector.java:38) at com.google.inject.internal.SingleParameterInjector.getAll(SingleParameterInjector.java:62) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:104) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.InjectorImpl$2$1.call(InjectorImpl.java:1016) at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1092) at com.google.inject.internal.InjectorImpl$2.get(InjectorImpl.java:1012) at com.google.inject.internal.InjectorImpl.getInstance(InjectorImpl.java:1051) at io.confluent.controlcenter.ControlCenter.main(ControlCenter.java:58)
"VM Thread" os_prio=0 tid=0x00007f12a40ba000 nid=0x52c runnable
"Gang worker#0 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4020000 nid=0x527 runnable
"Gang worker#1 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4021800 nid=0x528 runnable
"Gang worker#2 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4023000 nid=0x529 runnable
"Gang worker#3 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4025000 nid=0x52a runnable
"Concurrent Mark-Sweep GC Thread" os_prio=0 tid=0x00007f12a4067800 nid=0x52b runnable
"VM Periodic Task Thread" os_prio=0 tid=0x00007f12a471c800 nid=0x536 waiting on condition
JNI global references: 280
root@1b089dc4b52b:/var/log# jstack -l 1822016-07-23 01:48:22Full thread dump OpenJDK 64-Bit Server VM (25.91-b14 mixed mode):
"Attach Listener" #26 daemon prio=9 os_prio=0 tid=0x00007f1268001000 nid=0x674 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"main-EventThread" #25 daemon prio=5 os_prio=0 tid=0x00007f12a4d22000 nid=0x541 waiting on condition [0x00007f1252263000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d56e1d40> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
Locked ownable synchronizers: - None
"main-SendThread(localhost:2181)" #24 daemon prio=5 os_prio=0 tid=0x00007f12a4d20000 nid=0x540 runnable [0x00007f1252364000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d56e1d88> (a sun.nio.ch.Util$2) - locked <0x00000000d56e1da0> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d55fddb0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
Locked ownable synchronizers: - None
"ZkClient-EventThread-23-localhost:2181" #23 daemon prio=5 os_prio=0 tid=0x00007f12a4d06000 nid=0x53f waiting on condition [0x00007f1252465000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d56e1db8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
Locked ownable synchronizers: - None
"main-EventThread" #21 daemon prio=5 os_prio=0 tid=0x00007f12a4c14000 nid=0x53e waiting on condition [0x00007f1252566000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51bdb20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
Locked ownable synchronizers: - None
"main-SendThread(localhost:2181)" #20 daemon prio=5 os_prio=0 tid=0x00007f12a4bac000 nid=0x53d runnable [0x00007f1252667000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51bde38> (a sun.nio.ch.Util$2) - locked <0x00000000d51bde20> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190108> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
Locked ownable synchronizers: - None
"ZkClient-EventThread-19-localhost:2181" #19 daemon prio=5 os_prio=0 tid=0x00007f12a4baa800 nid=0x53c waiting on condition [0x00007f1252768000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51bdf28> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
Locked ownable synchronizers: - None
"kafka-producer-network-thread | _confluent-controlcenter-0-1-StreamThread-2-producer" #18 daemon prio=5 os_prio=0 tid=0x00007f12a4ba8000 nid=0x53b runnable [0x00007f1252869000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51be2b8> (a sun.nio.ch.Util$2) - locked <0x00000000d51be2a0> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190198> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.kafka.common.network.Selector.select(Selector.java:454) at org.apache.kafka.common.network.Selector.poll(Selector.java:277) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134) at java.lang.Thread.run(Thread.java:745)
Locked ownable synchronizers: - None
"main-EventThread" #16 daemon prio=5 os_prio=0 tid=0x00007f12a4b66000 nid=0x53a waiting on condition [0x00007f1252b6a000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51c0238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:493)
Locked ownable synchronizers: - None
"main-SendThread(localhost:2181)" #15 daemon prio=5 os_prio=0 tid=0x00007f12a4b67800 nid=0x539 runnable [0x00007f1252c6b000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51c0568> (a sun.nio.ch.Util$2) - locked <0x00000000d51c0550> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190270> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:274) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1035)
Locked ownable synchronizers: - None
"ZkClient-EventThread-14-localhost:2181" #14 daemon prio=5 os_prio=0 tid=0x00007f12a4b60800 nid=0x538 waiting on condition [0x00007f1252d6c000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x00000000d51c0688> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
Locked ownable synchronizers: - None
"kafka-producer-network-thread | _confluent-controlcenter-0-1-StreamThread-1-producer" #13 daemon prio=5 os_prio=0 tid=0x00007f12a4b1e800 nid=0x537 runnable [0x00007f1252e6d000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x00000000d51c0a18> (a sun.nio.ch.Util$2) - locked <0x00000000d51c0a00> (a java.util.Collections$UnmodifiableSet) - locked <0x00000000d5190300> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.kafka.common.network.Selector.select(Selector.java:454) at org.apache.kafka.common.network.Selector.poll(Selector.java:277) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134) at java.lang.Thread.run(Thread.java:745)
Locked ownable synchronizers: - None
"RMI TCP Accept-0" #11 daemon prio=5 os_prio=0 tid=0x00007f12a4707000 nid=0x535 runnable [0x00007f1253a69000] java.lang.Thread.State: RUNNABLE at java.net.PlainSocketImpl.socketAccept(Native Method) at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409) at java.net.ServerSocket.implAccept(ServerSocket.java:545) at java.net.ServerSocket.accept(ServerSocket.java:513) at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372) at java.lang.Thread.run(Thread.java:745)
Locked ownable synchronizers: - None
"Service Thread" #9 daemon prio=9 os_prio=0 tid=0x00007f12a4102800 nid=0x534 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"C1 CompilerThread2" #8 daemon prio=9 os_prio=0 tid=0x00007f12a40f7800 nid=0x533 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"C2 CompilerThread1" #7 daemon prio=9 os_prio=0 tid=0x00007f12a40f3000 nid=0x532 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"C2 CompilerThread0" #6 daemon prio=9 os_prio=0 tid=0x00007f12a40f0800 nid=0x531 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"Signal Dispatcher" #5 daemon prio=9 os_prio=0 tid=0x00007f12a40ee800 nid=0x530 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"Surrogate Locker Thread (Concurrent GC)" #4 daemon prio=9 os_prio=0 tid=0x00007f12a40ec800 nid=0x52f waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE
Locked ownable synchronizers: - None
"Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f12a40c6800 nid=0x52e in Object.wait() [0x00007f128c2fb000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000d4fd9430> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) - locked <0x00000000d4fd9430> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
Locked ownable synchronizers: - None
"Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f12a40c1800 nid=0x52d in Object.wait() [0x00007f128c3fc000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000d4faccc0> (a java.lang.ref.Reference$Lock) at java.lang.Object.wait(Object.java:502) at java.lang.ref.Reference.tryHandlePending(Reference.java:191) - locked <0x00000000d4faccc0> (a java.lang.ref.Reference$Lock) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
Locked ownable synchronizers: - None
"main" #1 prio=5 os_prio=0 tid=0x00007f12a400e800 nid=0x526 runnable [0x00007f12aae19000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) at java.net.SocketInputStream.read(SocketInputStream.java:170) at java.net.SocketInputStream.read(SocketInputStream.java:141) at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) at java.io.BufferedInputStream.read1(BufferedInputStream.java:286) at java.io.BufferedInputStream.read(BufferedInputStream.java:345) - locked <0x00000000c199f9a0> (a java.io.BufferedInputStream) at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:704) at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:647) at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1536) - locked <0x00000000c19a7f48> (a sun.net.www.protocol.http.HttpURLConnection) at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1441) - locked <0x00000000c19a7f48> (a sun.net.www.protocol.http.HttpURLConnection) at java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480) at org.glassfish.jersey.client.HttpUrlConnector._apply(HttpUrlConnector.java:335) at org.glassfish.jersey.client.HttpUrlConnector.apply(HttpUrlConnector.java:242) at org.glassfish.jersey.client.ClientRuntime.invoke(ClientRuntime.java:254) at org.glassfish.jersey.client.JerseyInvocation$3.call(JerseyInvocation.java:709) at org.glassfish.jersey.internal.Errors.process(Errors.java:315) at org.glassfish.jersey.internal.Errors.process(Errors.java:297) at org.glassfish.jersey.internal.Errors.process(Errors.java:228) at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:444) at org.glassfish.jersey.client.JerseyInvocation.invoke(JerseyInvocation.java:705) at io.confluent.controlcenter.connect.ConnectService.getConnectorPlugins(ConnectService.java:83) at io.confluent.controlcenter.connect.ConnectService.<init>(ConnectService.java:48) at io.confluent.controlcenter.connect.ConnectService$$FastClassByGuice$$89f5f123.newInstance(<generated>) at com.google.inject.internal.cglib.reflect.$FastConstructor.newInstance(FastConstructor.java:40) at com.google.inject.internal.DefaultConstructionProxyFactory$1.newInstance(DefaultConstructionProxyFactory.java:61) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:105) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:46) at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1103) at com.google.inject.internal.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:40) at com.google.inject.internal.SingletonScope$1.get(SingletonScope.java:145) at com.google.inject.internal.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:41) at com.google.inject.internal.SingleParameterInjector.inject(SingleParameterInjector.java:38) at com.google.inject.internal.SingleParameterInjector.getAll(SingleParameterInjector.java:62) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:104) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.SingleParameterInjector.inject(SingleParameterInjector.java:38) at com.google.inject.internal.SingleParameterInjector.getAll(SingleParameterInjector.java:62) at com.google.inject.internal.ConstructorInjector.provision(ConstructorInjector.java:104) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:267) at com.google.inject.internal.InjectorImpl$2$1.call(InjectorImpl.java:1016) at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1092) at com.google.inject.internal.InjectorImpl$2.get(InjectorImpl.java:1012) at com.google.inject.internal.InjectorImpl.getInstance(InjectorImpl.java:1051) at io.confluent.controlcenter.ControlCenter.main(ControlCenter.java:58)
Locked ownable synchronizers: - <0x00000000d51eec50> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
"VM Thread" os_prio=0 tid=0x00007f12a40ba000 nid=0x52c runnable
"Gang worker#0 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4020000 nid=0x527 runnable
"Gang worker#1 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4021800 nid=0x528 runnable
"Gang worker#2 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4023000 nid=0x529 runnable
"Gang worker#3 (Parallel GC Threads)" os_prio=0 tid=0x00007f12a4025000 nid=0x52a runnable
"Concurrent Mark-Sweep GC Thread" os_prio=0 tid=0x00007f12a4067800 nid=0x52b runnable
"VM Periodic Task Thread" os_prio=0 tid=0x00007f12a471c800 nid=0x536 waiting on condition
JNI global references: 281
root@1b089dc4b52b:/var/log#
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6d0b1575-5796-4ad8-ace5-a490a35391a9%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6d0b1575-5796-4ad8-ace5-a490a35391a9%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
FROM ubuntu
RUN apt-get update && \ apt-get install -y openjdk-8-jdk-headless vim && \ apt-get clean
ADD files/confluent-3.0.0-2.11.tar /opt
ADD files/entry.sh /ENTRYPOINT /entry.sh
#!/bin/bash
echo Starting up Zookeeper/opt/confluent-3.0.0/bin/zookeeper-server-start /opt/confluent-3.0.0/etc/kafka/zookeeper.properties 2>&1 > /var/log/zookeeper.log &while [ ! -f /var/log/zookeeper.log ]; do sleep 1; donetail -f /var/log/zookeeper.log | while read LINEdo [[ "${LINE}" == *"binding to port"* ]] && pkill -P $$ taildone
echo Starting up Kafka/opt/confluent-3.0.0/bin/kafka-server-start /opt/confluent-3.0.0/etc/kafka/server.properties 2>&1 > /var/log/kafka.log &while [ ! -f /var/log/kafka.log ]; do sleep 1; donetail -f /var/log/kafka.log | while read LINEdo [[ "${LINE}" == *"Monitored broker is now ready"* ]] && pkill -P $$ taildone
echo Starting up Schema Registry/opt/confluent-3.0.0/bin/schema-registry-start /opt/confluent-3.0.0/etc/schema-registry/schema-registry.properties 2>&1 > /var/log/schema-registry.log &
echo Starting up Kafka Connectcp /opt/confluent-3.0.0/etc/schema-registry/connect-avro-distributed.properties /tmp/connect-distributed.propertiesecho "" >> /tmp/connect-distributed.propertiescat <<EOF >> /tmp/connect-distributed.propertiesconsumer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptorproducer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptorEOF/opt/confluent-3.0.0/bin/connect-distributed /tmp/connect-distributed.properties 2>&1 > /var/log/kafka-connect.log &
echo Starting up Control Centercp /opt/confluent-3.0.0/etc/confluent-control-center/control-center.properties /tmp/control-center.propertiescat <<EOF >> /tmp/control-center.propertiesconfluent.controlcenter.internal.topics.partitions=1confluent.controlcenter.internal.topics.replication=1confluent.monitoring.interceptor.topic.partitions=1confluent.monitoring.interceptor.topic.replication=1EOF/opt/confluent-3.0.0/bin/control-center-start /tmp/control-center.properties 2>&1 > /var/log/control-center.log &
echo Startup complete
bash
tail -f /var/log/control-center.log
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6d0b1575-5796-4ad8-ace5-a490a35391a9%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f64032fe-3030-4066-9da4-5af13f151589%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/b2a4861d-9458-4ab2-be6a-40910fb06097%40googlegroups.com.
...
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/c1c3451c-7db6-4cf2-996b-4cb98d8ed032%40googlegroups.com.
...
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f54431b8-6d1d-40ba-a26e-4a76e9c1a2ad%40googlegroups.com.
cd /etc/kafka && /usr/bin/connect-distributed /tmp/connect-distributed.properties
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/abdd78c7-ca23-4931-94e1-77a591f96a19%40googlegroups.com.
Hi Vadim,
Thanks.
[2016-07-22 15:40:04,311] WARN The configuration producer.interceptor.classes =<span style="
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/fa339cce-70b2-4f05-bc77-447fd4d5ed9f%40googlegroups.com.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Yes, it worked for me and now I can see the created topics: test-topic and poem.A few more questions please:(1)how can I see the content of the messages, is it possible ?
(2)let's say I'd like to connect to remote linux server 'remote-server' on port 2181.I have kafka running stuff on that server and I'd like to monitor those topics/massages with the control center web ui.How can I do that ? Could you please outline the main steps ?
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/fa339cce-70b2-4f05-bc77-447fd4d5ed9f%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f6ca2a09-4005-43f3-9811-5d121805bd5f%40googlegroups.com.
Hi Vadim,See inline below.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/fa339cce-70b2-4f05-bc77-447fd4d5ed9f%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
$ /usr/bin/kafka-console-consumer --zookeeper localhost:2181 --topic test-topic --from-beginning
#Reads Avro data and converts it to JSON for human readability
$ /usr/bin/kafka-avro-console-consumer --topic test --zookeeper localhost:2181 --from-beginning
Hi Vadim,See inline below.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/fa339cce-70b2-4f05-bc77-447fd4d5ed9f%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/f6ca2a09-4005-43f3-9811-5d121805bd5f%40googlegroups.com.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/673514e1-5031-4d59-9f8c-d70f6dd8189a%40googlegroups.com.
WORKDIR /etc/kafka
...
Thank you!!!
[2016-07-22 15:41:17,097] WARN checking license failure: Unable to process JOSE object (cause: org.jose4j.lang.JoseException: Invalid JOSE Compact Serialization. Expecting either 3 or 5 parts for</
Hi Vadim,See inline below.
Thanks.
~# tail -f /var/log/control-center.log
[2016-07-22 15:41:16,566] WARN file=dist/index.html length=311<span style="colo