You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by matvey <ma...@gmail.com> on 2018/07/31 10:43:01 UTC
Streaming Data via Kafka Connect
Hello. I want to stream data from Kafka to Ignite cache, and I'm using this
guide https://apacheignite-mix.readme.io/v2.6/docs/kafka-streamer. I use
confluent for these purposes.
The problem is that after I start connector (bin/connect-standalone
etc/kafka/connect-standalone-ignite.properties
etc/kafka/ignite-connector.properties), the cache remains empty (I use
ignitevisor and web console to check). Topic, which I use is not empty.
Here are my configs. Thank you in advance.
--connect-standalone-ignite.properties--
bootstrap.servers=1.2.3.4:9092
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false
internal.key.converter=org.apache.kafka.connect.storage.StringConverter
internal.value.converter=org.apache.kafka.connect.storage.StringConverter
internal.key.converter.schemas.enable=false
internal.value.converter.schemas.enable=false
offset.storage.file.filename=/tmp/connect.offsets1
--ignite-connector.properties--
# connector
name=my-ignite-connector
connector.class=org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
tasks.max=1
topics=super_topic
# cache
cacheName=mycache
cacheAllowOverwrite=true
igniteCfg=/var/u00/ignite/config/clienttestconf.xml
--clienttestconf.xml--
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="ignite.cfg"
class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="gridName" value="testGrid"/>
<property name="clientMode" value="true"/>
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.zk.ZookeeperDiscoverySpi">
<property name="zkConnectionString"
value="truzookeepera:2181,truzookeeperb:2181"/>
<property name="sessionTimeout" value="30000"/>
<property name="zkRootPath" value="/apacheIgnite"/>
<property name="joinTimeout" value="10000"/>
</bean>
</property>
<property name="cacheConfiguration">
<bean
class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="mycache"/>
<property name="atomicityMode"
value="ATOMIC"/>
<property name="cacheMode"
value="PARTITIONED"/>
<property name="backups" value="1"/>
<property name="affinity">
<bean
class="org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction">
<property name="excludeNeighbors"
value="true"/>
<property name="partitions"
value="2048"/>
</bean>
</property>
</bean>
</property>
</bean>
</beans>
here is the output messages:
[2018-07-31 13:28:46,014] INFO Kafka Connect standalone worker initializing
... (org.apache.kafka.connect.cli.ConnectStandalone:67)
[2018-07-31 13:28:46,022] INFO WorkerInfo values:
jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20,
-XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent,
-Djava.awt.headless=true, -Dcom.sun.management.jmxremote,
-Dcom.sun.management.jmxremote.authenticate=false,
-Dcom.sun.management.jmxremote.ssl=false,
-Dkafka.logs.dir=/var/u00/confluent/bin/../logs,
-Dlog4j.configuration=file:bin/../etc/kafka/connect-log4j.properties
jvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_171,
25.171-b10
jvm.classpath =
/var/u00/confluent/share/java/kafka/jackson-databind-2.9.5.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-test-sources.jar:/var/u00/confluent/share/java/kafka/rocksdbjni-5.7.3.jar:/var/u00/confluent/share/java/kafka/javax.inject-1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-test.jar:/var/u00/confluent/share/java/kafka/jackson-module-jaxb-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka/connect-transforms-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka-streams-examples-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/support-metrics-common-4.1.1.jar:/var/u00/confluent/share/java/kafka/javax.ws.rs-api-2.0.1.jar:/var/u00/confluent/share/java/kafka/connect-runtime-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-scaladoc.jar:/var/u00/confluent/share/java/kafka/javassist-3.20.0-GA.jar:/var/u00/confluent/share/java/kafka/jetty-continuation-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-streams-test-utils-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/connect-file-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/jersey-client-2.25.1.jar:/var/u00/confluent/share/java/kafka/validation-api-1.1.0.Final.jar:/var/u00/confluent/share/java/kafka/commons-logging-1.2.jar:/var/u00/confluent/share/java/kafka/lz4-java-1.4.1.jar:/var/u00/confluent/share/java/kafka/jackson-core-2.9.5.jar:/var/u00/confluent/share/java/kafka/connect-api-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/guava-20.0.jar:/var/u00/confluent/share/java/kafka/zookeeper-3.4.10.jar:/var/u00/confluent/share/java/kafka/javassist-3.21.0-GA.jar:/var/u00/confluent/share/java/kafka/javax.servlet-api-3.1.0.jar:/var/u00/confluent/share/java/kafka/commons-validator-1.4.1.jar:/var/u00/confluent/share/java/kafka/hk2-utils-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/hk2-locator-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/jackson-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka/commons-collections-3.2.1.jar:/var/u00/confluent/share/java/kafka/httpclient-4.5.2.jar:/var/u00/confluent/share/java/kafka/metrics-core-2.2.0.jar:/var/u00/confluent/share/java/kafka/avro-1.8.1.jar:/var/u00/confluent/share/java/kafka/support-metrics-client-4.1.1.jar:/var/u00/confluent/share/java/kafka/jersey-container-servlet-core-2.25.1.jar:/var/u00/confluent/share/java/kafka/log4j-1.2.17.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-sources.jar:/var/u00/confluent/share/java/kafka/jetty-io-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-common-2.25.1.jar:/var/u00/confluent/share/java/kafka/commons-lang3-3.5.jar:/var/u00/confluent/share/java/kafka/scala-library-2.11.12.jar:/var/u00/confluent/share/java/kafka/jetty-servlets-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-log4j-appender-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/javax.annotation-api-1.2.jar:/var/u00/confluent/share/java/kafka/netty-3.10.5.Final.jar:/var/u00/confluent/share/java/kafka/plexus-utils-3.1.0.jar:/var/u00/confluent/share/java/kafka/jetty-util-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jackson-core-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka/slf4j-api-1.7.25.jar:/var/u00/confluent/share/java/kafka/xz-1.5.jar:/var/u00/confluent/share/java/kafka/commons-compress-1.8.1.jar:/var/u00/confluent/share/java/kafka/jline-0.9.94.jar:/var/u00/confluent/share/java/kafka/kafka-tools-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/commons-codec-1.9.jar:/var/u00/confluent/share/java/kafka/activation-1.1.1.jar:/var/u00/confluent/share/java/kafka/commons-lang3-3.1.jar:/var/u00/confluent/share/java/kafka/jaxb-api-2.3.0.jar:/var/u00/confluent/share/java/kafka/kafka-streams-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/httpcore-4.4.4.jar:/var/u00/confluent/share/java/kafka/jopt-simple-5.0.4.jar:/var/u00/confluent/share/java/kafka/slf4j-log4j12-1.7.25.jar:/var/u00/confluent/share/java/kafka/jackson-jaxrs-base-2.9.5.jar:/var/u00/confluent/share/java/kafka/paranamer-2.7.jar:/var/u00/confluent/share/java/kafka/reflections-0.9.11.jar:/var/u00/confluent/share/java/kafka/osgi-resource-locator-1.0.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-javadoc.jar:/var/u00/confluent/share/java/kafka/jersey-container-servlet-2.25.1.jar:/var/u00/confluent/share/java/kafka/connect-json-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/snappy-java-1.1.7.1.jar:/var/u00/confluent/share/java/kafka/jetty-client-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-guava-2.25.1.jar:/var/u00/confluent/share/java/kafka/httpmime-4.5.2.jar:/var/u00/confluent/share/java/kafka/jetty-server-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-clients-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/jersey-media-jaxb-2.25.1.jar:/var/u00/confluent/share/java/kafka/jackson-jaxrs-json-provider-2.9.5.jar:/var/u00/confluent/share/java/kafka/aopalliance-repackaged-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/hk2-api-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka/zkclient-0.10.jar:/var/u00/confluent/share/java/kafka/jetty-http-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/javax.inject-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/maven-artifact-3.5.3.jar:/var/u00/confluent/share/java/kafka/scala-reflect-2.11.12.jar:/var/u00/confluent/share/java/kafka/jetty-security-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-server-2.25.1.jar:/var/u00/confluent/share/java/kafka/jetty-servlet-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/commons-beanutils-1.8.3.jar:/var/u00/confluent/share/java/kafka/argparse4j-0.7.0.jar:/var/u00/confluent/share/java/kafka/scala-logging_2.11-3.8.0.jar:/var/u00/confluent/share/java/kafka/common-utils-4.1.1.jar:/var/u00/confluent/share/java/kafka/commons-digester-1.8.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka.jar:/var/u00/confluent/share/java/kafka/ignite-kafka-2.5.0.jar:/var/u00/confluent/share/java/kafka/ignite-core-2.5.0.jar:/var/u00/confluent/share/java/kafka/cache-api-1.0.0.jar:/var/u00/confluent/share/java/kafka/ignite-spring-2.5.0.jar:/var/u00/confluent/share/java/kafka/spring-aop-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-beans-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-context-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-core-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-expression-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/curator-client-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-framework-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-recipes-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-x-discovery-2.9.1.jar:/var/u00/confluent/share/java/kafka/guava-16.0.1.jar:/var/u00/confluent/share/java/kafka/ignite-zookeeper-2.5.0.jar:/var/u00/confluent/share/java/kafka/zookeeper-3.4.6.jar:/var/u00/confluent/share/java/kafka/connect-api-0.10.0.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-0.10.0.1.jar:/var/u00/confluent/share/java/confluent-common/zookeeper-3.4.10.jar:/var/u00/confluent/share/java/confluent-common/build-tools-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/log4j-1.2.17.jar:/var/u00/confluent/share/java/confluent-common/netty-3.10.5.Final.jar:/var/u00/confluent/share/java/confluent-common/common-config-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/slf4j-api-1.7.25.jar:/var/u00/confluent/share/java/confluent-common/jline-0.9.94.jar:/var/u00/confluent/share/java/confluent-common/common-metrics-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/zkclient-0.10.jar:/var/u00/confluent/share/java/confluent-common/common-utils-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-databind-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-schema-registry-client-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-core-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-connect-avro-converter-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/avro-1.8.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-avro-serializer-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka-serde-tools/xz-1.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-json-serializer-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/paranamer-2.7.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-streams-avro-serde-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-databind-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-test-sources.jar:/var/u00/confluent/bin/../share/java/kafka/rocksdbjni-5.7.3.jar:/var/u00/confluent/bin/../share/java/kafka/javax.inject-1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-test.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/connect-transforms-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-examples-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/support-metrics-common-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/javax.ws.rs-api-2.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-runtime-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-scaladoc.jar:/var/u00/confluent/bin/../share/java/kafka/javassist-3.20.0-GA.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-continuation-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-test-utils-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-file-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-client-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/validation-api-1.1.0.Final.jar:/var/u00/confluent/bin/../share/java/kafka/commons-logging-1.2.jar:/var/u00/confluent/bin/../share/java/kafka/lz4-java-1.4.1.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-core-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/connect-api-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/guava-20.0.jar:/var/u00/confluent/bin/../share/java/kafka/zookeeper-3.4.10.jar:/var/u00/confluent/bin/../share/java/kafka/javassist-3.21.0-GA.jar:/var/u00/confluent/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/var/u00/confluent/bin/../share/java/kafka/commons-validator-1.4.1.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-utils-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-locator-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-annotations-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/commons-collections-3.2.1.jar:/var/u00/confluent/bin/../share/java/kafka/httpclient-4.5.2.jar:/var/u00/confluent/bin/../share/java/kafka/metrics-core-2.2.0.jar:/var/u00/confluent/bin/../share/java/kafka/avro-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/support-metrics-client-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-container-servlet-core-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/log4j-1.2.17.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-sources.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-io-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-common-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-lang3-3.5.jar:/var/u00/confluent/bin/../share/java/kafka/scala-library-2.11.12.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-servlets-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-log4j-appender-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/javax.annotation-api-1.2.jar:/var/u00/confluent/bin/../share/java/kafka/netty-3.10.5.Final.jar:/var/u00/confluent/bin/../share/java/kafka/plexus-utils-3.1.0.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-util-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-core-asl-1.9.13.jar:/var/u00/confluent/bin/../share/java/kafka/slf4j-api-1.7.25.jar:/var/u00/confluent/bin/../share/java/kafka/xz-1.5.jar:/var/u00/confluent/bin/../share/java/kafka/commons-compress-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/jline-0.9.94.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-tools-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-codec-1.9.jar:/var/u00/confluent/bin/../share/java/kafka/activation-1.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-lang3-3.1.jar:/var/u00/confluent/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/httpcore-4.4.4.jar:/var/u00/confluent/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/var/u00/confluent/bin/../share/java/kafka/slf4j-log4j12-1.7.25.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-jaxrs-base-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/paranamer-2.7.jar:/var/u00/confluent/bin/../share/java/kafka/reflections-0.9.11.jar:/var/u00/confluent/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-javadoc.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-container-servlet-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-json-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/snappy-java-1.1.7.1.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-client-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-guava-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/httpmime-4.5.2.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-server-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-clients-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-media-jaxb-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/aopalliance-repackaged-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-api-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/bin/../share/java/kafka/zkclient-0.10.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-http-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/javax.inject-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/maven-artifact-3.5.3.jar:/var/u00/confluent/bin/../share/java/kafka/scala-reflect-2.11.12.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-security-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-server-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-servlet-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/commons-beanutils-1.8.3.jar:/var/u00/confluent/bin/../share/java/kafka/argparse4j-0.7.0.jar:/var/u00/confluent/bin/../share/java/kafka/scala-logging_2.11-3.8.0.jar:/var/u00/confluent/bin/../share/java/kafka/common-utils-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-digester-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-kafka-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-core-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/cache-api-1.0.0.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-spring-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/spring-aop-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-beans-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-context-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-core-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-expression-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/curator-client-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-framework-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-recipes-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-x-discovery-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/guava-16.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-zookeeper-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/zookeeper-3.4.6.jar:/var/u00/confluent/bin/../share/java/kafka/connect-api-0.10.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-0.10.0.1.jar:/var/u00/confluent/bin/../share/java/confluent-support-metrics/*:/usr/share/java/confluent-support-metrics/*
os.spec = Linux, amd64, 3.10.0-693.21.1.el7.x86_64
os.vcpus = 2
(org.apache.kafka.connect.runtime.WorkerInfo:71)
[2018-07-31 13:28:46,023] INFO Scanning for plugin classes. This might take
a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:76)
[2018-07-31 13:28:51,003] INFO Registered loader:
sun.misc.Launcher$AppClassLoader@764c12b6
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.file.FileStreamSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.file.FileStreamSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.tools.MockSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.tools.MockSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.tools.SchemaSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,004] INFO Added plugin
'org.apache.kafka.connect.tools.MockConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,005] INFO Added plugin
'org.apache.kafka.connect.tools.VerifiableSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,005] INFO Added plugin
'org.apache.kafka.connect.tools.VerifiableSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,005] INFO Added plugin
'org.apache.ignite.stream.kafka.connect.IgniteSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,005] INFO Added plugin
'org.apache.kafka.connect.converters.ByteArrayConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,005] INFO Added plugin
'org.apache.kafka.connect.json.JsonConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.ignite.stream.kafka.connect.serialization.CacheEventConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.storage.StringConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'io.confluent.connect.avro.AvroConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.storage.SimpleHeaderConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.Cast$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.ValueToKey'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.InsertField$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.ExtractField$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,006] INFO Added plugin
'org.apache.kafka.connect.transforms.Cast$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.TimestampConverter$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.ExtractField$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.MaskField$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.RegexRouter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.ReplaceField$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.ReplaceField$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.InsertField$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.Flatten$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.TimestampConverter$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.HoistField$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.MaskField$Key'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.HoistField$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.Flatten$Value'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
[2018-07-31 13:28:51,007] INFO Added plugin
'org.apache.kafka.connect.transforms.TimestampRouter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
Jul 31, 2018 1:28:51 PM java.util.logging.LogManager$RootLogger log
SEVERE: Failed to resolve default logging config file:
config/java.util.logging.properties
[2018-07-31 13:28:51,044] DEBUG Registered java.sql.Driver:
org.apache.ignite.IgniteJdbcDriver@5a6d5a8f to java.sql.DriverManager
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:250)
[2018-07-31 13:28:51,044] DEBUG Registered java.sql.Driver:
org.apache.ignite.IgniteJdbcThinDriver@4a67318f to java.sql.DriverManager
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:250)
[2018-07-31 13:28:51,045] INFO Added aliases 'IgniteSinkConnector' and
'IgniteSink' to plugin
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,045] INFO Added aliases 'IgniteSourceConnector' and
'IgniteSource' to plugin
'org.apache.ignite.stream.kafka.connect.IgniteSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,045] INFO Added aliases 'FileStreamSinkConnector' and
'FileStreamSink' to plugin
'org.apache.kafka.connect.file.FileStreamSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,045] INFO Added aliases 'FileStreamSourceConnector' and
'FileStreamSource' to plugin
'org.apache.kafka.connect.file.FileStreamSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,045] INFO Added aliases 'MockConnector' and 'Mock' to
plugin 'org.apache.kafka.connect.tools.MockConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,045] INFO Added aliases 'MockSinkConnector' and
'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'MockSourceConnector' and
'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'SchemaSourceConnector' and
'SchemaSource' to plugin
'org.apache.kafka.connect.tools.SchemaSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'VerifiableSinkConnector' and
'VerifiableSink' to plugin
'org.apache.kafka.connect.tools.VerifiableSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'VerifiableSourceConnector' and
'VerifiableSource' to plugin
'org.apache.kafka.connect.tools.VerifiableSourceConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'AvroConverter' and 'Avro' to
plugin 'io.confluent.connect.avro.AvroConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'CacheEventConverter' and
'CacheEvent' to plugin
'org.apache.ignite.stream.kafka.connect.serialization.CacheEventConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'ByteArrayConverter' and
'ByteArray' to plugin
'org.apache.kafka.connect.converters.ByteArrayConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'JsonConverter' and 'Json' to
plugin 'org.apache.kafka.connect.json.JsonConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,046] INFO Added aliases 'StringConverter' and 'String'
to plugin 'org.apache.kafka.connect.storage.StringConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,047] INFO Added aliases 'ByteArrayConverter' and
'ByteArray' to plugin
'org.apache.kafka.connect.converters.ByteArrayConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,047] INFO Added aliases 'JsonConverter' and 'Json' to
plugin 'org.apache.kafka.connect.json.JsonConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,047] INFO Added alias 'SimpleHeaderConverter' to plugin
'org.apache.kafka.connect.storage.SimpleHeaderConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
[2018-07-31 13:28:51,047] INFO Added aliases 'StringConverter' and 'String'
to plugin 'org.apache.kafka.connect.storage.StringConverter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
[2018-07-31 13:28:51,048] INFO Added alias 'RegexRouter' to plugin
'org.apache.kafka.connect.transforms.RegexRouter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
[2018-07-31 13:28:51,048] INFO Added alias 'TimestampRouter' to plugin
'org.apache.kafka.connect.transforms.TimestampRouter'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
[2018-07-31 13:28:51,048] INFO Added alias 'ValueToKey' to plugin
'org.apache.kafka.connect.transforms.ValueToKey'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
[2018-07-31 13:28:51,058] INFO StandaloneConfig values:
access.control.allow.methods =
access.control.allow.origin =
bootstrap.servers = [1.2.3.4:9092]
header.converter = class
org.apache.kafka.connect.storage.SimpleHeaderConverter
internal.key.converter = class
org.apache.kafka.connect.storage.StringConverter
internal.value.converter = class
org.apache.kafka.connect.storage.StringConverter
key.converter = class
org.apache.kafka.connect.storage.StringConverter
listeners = null
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
offset.flush.interval.ms = 60000
offset.flush.timeout.ms = 5000
offset.storage.file.filename = /tmp/connect.offsets1
plugin.path = null
rest.advertised.host.name = null
rest.advertised.listener = null
rest.advertised.port = null
rest.host.name = null
rest.port = 8083
ssl.client.auth = none
task.shutdown.graceful.timeout.ms = 5000
value.converter = class
org.apache.kafka.connect.storage.StringConverter
(org.apache.kafka.connect.runtime.standalone.StandaloneConfig:279)
[2018-07-31 13:28:51,059] INFO Creating Kafka admin client
(org.apache.kafka.connect.util.ConnectUtils:43)
[2018-07-31 13:28:51,065] INFO AdminClientConfig values:
bootstrap.servers = [1.2.3.4:9092]
client.id =
connections.max.idle.ms = 300000
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 120000
retries = 5
retry.backoff.ms = 100
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
send.buffer.bytes = 131072
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:279)
[2018-07-31 13:28:51,084] DEBUG Added sensor with name connections-closed:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,086] DEBUG Added sensor with name connections-created:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,086] DEBUG Added sensor with name
successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,086] DEBUG Added sensor with name
failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,086] DEBUG Added sensor with name bytes-sent-received:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,087] DEBUG Added sensor with name bytes-sent:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,088] DEBUG Added sensor with name bytes-received:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,088] DEBUG Added sensor with name select-time:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,089] DEBUG Added sensor with name io-time:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,094] DEBUG Updated cluster metadata version 1 to
Cluster(id = null, nodes = [1.2.3.4:9092 (id: -1 rack: null)], partitions =
[]) (org.apache.kafka.clients.Metadata:270)
[2018-07-31 13:28:51,097] WARN The configuration
'key.converter.schemas.enable' was supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration 'internal.key.converter'
was supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration
'offset.storage.file.filename' was supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration
'internal.value.converter.schemas.enable' was supplied but isn't a known
config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration
'value.converter.schemas.enable' was supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration 'internal.value.converter'
was supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration 'value.converter' was
supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration
'internal.key.converter.schemas.enable' was supplied but isn't a known
config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] WARN The configuration 'key.converter' was
supplied but isn't a known config.
(org.apache.kafka.clients.admin.AdminClientConfig:287)
[2018-07-31 13:28:51,097] INFO Kafka version : 1.1.1-cp1
(org.apache.kafka.common.utils.AppInfoParser:109)
[2018-07-31 13:28:51,098] INFO Kafka commitId : 440b1a581a04ac59
(org.apache.kafka.common.utils.AppInfoParser:110)
[2018-07-31 13:28:51,099] DEBUG [AdminClient clientId=adminclient-1] Kafka
admin client initialized
(org.apache.kafka.clients.admin.KafkaAdminClient:381)
[2018-07-31 13:28:51,100] DEBUG Looking up Kafka cluster ID
(org.apache.kafka.connect.util.ConnectUtils:50)
[2018-07-31 13:28:51,101] DEBUG [AdminClient clientId=adminclient-1]
Queueing Call(callName=listNodes, deadlineMs=1533033051100) with a timeout
120000 ms from now. (org.apache.kafka.clients.admin.KafkaAdminClient:1045)
[2018-07-31 13:28:51,101] DEBUG Fetching Kafka cluster ID
(org.apache.kafka.connect.util.ConnectUtils:57)
[2018-07-31 13:28:51,194] DEBUG [AdminClient clientId=adminclient-1]
Initialize connection to node 1.2.3.4:9092 (id: -1 rack: null) for sending
metadata request (org.apache.kafka.clients.NetworkClient:943)
[2018-07-31 13:28:51,195] DEBUG [AdminClient clientId=adminclient-1]
Initiating connection to node 1.2.3.4:9092 (id: -1 rack: null)
(org.apache.kafka.clients.NetworkClient:791)
[2018-07-31 13:28:51,202] DEBUG Added sensor with name node--1.bytes-sent
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,203] DEBUG Added sensor with name
node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,203] DEBUG Added sensor with name node--1.latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,203] DEBUG [AdminClient clientId=adminclient-1] Created
socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1
(org.apache.kafka.common.network.Selector:474)
[2018-07-31 13:28:51,318] DEBUG [AdminClient clientId=adminclient-1]
Completed connection to node -1. Fetching API versions.
(org.apache.kafka.clients.NetworkClient:753)
[2018-07-31 13:28:51,318] DEBUG [AdminClient clientId=adminclient-1]
Initiating API versions fetch from node -1.
(org.apache.kafka.clients.NetworkClient:767)
[2018-07-31 13:28:51,326] DEBUG [AdminClient clientId=adminclient-1]
Recorded API versions for node -1: (Produce(0): 0 to 5 [usable: 5],
Fetch(1): 0 to 7 [usable: 7], ListOffsets(2): 0 to 2 [usable: 2],
Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1],
StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4],
ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable:
3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable:
1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1],
LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1],
DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1],
SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1],
CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1],
DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0],
OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable:
0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0],
WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0],
DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0],
DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 to 1 [usable: 1],
AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0],
DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0],
CreatePartitions(37): 0 [usable: 0], CreateDelegationToken(38): 0 [usable:
0], RenewDelegationToken(39): 0 [usable: 0], ExpireDelegationToken(40): 0
[usable: 0], DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42): 0
[usable: 0]) (org.apache.kafka.clients.NetworkClient:720)
[2018-07-31 13:28:51,326] DEBUG [AdminClient clientId=adminclient-1] Sending
metadata request (type=MetadataRequest, topics=) to node 1.2.3.4:9092 (id:
-1 rack: null) (org.apache.kafka.clients.NetworkClient:927)
[2018-07-31 13:28:51,327] INFO Cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
(org.apache.kafka.clients.Metadata:265)
[2018-07-31 13:28:51,327] DEBUG Updated cluster metadata version 2 to
Cluster(id = AGRLoUkJQ0GzKKfZwUj1wQ, nodes = [trukfk3:9092 (id: 1002 rack:
null), trukfk2:9092 (id: 1001 rack: null)], partitions = [])
(org.apache.kafka.clients.Metadata:270)
[2018-07-31 13:28:51,327] DEBUG [AdminClient clientId=adminclient-1]
Initiating connection to node trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.NetworkClient:791)
[2018-07-31 13:28:51,329] DEBUG Added sensor with name node-1002.bytes-sent
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,330] DEBUG Added sensor with name
node-1002.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,330] DEBUG Added sensor with name node-1002.latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1] Created
socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node
1002 (org.apache.kafka.common.network.Selector:474)
[2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1]
Completed connection to node 1002. Fetching API versions.
(org.apache.kafka.clients.NetworkClient:753)
[2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1]
Initiating API versions fetch from node 1002.
(org.apache.kafka.clients.NetworkClient:767)
[2018-07-31 13:28:51,332] DEBUG [AdminClient clientId=adminclient-1]
Recorded API versions for node 1002: (Produce(0): 0 to 5 [usable: 5],
Fetch(1): 0 to 7 [usable: 7], ListOffsets(2): 0 to 2 [usable: 2],
Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1],
StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4],
ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable:
3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable:
1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1],
LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1],
DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1],
SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1],
CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1],
DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0],
OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable:
0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0],
WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0],
DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0],
DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 to 1 [usable: 1],
AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0],
DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0],
CreatePartitions(37): 0 [usable: 0], CreateDelegationToken(38): 0 [usable:
0], RenewDelegationToken(39): 0 [usable: 0], ExpireDelegationToken(40): 0
[usable: 0], DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42): 0
[usable: 0]) (org.apache.kafka.clients.NetworkClient:720)
[2018-07-31 13:28:51,334] INFO Kafka cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
(org.apache.kafka.connect.util.ConnectUtils:59)
[2018-07-31 13:28:51,334] DEBUG [AdminClient clientId=adminclient-1]
Initiating close operation.
(org.apache.kafka.clients.admin.KafkaAdminClient:399)
[2018-07-31 13:28:51,334] DEBUG [AdminClient clientId=adminclient-1] Waiting
for the I/O thread to exit. Hard shutdown in 31536000000 ms.
(org.apache.kafka.clients.admin.KafkaAdminClient:415)
[2018-07-31 13:28:51,335] DEBUG Removed sensor with name connections-closed:
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,335] DEBUG Removed sensor with name
connections-created: (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,335] DEBUG Removed sensor with name
successful-authentication: (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,335] DEBUG Removed sensor with name
failed-authentication: (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,336] DEBUG Removed sensor with name
bytes-sent-received: (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,336] DEBUG Removed sensor with name bytes-sent:
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,336] DEBUG Removed sensor with name bytes-received:
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,336] DEBUG Removed sensor with name select-time:
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,336] DEBUG Removed sensor with name io-time:
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,337] DEBUG Removed sensor with name node--1.bytes-sent
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,337] DEBUG Removed sensor with name
node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,337] DEBUG Removed sensor with name node--1.latency
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,337] DEBUG Removed sensor with name
node-1002.bytes-sent (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,338] DEBUG Removed sensor with name
node-1002.bytes-received (org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,338] DEBUG Removed sensor with name node-1002.latency
(org.apache.kafka.common.metrics.Metrics:447)
[2018-07-31 13:28:51,338] DEBUG [AdminClient clientId=adminclient-1] Exiting
AdminClientRunnable thread.
(org.apache.kafka.clients.admin.KafkaAdminClient:1030)
[2018-07-31 13:28:51,338] DEBUG [AdminClient clientId=adminclient-1] Kafka
admin client closed. (org.apache.kafka.clients.admin.KafkaAdminClient:423)
[2018-07-31 13:28:51,338] DEBUG Kafka cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
(org.apache.kafka.connect.cli.ConnectStandalone:82)
[2018-07-31 13:28:51,346] DEBUG Logging to
org.slf4j.impl.Log4jLoggerAdapter(org.eclipse.jetty.util.log) via
org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:176)
[2018-07-31 13:28:51,348] INFO Logging initialized @5609ms
(org.eclipse.jetty.util.log:186)
[2018-07-31 13:28:51,355] DEBUG org.eclipse.jetty.server.Server@1500e009
added {qtp916958177{STOPPED,8<=0<=200,i=0,q=0},AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,363] DEBUG HttpConnectionFactory@7dc51783{HTTP/1.1}
added {HttpConfiguration@4b61d0c6{32768/8192,8192/8192,https://:0,[]},POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
added {org.eclipse.jetty.server.Server@1500e009,UNMANAGED}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
added {qtp916958177{STOPPED,8<=0<=200,i=0,q=0},AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
added
{org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,366] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
added {org.eclipse.jetty.io.ArrayByteBufferPool@6e4ea0bd,POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,366] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
added {HttpConnectionFactory@7dc51783{HTTP/1.1},AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,367] DEBUG
ServerConnector@62315f22{HTTP/1.1}{0.0.0.0:0} added
{org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2,MANAGED}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,367] INFO Added connector for http://:8083
(org.apache.kafka.connect.runtime.rest.RestServer:110)
[2018-07-31 13:28:51,367] DEBUG org.eclipse.jetty.server.Server@1500e009
added {http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083},AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,475] INFO Advertised URI: http://1.2.3.4:8083/
(org.apache.kafka.connect.runtime.rest.RestServer:248)
[2018-07-31 13:28:51,483] DEBUG Registering Connect metrics with JMX for
worker '1.2.3.4:8083' (org.apache.kafka.connect.runtime.ConnectMetrics:78)
[2018-07-31 13:28:51,483] INFO Kafka version : 1.1.1-cp1
(org.apache.kafka.common.utils.AppInfoParser:109)
[2018-07-31 13:28:51,483] INFO Kafka commitId : 440b1a581a04ac59
(org.apache.kafka.common.utils.AppInfoParser:110)
[2018-07-31 13:28:51,486] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;connector-startup-results
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,486] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;connector-startup-attempts
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;connector-startup-successes
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;connector-startup-failures
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;task-startup-results
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;task-startup-attempts
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;task-startup-successes
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,487] DEBUG Added sensor with name connect-sensor-group:
connect-worker-metrics;task-startup-failures
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,489] DEBUG Configuring the key converter with
configuration:
{schemas.enable=false}
(org.apache.kafka.connect.runtime.isolation.Plugins:237)
[2018-07-31 13:28:51,489] INFO StringConverterConfig values:
converter.encoding = UTF8
converter.type = key
(org.apache.kafka.connect.storage.StringConverterConfig:279)
[2018-07-31 13:28:51,490] DEBUG Configuring the value converter with
configuration:
{schemas.enable=false}
(org.apache.kafka.connect.runtime.isolation.Plugins:237)
[2018-07-31 13:28:51,490] INFO StringConverterConfig values:
converter.encoding = UTF8
converter.type = value
(org.apache.kafka.connect.storage.StringConverterConfig:279)
[2018-07-31 13:28:51,495] DEBUG Kafka Connect instance created
(org.apache.kafka.connect.runtime.Connect:41)
[2018-07-31 13:28:51,495] INFO Kafka Connect standalone worker
initialization took 5480ms
(org.apache.kafka.connect.cli.ConnectStandalone:92)
[2018-07-31 13:28:51,495] INFO Kafka Connect starting
(org.apache.kafka.connect.runtime.Connect:49)
[2018-07-31 13:28:51,496] INFO Herder starting
(org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)
[2018-07-31 13:28:51,496] INFO Worker starting
(org.apache.kafka.connect.runtime.Worker:139)
[2018-07-31 13:28:51,496] INFO Starting FileOffsetBackingStore with file
/tmp/connect.offsets1
(org.apache.kafka.connect.storage.FileOffsetBackingStore:59)
[2018-07-31 13:28:51,498] INFO Worker started
(org.apache.kafka.connect.runtime.Worker:144)
[2018-07-31 13:28:51,498] INFO Herder started
(org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)
[2018-07-31 13:28:51,498] INFO Starting REST server
(org.apache.kafka.connect.runtime.rest.RestServer:155)
[2018-07-31 13:28:51,546] DEBUG
org.eclipse.jetty.server.session.SessionHandler@320494b6 added
{org.eclipse.jetty.server.session.HashSessionManager@652ab8d9,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,546] DEBUG
o.e.j.s.ServletContextHandler@14fc5d40{/,null,null} added
{org.eclipse.jetty.server.session.SessionHandler@320494b6,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,548] DEBUG
org.eclipse.jetty.server.session.SessionHandler@320494b6 added
{org.eclipse.jetty.servlet.ServletHandler@50d3bf39,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,548] DEBUG
org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
{org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,549] DEBUG
org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
{[/*]=>org.glassfish.jersey.servlet.ServletContainer-281f23f2,POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,550] DEBUG
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c added
{org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,556] DEBUG
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
{o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,556] DEBUG
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
{org.eclipse.jetty.server.handler.DefaultHandler@59429fac,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,556] DEBUG
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
{org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,557] DEBUG
org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5 added
{org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c],AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,557] DEBUG org.eclipse.jetty.server.Server@1500e009
added {org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,557] DEBUG starting
org.eclipse.jetty.server.Server@1500e009
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,559] INFO jetty-9.2.24.v20180105
(org.eclipse.jetty.server.Server:327)
[2018-07-31 13:28:51,568] DEBUG starting
org.eclipse.jetty.server.Server@1500e009
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,568] DEBUG starting
qtp916958177{STOPPED,8<=0<=200,i=0,q=0}
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,569] DEBUG STARTED @5831ms
qtp916958177{STARTED,8<=8<=200,i=7,q=0}
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,569] DEBUG starting
org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,569] DEBUG starting
org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,569] DEBUG starting
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,570] DEBUG starting
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,570] DEBUG starting
o.e.j.s.ServletContextHandler@14fc5d40{/,null,null}
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,574] DEBUG starting
o.e.j.s.ServletContextHandler@14fc5d40{/,null,STARTING}
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,574] DEBUG starting
org.eclipse.jetty.server.session.SessionHandler@320494b6
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,574] DEBUG starting
org.eclipse.jetty.server.session.SessionHandler@320494b6
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,574] DEBUG starting
org.eclipse.jetty.server.session.HashSessionManager@652ab8d9
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,574] DEBUG
org.eclipse.jetty.server.session.HashSessionManager@652ab8d9 added
{org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969,MANAGED}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,575] DEBUG starting
org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,575] DEBUG STARTED @5837ms
org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,575] DEBUG org.eclipse.jetty.server.Server@1500e009
added
{org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7,MANAGED}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,576] DEBUG
org.eclipse.jetty.server.session.HashSessionManager@652ab8d9 added
{org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7,UNMANAGED}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,576] DEBUG starting
org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,576] DEBUG STARTED @5838ms
org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,577] DEBUG STARTED @5839ms
org.eclipse.jetty.server.session.HashSessionManager@652ab8d9
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,577] DEBUG starting
org.eclipse.jetty.servlet.ServletHandler@50d3bf39
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,578] DEBUG Chose path=/* mapped to
servlet=org.glassfish.jersey.servlet.ServletContainer-281f23f2 from
default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2018-07-31 13:28:51,579] DEBUG filterNameMap={}
(org.eclipse.jetty.servlet.ServletHandler:1516)
[2018-07-31 13:28:51,579] DEBUG pathFilters=null
(org.eclipse.jetty.servlet.ServletHandler:1517)
[2018-07-31 13:28:51,579] DEBUG servletFilterMap=null
(org.eclipse.jetty.servlet.ServletHandler:1518)
[2018-07-31 13:28:51,579] DEBUG
servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true}
(org.eclipse.jetty.servlet.ServletHandler:1519)
[2018-07-31 13:28:51,580] DEBUG
servletNameMap={org.glassfish.jersey.servlet.ServletContainer-281f23f2=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true}
(org.eclipse.jetty.servlet.ServletHandler:1520)
[2018-07-31 13:28:51,580] DEBUG Adding Default404Servlet to
org.eclipse.jetty.servlet.ServletHandler@50d3bf39
(org.eclipse.jetty.servlet.ServletHandler:165)
[2018-07-31 13:28:51,580] DEBUG
org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
{org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false,AUTO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,581] DEBUG
org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
{[/]=>org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa,POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,581] DEBUG Chose path=/* mapped to
servlet=org.glassfish.jersey.servlet.ServletContainer-281f23f2 from
default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2018-07-31 13:28:51,581] DEBUG Chose path=/ mapped to
servlet=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa
from default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2018-07-31 13:28:51,581] DEBUG filterNameMap={}
(org.eclipse.jetty.servlet.ServletHandler:1516)
[2018-07-31 13:28:51,582] DEBUG pathFilters=null
(org.eclipse.jetty.servlet.ServletHandler:1517)
[2018-07-31 13:28:51,582] DEBUG servletFilterMap=null
(org.eclipse.jetty.servlet.ServletHandler:1518)
[2018-07-31 13:28:51,582] DEBUG
servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true,
/=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false}
(org.eclipse.jetty.servlet.ServletHandler:1519)
[2018-07-31 13:28:51,582] DEBUG
servletNameMap={org.glassfish.jersey.servlet.ServletContainer-281f23f2=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true,
org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false}
(org.eclipse.jetty.servlet.ServletHandler:1520)
[2018-07-31 13:28:51,582] DEBUG starting
org.eclipse.jetty.servlet.ServletHandler@50d3bf39
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,582] DEBUG STARTED @5844ms
org.eclipse.jetty.servlet.ServletHandler@50d3bf39
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,582] DEBUG STARTED @5844ms
org.eclipse.jetty.server.session.SessionHandler@320494b6
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,582] DEBUG starting
org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,583] DEBUG STARTED @5845ms
org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,583] DEBUG starting
org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,583] DEBUG STARTED @5845ms
org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6==org.glassfish.jersey.servlet.ServletContainer,-1,true
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,584] DEBUG Servlet.init
org.glassfish.jersey.servlet.ServletContainer@38a1c423 for
org.glassfish.jersey.servlet.ServletContainer-281f23f2
(org.eclipse.jetty.servlet.ServletHolder:615)
[2018-07-31 13:28:51,902] INFO Started
o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE}
(org.eclipse.jetty.server.handler.ContextHandler:744)
[2018-07-31 13:28:51,902] DEBUG STARTED @6164ms
o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE}
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,902] DEBUG starting
org.eclipse.jetty.server.handler.DefaultHandler@59429fac
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,902] DEBUG starting
org.eclipse.jetty.server.handler.DefaultHandler@59429fac
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,902] DEBUG STARTED @6164ms
org.eclipse.jetty.server.handler.DefaultHandler@59429fac
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,902] DEBUG starting
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,902] DEBUG starting
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
(org.eclipse.jetty.server.handler.AbstractHandler:58)
[2018-07-31 13:28:51,902] DEBUG starting
org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
org.eclipse.jetty.server.handler.HandlerCollection@5cd61783[o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE},
org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,903] DEBUG starting
http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,906] DEBUG http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
added {sun.nio.ch.ServerSocketChannelImpl[/0:0:0:0:0:0:0:0:8083],POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,907] DEBUG starting
org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,907] DEBUG STARTED @6169ms
org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,907] DEBUG starting
HttpConnectionFactory@7dc51783{HTTP/1.1}
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,907] DEBUG STARTED @6169ms
HttpConnectionFactory@7dc51783{HTTP/1.1}
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,907] DEBUG starting
org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2
(org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,909] DEBUG starting
org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=-1
selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2018-07-31 13:28:51,909] DEBUG STARTED @6171ms
org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=0
selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,910] DEBUG STARTED @6172ms
org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,910] DEBUG http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
added {acceptor-0@7718a40f,POJO}
(org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2018-07-31 13:28:51,910] INFO Started
http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
(org.eclipse.jetty.server.ServerConnector:266)
[2018-07-31 13:28:51,911] DEBUG STARTED @6173ms
http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,911] INFO Started @6173ms
(org.eclipse.jetty.server.Server:379)
[2018-07-31 13:28:51,911] DEBUG STARTED @6173ms
org.eclipse.jetty.server.Server@1500e009
(org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2018-07-31 13:28:51,911] INFO Advertised URI: http://1.2.3.4:8083/
(org.apache.kafka.connect.runtime.rest.RestServer:248)
[2018-07-31 13:28:51,911] INFO REST server listening at
http://1.2.3.4:8083/, advertising URL http://1.2.3.4:8083/
(org.apache.kafka.connect.runtime.rest.RestServer:207)
[2018-07-31 13:28:51,911] INFO Kafka Connect started
(org.apache.kafka.connect.runtime.Connect:55)
[2018-07-31 13:28:51,912] DEBUG Getting plugin class loader for connector:
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
[2018-07-31 13:28:51,915] INFO ConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig:279)
[2018-07-31 13:28:51,916] INFO EnrichedConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
[2018-07-31 13:28:51,916] INFO Creating connector my-ignite-connector of
type org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
(org.apache.kafka.connect.runtime.Worker:202)
[2018-07-31 13:28:51,918] INFO Instantiated connector my-ignite-connector
with version 1.1.1-cp1 of type class
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
(org.apache.kafka.connect.runtime.Worker:205)
[2018-07-31 13:28:51,918] DEBUG Getting plugin class loader for connector:
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
[2018-07-31 13:28:51,918] DEBUG WorkerConnector{id=my-ignite-connector}
Initializing connector my-ignite-connector with config
{connector.class=org.apache.ignite.stream.kafka.connect.IgniteSinkConnector,
cacheName=mycache, tasks.max=1, topics=super_topic,
name=my-ignite-connector, cacheAllowOverwrite=true,
igniteCfg=/var/u00/ignite/config/clienttestconf.xml}
(org.apache.kafka.connect.runtime.WorkerConnector:79)
[2018-07-31 13:28:51,918] DEBUG WorkerConnector{id=my-ignite-connector}
Transition connector to STARTED
(org.apache.kafka.connect.runtime.WorkerConnector:190)
[2018-07-31 13:28:51,918] DEBUG Starting
Thread[qtp916958177-18-selector-ServerConnectorManager@48e7b3d2/0,5,main] on
org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=0
selected=0 (org.eclipse.jetty.io.SelectorManager:548)
[2018-07-31 13:28:51,919] DEBUG Selector loop waiting on select
(org.eclipse.jetty.io.SelectorManager:600)
[2018-07-31 13:28:51,919] INFO Finished creating connector
my-ignite-connector (org.apache.kafka.connect.runtime.Worker:224)
[2018-07-31 13:28:51,919] DEBUG Getting plugin class loader for connector:
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
[2018-07-31 13:28:51,920] INFO SinkConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
topics = [super_topic]
topics.regex =
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.SinkConnectorConfig:279)
[2018-07-31 13:28:51,920] INFO EnrichedConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
topics = [super_topic]
topics.regex =
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
[2018-07-31 13:28:51,920] DEBUG Getting plugin class loader for connector:
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
[2018-07-31 13:28:51,921] INFO Creating task my-ignite-connector-0
(org.apache.kafka.connect.runtime.Worker:362)
[2018-07-31 13:28:51,921] INFO ConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig:279)
[2018-07-31 13:28:51,921] INFO EnrichedConnectorConfig values:
connector.class =
org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
header.converter = null
key.converter = null
name = my-ignite-connector
tasks.max = 1
transforms = []
value.converter = null
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
[2018-07-31 13:28:51,921] DEBUG Getting plugin class loader for connector:
'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
[2018-07-31 13:28:51,922] INFO TaskConfig values:
task.class = class
org.apache.ignite.stream.kafka.connect.IgniteSinkTask
(org.apache.kafka.connect.runtime.TaskConfig:279)
[2018-07-31 13:28:51,922] INFO Instantiated task my-ignite-connector-0 with
version 1.1.1-cp1 of type
org.apache.ignite.stream.kafka.connect.IgniteSinkTask
(org.apache.kafka.connect.runtime.Worker:377)
[2018-07-31 13:28:51,922] DEBUG Configuring the key converter with
configuration:
{schemas.enable=false}
(org.apache.kafka.connect.runtime.isolation.Plugins:237)
[2018-07-31 13:28:51,922] INFO StringConverterConfig values:
converter.encoding = UTF8
converter.type = key
(org.apache.kafka.connect.storage.StringConverterConfig:279)
[2018-07-31 13:28:51,922] INFO Set up the key converter class
org.apache.kafka.connect.storage.StringConverter for task
my-ignite-connector-0 using the worker config
(org.apache.kafka.connect.runtime.Worker:400)
[2018-07-31 13:28:51,922] DEBUG Configuring the value converter with
configuration:
{schemas.enable=false}
(org.apache.kafka.connect.runtime.isolation.Plugins:237)
[2018-07-31 13:28:51,922] INFO StringConverterConfig values:
converter.encoding = UTF8
converter.type = value
(org.apache.kafka.connect.storage.StringConverterConfig:279)
[2018-07-31 13:28:51,922] INFO Set up the value converter class
org.apache.kafka.connect.storage.StringConverter for task
my-ignite-connector-0 using the worker config
(org.apache.kafka.connect.runtime.Worker:406)
[2018-07-31 13:28:51,922] DEBUG Configuring the header converter with
configuration:
{converter.type=header}
(org.apache.kafka.connect.runtime.isolation.Plugins:294)
[2018-07-31 13:28:51,923] INFO Set up the header converter class
org.apache.kafka.connect.storage.SimpleHeaderConverter for task
my-ignite-connector-0 using the worker config
(org.apache.kafka.connect.runtime.Worker:412)
[2018-07-31 13:28:51,926] DEBUG Added sensor with name connect-sensor-group:
connector-task-metrics;connector=my-ignite-connector;task=0;commit-time
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,926] DEBUG Added sensor with name connect-sensor-group:
connector-task-metrics;connector=my-ignite-connector;task=0;batch-size
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,926] DEBUG Added sensor with name connect-sensor-group:
connector-task-metrics;connector=my-ignite-connector;task=0;offset-commit-completion
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,927] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;sink-record-read
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,927] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;sink-record-send
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,930] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;sink-record-active-count
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,931] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;partition-count
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,931] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;offset-seq-number
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,931] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;offset-commit-completion
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,931] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;offset-commit-completion-skip
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,932] DEBUG Added sensor with name connect-sensor-group:
sink-task-metrics;connector=my-ignite-connector;task=0;put-batch-time
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,936] INFO ConsumerConfig values:
auto.commit.interval.ms = 5000
auto.offset.reset = earliest
bootstrap.servers = [1.2.3.4:9092]
check.crcs = true
client.id =
connections.max.idle.ms = 540000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = connect-my-ignite-connector
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
isolation.level = read_uncommitted
key.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy = [class
org.apache.kafka.clients.consumer.RangeAssignor]
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 305000
retry.backoff.ms = 100
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
send.buffer.bytes = 131072
session.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
(org.apache.kafka.clients.consumer.ConsumerConfig:279)
[2018-07-31 13:28:51,936] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initializing the Kafka consumer
(org.apache.kafka.clients.consumer.KafkaConsumer:662)
[2018-07-31 13:28:51,937] DEBUG Updated cluster metadata version 1 to
Cluster(id = null, nodes = [1.2.3.4:9092 (id: -1 rack: null)], partitions =
[]) (org.apache.kafka.clients.Metadata:270)
[2018-07-31 13:28:51,941] DEBUG Added sensor with name fetch-throttle-time
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,941] DEBUG Added sensor with name connections-closed:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,942] DEBUG Added sensor with name connections-created:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,942] DEBUG Added sensor with name
successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,942] DEBUG Added sensor with name
failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,942] DEBUG Added sensor with name bytes-sent-received:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,942] DEBUG Added sensor with name bytes-sent:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,943] DEBUG Added sensor with name bytes-received:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,943] DEBUG Added sensor with name select-time:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,943] DEBUG Added sensor with name io-time:
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,952] DEBUG Added sensor with name heartbeat-latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,952] DEBUG Added sensor with name join-latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,953] DEBUG Added sensor with name sync-latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,954] DEBUG Added sensor with name commit-latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,956] DEBUG Added sensor with name bytes-fetched
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,956] DEBUG Added sensor with name records-fetched
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,957] DEBUG Added sensor with name fetch-latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,957] DEBUG Added sensor with name records-lag
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:51,957] INFO Kafka version : 1.1.1-cp1
(org.apache.kafka.common.utils.AppInfoParser:109)
[2018-07-31 13:28:51,957] INFO Kafka commitId : 440b1a581a04ac59
(org.apache.kafka.common.utils.AppInfoParser:110)
[2018-07-31 13:28:51,957] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Kafka consumer initialized
(org.apache.kafka.clients.consumer.KafkaConsumer:787)
[2018-07-31 13:28:51,958] INFO Created connector my-ignite-connector
(org.apache.kafka.connect.cli.ConnectStandalone:104)
[2018-07-31 13:28:51,959] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Subscribed to topic(s): super_topic
(org.apache.kafka.clients.consumer.KafkaConsumer:913)
[2018-07-31 13:28:51,959] DEBUG WorkerSinkTask{id=my-ignite-connector-0}
Initializing and starting task for topics [super_topic]
(org.apache.kafka.connect.runtime.WorkerSinkTask:272)
[2018-07-31 13:28:52,009] DEBUG Adding [systemProperties] PropertySource
with lowest search precedence
(org.springframework.core.env.StandardEnvironment:109)
[2018-07-31 13:28:52,010] DEBUG Adding [systemEnvironment] PropertySource
with lowest search precedence
(org.springframework.core.env.StandardEnvironment:109)
[2018-07-31 13:28:52,010] DEBUG Initialized StandardEnvironment with
PropertySources [systemProperties,systemEnvironment]
(org.springframework.core.env.StandardEnvironment:124)
[2018-07-31 13:28:52,014] INFO Loading XML bean definitions from URL
[file:/var/u00/ignite/config/clienttestconf.xml]
(org.springframework.beans.factory.xml.XmlBeanDefinitionReader:317)
[2018-07-31 13:28:52,030] DEBUG Using JAXP provider
[com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderFactoryImpl]
(org.springframework.beans.factory.xml.DefaultDocumentLoader:73)
[2018-07-31 13:28:52,055] DEBUG Loading schema mappings from
[META-INF/spring.schemas]
(org.springframework.beans.factory.xml.PluggableSchemaResolver:141)
[2018-07-31 13:28:52,056] DEBUG Loaded schema mappings:
{http://www.springframework.org/schema/cache/spring-cache-4.2.xsd=org/springframework/cache/config/spring-cache-4.2.xsd,
http://www.springframework.org/schema/aop/spring-aop-4.1.xsd=org/springframework/aop/config/spring-aop-4.1.xsd,
http://www.springframework.org/schema/context/spring-context-3.1.xsd=org/springframework/context/config/spring-context-3.1.xsd,
http://www.springframework.org/schema/util/spring-util-3.0.xsd=org/springframework/beans/factory/xml/spring-util-3.0.xsd,
http://www.springframework.org/schema/tool/spring-tool.xsd=org/springframework/beans/factory/xml/spring-tool-4.3.xsd,
http://www.springframework.org/schema/aop/spring-aop-3.2.xsd=org/springframework/aop/config/spring-aop-3.2.xsd,
http://www.springframework.org/schema/lang/spring-lang-4.1.xsd=org/springframework/scripting/config/spring-lang-4.1.xsd,
http://www.springframework.org/schema/context/spring-context-4.0.xsd=org/springframework/context/config/spring-context-4.0.xsd,
http://www.springframework.org/schema/beans/spring-beans-4.2.xsd=org/springframework/beans/factory/xml/spring-beans-4.2.xsd,
http://www.springframework.org/schema/tool/spring-tool-4.1.xsd=org/springframework/beans/factory/xml/spring-tool-4.1.xsd,
http://www.springframework.org/schema/lang/spring-lang-3.2.xsd=org/springframework/scripting/config/spring-lang-3.2.xsd,
http://www.springframework.org/schema/cache/spring-cache-3.2.xsd=org/springframework/cache/config/spring-cache-3.2.xsd,
http://www.springframework.org/schema/jee/spring-jee-4.1.xsd=org/springframework/ejb/config/spring-jee-4.1.xsd,
http://www.springframework.org/schema/task/spring-task-4.2.xsd=org/springframework/scheduling/config/spring-task-4.2.xsd,
http://www.springframework.org/schema/util/spring-util-2.0.xsd=org/springframework/beans/factory/xml/spring-util-2.0.xsd,
http://www.springframework.org/schema/tool/spring-tool-3.2.xsd=org/springframework/beans/factory/xml/spring-tool-3.2.xsd,
http://www.springframework.org/schema/context/spring-context.xsd=org/springframework/context/config/spring-context-4.3.xsd,
http://www.springframework.org/schema/cache/spring-cache-4.1.xsd=org/springframework/cache/config/spring-cache-4.1.xsd,
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd=org/springframework/aop/config/spring-aop-4.0.xsd,
http://www.springframework.org/schema/jee/spring-jee-3.2.xsd=org/springframework/ejb/config/spring-jee-3.2.xsd,
http://www.springframework.org/schema/context/spring-context-3.0.xsd=org/springframework/context/config/spring-context-3.0.xsd,
http://www.springframework.org/schema/util/spring-util-2.5.xsd=org/springframework/beans/factory/xml/spring-util-2.5.xsd,
http://www.springframework.org/schema/util/spring-util-4.3.xsd=org/springframework/beans/factory/xml/spring-util-4.3.xsd,
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd=org/springframework/beans/factory/xml/spring-beans-3.2.xsd,
http://www.springframework.org/schema/aop/spring-aop-3.1.xsd=org/springframework/aop/config/spring-aop-3.1.xsd,
http://www.springframework.org/schema/lang/spring-lang-4.0.xsd=org/springframework/scripting/config/spring-lang-4.0.xsd,
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd=org/springframework/beans/factory/xml/spring-beans-4.1.xsd,
http://www.springframework.org/schema/tool/spring-tool-4.0.xsd=org/springframework/beans/factory/xml/spring-tool-4.0.xsd,
http://www.springframework.org/schema/lang/spring-lang-3.1.xsd=org/springframework/scripting/config/spring-lang-3.1.xsd,
http://www.springframework.org/schema/cache/spring-cache-3.1.xsd=org/springframework/cache/config/spring-cache-3.1.xsd,
http://www.springframework.org/schema/jee/spring-jee-4.0.xsd=org/springframework/ejb/config/spring-jee-4.0.xsd,
http://www.springframework.org/schema/task/spring-task-4.1.xsd=org/springframework/scheduling/config/spring-task-4.1.xsd,
http://www.springframework.org/schema/tool/spring-tool-3.1.xsd=org/springframework/beans/factory/xml/spring-tool-3.1.xsd,
http://www.springframework.org/schema/cache/spring-cache-4.0.xsd=org/springframework/cache/config/spring-cache-4.0.xsd,
http://www.springframework.org/schema/jee/spring-jee-3.1.xsd=org/springframework/ejb/config/spring-jee-3.1.xsd,
http://www.springframework.org/schema/task/spring-task-3.2.xsd=org/springframework/scheduling/config/spring-task-3.2.xsd,
http://www.springframework.org/schema/util/spring-util-4.2.xsd=org/springframework/beans/factory/xml/spring-util-4.2.xsd,
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd=org/springframework/beans/factory/xml/spring-beans-3.1.xsd,
http://www.springframework.org/schema/util/spring-util.xsd=org/springframework/beans/factory/xml/spring-util-4.3.xsd,
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd=org/springframework/aop/config/spring-aop-3.0.xsd,
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd=org/springframework/beans/factory/xml/spring-beans-4.0.xsd,
http://www.springframework.org/schema/beans/spring-beans.xsd=org/springframework/beans/factory/xml/spring-beans-4.3.xsd,
http://www.springframework.org/schema/lang/spring-lang-3.0.xsd=org/springframework/scripting/config/spring-lang-3.0.xsd,
http://www.springframework.org/schema/context/spring-context-2.5.xsd=org/springframework/context/config/spring-context-2.5.xsd,
http://www.springframework.org/schema/context/spring-context-4.3.xsd=org/springframework/context/config/spring-context-4.3.xsd,
http://www.springframework.org/schema/task/spring-task-4.0.xsd=org/springframework/scheduling/config/spring-task-4.0.xsd,
http://www.springframework.org/schema/tool/spring-tool-3.0.xsd=org/springframework/beans/factory/xml/spring-tool-3.0.xsd,
http://www.springframework.org/schema/aop/spring-aop-2.0.xsd=org/springframework/aop/config/spring-aop-2.0.xsd,
http://www.springframework.org/schema/jee/spring-jee-3.0.xsd=org/springframework/ejb/config/spring-jee-3.0.xsd,
http://www.springframework.org/schema/util/spring-util-4.1.xsd=org/springframework/beans/factory/xml/spring-util-4.1.xsd,
http://www.springframework.org/schema/task/spring-task-3.1.xsd=org/springframework/scheduling/config/spring-task-3.1.xsd,
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd=org/springframework/beans/factory/xml/spring-beans-3.0.xsd,
http://www.springframework.org/schema/jee/spring-jee.xsd=org/springframework/ejb/config/spring-jee-4.3.xsd,
http://www.springframework.org/schema/aop/spring-aop-2.5.xsd=org/springframework/aop/config/spring-aop-2.5.xsd,
http://www.springframework.org/schema/aop/spring-aop-4.3.xsd=org/springframework/aop/config/spring-aop-4.3.xsd,
http://www.springframework.org/schema/lang/spring-lang-2.0.xsd=org/springframework/scripting/config/spring-lang-2.0.xsd,
http://www.springframework.org/schema/util/spring-util-3.2.xsd=org/springframework/beans/factory/xml/spring-util-3.2.xsd,
http://www.springframework.org/schema/task/spring-task.xsd=org/springframework/scheduling/config/spring-task-4.3.xsd,
http://www.springframework.org/schema/tool/spring-tool-2.0.xsd=org/springframework/beans/factory/xml/spring-tool-2.0.xsd,
http://www.springframework.org/schema/lang/spring-lang-2.5.xsd=org/springframework/scripting/config/spring-lang-2.5.xsd,
http://www.springframework.org/schema/lang/spring-lang-4.3.xsd=org/springframework/scripting/config/spring-lang-4.3.xsd,
http://www.springframework.org/schema/context/spring-context-4.2.xsd=org/springframework/context/config/spring-context-4.2.xsd,
http://www.springframework.org/schema/jee/spring-jee-2.0.xsd=org/springframework/ejb/config/spring-jee-2.0.xsd,
http://www.springframework.org/schema/tool/spring-tool-4.3.xsd=org/springframework/beans/factory/xml/spring-tool-4.3.xsd,
http://www.springframework.org/schema/tool/spring-tool-2.5.xsd=org/springframework/beans/factory/xml/spring-tool-2.5.xsd,
http://www.springframework.org/schema/jee/spring-jee-4.3.xsd=org/springframework/ejb/config/spring-jee-4.3.xsd,
http://www.springframework.org/schema/jee/spring-jee-2.5.xsd=org/springframework/ejb/config/spring-jee-2.5.xsd,
http://www.springframework.org/schema/util/spring-util-4.0.xsd=org/springframework/beans/factory/xml/spring-util-4.0.xsd,
http://www.springframework.org/schema/task/spring-task-3.0.xsd=org/springframework/scheduling/config/spring-task-3.0.xsd,
http://www.springframework.org/schema/cache/spring-cache-4.3.xsd=org/springframework/cache/config/spring-cache-4.3.xsd,
http://www.springframework.org/schema/aop/spring-aop-4.2.xsd=org/springframework/aop/config/spring-aop-4.2.xsd,
http://www.springframework.org/schema/lang/spring-lang.xsd=org/springframework/scripting/config/spring-lang-4.3.xsd,
http://www.springframework.org/schema/context/spring-context-3.2.xsd=org/springframework/context/config/spring-context-3.2.xsd,
http://www.springframework.org/schema/util/spring-util-3.1.xsd=org/springframework/beans/factory/xml/spring-util-3.1.xsd,
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd=org/springframework/beans/factory/xml/spring-beans-2.0.xsd,
http://www.springframework.org/schema/cache/spring-cache.xsd=org/springframework/cache/config/spring-cache-4.3.xsd,
http://www.springframework.org/schema/lang/spring-lang-4.2.xsd=org/springframework/scripting/config/spring-lang-4.2.xsd,
http://www.springframework.org/schema/context/spring-context-4.1.xsd=org/springframework/context/config/spring-context-4.1.xsd,
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd=org/springframework/beans/factory/xml/spring-beans-2.5.xsd,
http://www.springframework.org/schema/beans/spring-beans-4.3.xsd=org/springframework/beans/factory/xml/spring-beans-4.3.xsd,
http://www.springframework.org/schema/tool/spring-tool-4.2.xsd=org/springframework/beans/factory/xml/spring-tool-4.2.xsd,
http://www.springframework.org/schema/jee/spring-jee-4.2.xsd=org/springframework/ejb/config/spring-jee-4.2.xsd,
http://www.springframework.org/schema/task/spring-task-4.3.xsd=org/springframework/scheduling/config/spring-task-4.3.xsd,
http://www.springframework.org/schema/aop/spring-aop.xsd=org/springframework/aop/config/spring-aop-4.3.xsd}
(org.springframework.beans.factory.xml.PluggableSchemaResolver:147)
[2018-07-31 13:28:52,057] DEBUG Found XML schema
[http://www.springframework.org/schema/beans/spring-beans.xsd] in classpath:
org/springframework/beans/factory/xml/spring-beans-4.3.xsd
(org.springframework.beans.factory.xml.PluggableSchemaResolver:119)
[2018-07-31 13:28:52,095] DEBUG Loading bean definitions
(org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader:92)
[2018-07-31 13:28:52,105] DEBUG Neither XML 'id' nor 'name' specified -
using generated bean name
[org.apache.ignite.spi.discovery.zk.ZookeeperDiscoverySpi#7ea067d7]
(org.springframework.beans.factory.xml.BeanDefinitionParserDelegate:481)
[2018-07-31 13:28:52,106] DEBUG Neither XML 'id' nor 'name' specified -
using generated bean name
[org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction#6285b067]
(org.springframework.beans.factory.xml.BeanDefinitionParserDelegate:481)
[2018-07-31 13:28:52,106] DEBUG Neither XML 'id' nor 'name' specified -
using generated bean name
[org.apache.ignite.configuration.CacheConfiguration#1f66ed3f]
(org.springframework.beans.factory.xml.BeanDefinitionParserDelegate:481)
[2018-07-31 13:28:52,109] INFO Refreshing
org.springframework.context.support.GenericApplicationContext@5812d030:
startup date [Tue Jul 31 13:28:52 MSK 2018]; root of context hierarchy
(org.springframework.context.support.GenericApplicationContext:582)
[2018-07-31 13:28:52,110] DEBUG Bean factory for
org.springframework.context.support.GenericApplicationContext@5812d030:
org.springframework.beans.factory.support.DefaultListableBeanFactory@6c6c4aa5:
defining beans [ignite.cfg]; root of factory hierarchy
(org.springframework.context.support.GenericApplicationContext:616)
[2018-07-31 13:28:52,124] DEBUG Unable to locate MessageSource with name
'messageSource': using default
[org.springframework.context.support.DelegatingMessageSource@40a7fa5b]
(org.springframework.context.support.GenericApplicationContext:733)
[2018-07-31 13:28:52,125] DEBUG Unable to locate ApplicationEventMulticaster
with name 'applicationEventMulticaster': using default
[org.springframework.context.event.SimpleApplicationEventMulticaster@64d7f90a]
(org.springframework.context.support.GenericApplicationContext:757)
[2018-07-31 13:28:52,126] DEBUG Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@6c6c4aa5:
defining beans [ignite.cfg]; root of factory hierarchy
(org.springframework.beans.factory.support.DefaultListableBeanFactory:730)
[2018-07-31 13:28:52,126] DEBUG Creating shared instance of singleton bean
'ignite.cfg'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:221)
[2018-07-31 13:28:52,126] DEBUG Creating instance of bean 'ignite.cfg'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:449)
[2018-07-31 13:28:52,140] DEBUG Eagerly caching bean 'ignite.cfg' to allow
for resolving potential circular references
(org.springframework.beans.factory.support.DefaultListableBeanFactory:539)
[2018-07-31 13:28:52,188] DEBUG Creating instance of bean
'org.apache.ignite.spi.discovery.zk.ZookeeperDiscoverySpi#7ea067d7'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:449)
[2018-07-31 13:28:52,206] DEBUG Finished creating instance of bean
'org.apache.ignite.spi.discovery.zk.ZookeeperDiscoverySpi#7ea067d7'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:485)
[2018-07-31 13:28:52,206] DEBUG Creating instance of bean
'org.apache.ignite.configuration.CacheConfiguration#1f66ed3f'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:449)
[2018-07-31 13:28:52,231] DEBUG No property editor
[org.apache.ignite.cache.CacheAtomicityModeEditor] found for type
org.apache.ignite.cache.CacheAtomicityMode according to 'Editor' suffix
convention (org.springframework.beans.BeanUtils:450)
[2018-07-31 13:28:52,231] DEBUG No property editor
[org.apache.ignite.cache.CacheModeEditor] found for type
org.apache.ignite.cache.CacheMode according to 'Editor' suffix convention
(org.springframework.beans.BeanUtils:450)
[2018-07-31 13:28:52,231] DEBUG Creating instance of bean
'org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction#6285b067'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:449)
[2018-07-31 13:28:52,235] DEBUG Finished creating instance of bean
'org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction#6285b067'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:485)
[2018-07-31 13:28:52,235] DEBUG Finished creating instance of bean
'org.apache.ignite.configuration.CacheConfiguration#1f66ed3f'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:485)
[2018-07-31 13:28:52,235] DEBUG Finished creating instance of bean
'ignite.cfg'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:485)
[2018-07-31 13:28:52,236] DEBUG Unable to locate LifecycleProcessor with
name 'lifecycleProcessor': using default
[org.springframework.context.support.DefaultLifecycleProcessor@752a1e45]
(org.springframework.context.support.GenericApplicationContext:784)
[2018-07-31 13:28:52,237] DEBUG Returning cached instance of singleton bean
'lifecycleProcessor'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:251)
[2018-07-31 13:28:52,243] DEBUG Could not find key
'spring.liveBeansView.mbeanDomain' in any property source
(org.springframework.core.env.PropertySourcesPropertyResolver:91)
[2018-07-31 13:28:52,244] DEBUG Returning cached instance of singleton bean
'ignite.cfg'
(org.springframework.beans.factory.support.DefaultListableBeanFactory:251)
[13:28:52] __________ ________________
[13:28:52] / _/ ___/ |/ / _/_ __/ __/
[13:28:52] _/ // (7 7 // / / / / _/
[13:28:52] /___/\___/_/|_/___/ /_/ /___/
[13:28:52]
[13:28:52] ver. 2.5.0#20180523-sha1:86e110c7
[13:28:52] 2018 Copyright(C) Apache Software Foundation
[13:28:52]
[13:28:52] Ignite documentation: http://ignite.apache.org
[13:28:52]
[13:28:52] Quiet mode.
[13:28:52] ^-- Logging by 'JavaLogger [quiet=true, config=null]'
[13:28:52] ^-- To see **FULL** console log here add -DIGNITE_QUIET=false
or "-v" to ignite.{sh|bat}
[13:28:52]
[13:28:52] OS: Linux 3.10.0-693.21.1.el7.x86_64 amd64
[13:28:52] VM information: OpenJDK Runtime Environment 1.8.0_171-b10 Oracle
Corporation OpenJDK 64-Bit Server VM 25.171-b10
[13:28:52] Initial heap size is 256MB (should be no less than 512MB, use
-Xms512m -Xmx512m).
[13:28:52] Configured plugins:
[13:28:52] ^-- None
[13:28:52]
[13:28:52] Configured failure handler: [hnd=StopNodeOrHaltFailureHandler
[tryStop=false, timeout=0]]
[13:28:52] Message queue limit is set to 0 which may lead to potential OOMEs
when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes due to
message queues growth on sender and receiver sides.
[13:28:52] Security status [authentication=off, tls/ssl=off]
[13:28:52] REST protocols do not start on client node. To start the
protocols on client node set '-DIGNITE_REST_START_ON_CLIENT=true' system
property.
[13:28:53] Performance suggestions for grid 'testGrid' (fix if possible)
[13:28:53] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
[13:28:53] ^-- Set max direct memory size if getting 'OOME: Direct buffer
memory' (add '-XX:MaxDirectMemorySize=<size>[g|G|m|M|k|K]' to JVM options)
[13:28:53] ^-- Disable processing of calls to System.gc() (add
'-XX:+DisableExplicitGC' to JVM options)
[13:28:53] ^-- Speed up flushing of dirty pages by OS (alter
vm.dirty_expire_centisecs parameter by setting to 500)
[13:28:53] ^-- Reduce pages swapping ratio (set vm.swappiness=10)
[13:28:53] ^-- Decrease number of backups (set 'backups' to 0)
[13:28:53] Refer to this page for more performance suggestions:
https://apacheignite.readme.io/docs/jvm-and-system-tuning
[13:28:53]
[13:28:53] To start Console Management & Monitoring run
ignitevisorcmd.{sh|bat}
[13:28:53]
[13:28:53] Ignite node started OK (id=6e8a7f63, instance name=testGrid)
[13:28:53] Topology snapshot [ver=4, servers=1, clients=1, CPUs=4,
offheap=1.5GB, heap=3.0GB]
[13:28:53] ^-- Node [id=6E8A7F63-4870-4E37-A5E3-D7B2A964BE81,
clusterState=ACTIVE]
[2018-07-31 13:28:53,166] INFO WorkerSinkTask{id=my-ignite-connector-0} Sink
task finished initialization and start
(org.apache.kafka.connect.runtime.WorkerSinkTask:282)
[2018-07-31 13:28:53,166] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending FindCoordinator request to
broker 1.2.3.4:9092 (id: -1 rack: null)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:579)
[2018-07-31 13:28:53,168] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating connection to node
1.2.3.4:9092 (id: -1 rack: null)
(org.apache.kafka.clients.NetworkClient:791)
[2018-07-31 13:28:53,168] DEBUG Added sensor with name node--1.bytes-sent
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,169] DEBUG Added sensor with name
node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,169] DEBUG Added sensor with name node--1.latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,169] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Created socket with SO_RCVBUF = 65536,
SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1
(org.apache.kafka.common.network.Selector:474)
[2018-07-31 13:28:53,169] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Completed connection to node -1.
Fetching API versions. (org.apache.kafka.clients.NetworkClient:753)
[2018-07-31 13:28:53,169] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating API versions fetch from node
-1. (org.apache.kafka.clients.NetworkClient:767)
[2018-07-31 13:28:53,172] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Recorded API versions for node -1:
(Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 7 [usable: 7],
ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5],
LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0],
UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1
[usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3
[usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2
[usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1
[usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1
[usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1
[usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2
[usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0
[usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0
[usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0
[usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0],
TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0],
CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0],
DescribeConfigs(32): 0 to 1 [usable: 1], AlterConfigs(33): 0 [usable: 0],
AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0],
SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0],
CreateDelegationToken(38): 0 [usable: 0], RenewDelegationToken(39): 0
[usable: 0], ExpireDelegationToken(40): 0 [usable: 0],
DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42): 0 [usable: 0])
(org.apache.kafka.clients.NetworkClient:720)
[2018-07-31 13:28:53,173] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending metadata request
(type=MetadataRequest, topics=super_topic) to node 1.2.3.4:9092 (id: -1
rack: null) (org.apache.kafka.clients.NetworkClient:927)
[2018-07-31 13:28:53,177] INFO Cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
(org.apache.kafka.clients.Metadata:265)
[2018-07-31 13:28:53,177] DEBUG Updated cluster metadata version 2 to
Cluster(id = AGRLoUkJQ0GzKKfZwUj1wQ, nodes = [trukfk2:9092 (id: 1001 rack:
null), trukfk3:9092 (id: 1002 rack: null)], partitions = [Partition(topic =
super_topic, partition = 0, leader = 1002, replicas = [1002,1001], isr =
[1002,1001], offlineReplicas = []), Partition(topic = super_topic, partition
= 1, leader = 1002, replicas = [1001,1002], isr = [1002,1001],
offlineReplicas = [])]) (org.apache.kafka.clients.Metadata:270)
[2018-07-31 13:28:53,178] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Received FindCoordinator response
ClientResponse(receivedTimeMs=1533032933178, latencyMs=12,
disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR,
apiVersion=1, clientId=consumer-1, correlationId=0),
responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null',
error=NONE, node=trukfk2:9092 (id: 1001 rack: null)))
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:590)
[2018-07-31 13:28:53,178] INFO [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Discovered group coordinator
trukfk2:9092 (id: 2147482646 rack: null)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:605)
[2018-07-31 13:28:53,178] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating connection to node
trukfk2:9092 (id: 2147482646 rack: null)
(org.apache.kafka.clients.NetworkClient:791)
[2018-07-31 13:28:53,180] INFO [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Revoking previously assigned partitions
[] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:411)
[2018-07-31 13:28:53,180] DEBUG WorkerSinkTask{id=my-ignite-connector-0}
Partitions revoked (org.apache.kafka.connect.runtime.WorkerSinkTask:645)
[2018-07-31 13:28:53,180] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Disabling heartbeat thread
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:907)
[2018-07-31 13:28:53,180] INFO [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] (Re-)joining group
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:442)
[2018-07-31 13:28:53,181] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending JoinGroup ((type:
JoinGroupRequest, groupId=connect-my-ignite-connector, sessionTimeout=10000,
rebalanceTimeout=300000, memberId=, protocolType=consumer,
groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@a503589))
to coordinator trukfk2:9092 (id: 2147482646 rack: null)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:450)
[2018-07-31 13:28:53,182] DEBUG Added sensor with name
node-2147482646.bytes-sent (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,183] DEBUG Added sensor with name
node-2147482646.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,183] DEBUG Added sensor with name
node-2147482646.latency (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,183] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Created socket with SO_RCVBUF = 65536,
SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147482646
(org.apache.kafka.common.network.Selector:474)
[2018-07-31 13:28:53,183] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Completed connection to node
2147482646. Fetching API versions.
(org.apache.kafka.clients.NetworkClient:753)
[2018-07-31 13:28:53,183] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating API versions fetch from node
2147482646. (org.apache.kafka.clients.NetworkClient:767)
[2018-07-31 13:28:53,185] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Heartbeat thread started
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:930)
[2018-07-31 13:28:53,186] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Recorded API versions for node
2147482646: (Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 7 [usable: 7],
ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5],
LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0],
UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1
[usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3
[usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2
[usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1
[usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1
[usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1
[usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2
[usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0
[usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0
[usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0
[usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0],
TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0],
CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0],
DescribeConfigs(32): 0 to 1 [usable: 1], AlterConfigs(33): 0 [usable: 0],
AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0],
SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0],
CreateDelegationToken(38): 0 [usable: 0], RenewDelegationToken(39): 0
[usable: 0], ExpireDelegationToken(40): 0 [usable: 0],
DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42): 0 [usable: 0])
(org.apache.kafka.clients.NetworkClient:720)
[2018-07-31 13:28:53,188] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Received successful JoinGroup response:
JoinGroupResponse(throttleTimeMs=0, error=NONE, generationId=58,
groupProtocol=range,
memberId=consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1,
leaderId=consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1,
members=consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:460)
[2018-07-31 13:28:53,188] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Performing assignment using strategy
range with subscriptions
{consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1=Subscription(topics=[super_topic])}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:356)
[2018-07-31 13:28:53,189] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Finished assignment for group:
{consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1=Assignment(partitions=[super_topic-0,
super_topic-1])}
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:393)
[2018-07-31 13:28:53,189] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending leader SyncGroup to coordinator
trukfk2:9092 (id: 2147482646 rack: null): (type=SyncGroupRequest,
groupId=connect-my-ignite-connector, generationId=58,
memberId=consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1,
groupAssignment=consumer-1-16d02cac-5c10-440a-a9f9-df82eaa655b1)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:525)
[2018-07-31 13:28:53,191] INFO [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Successfully joined group with
generation 58
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:409)
[2018-07-31 13:28:53,192] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Enabling heartbeat thread
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:898)
[2018-07-31 13:28:53,192] INFO [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Setting newly assigned partitions
[super_topic-0, super_topic-1]
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:256)
[2018-07-31 13:28:53,192] DEBUG WorkerSinkTask{id=my-ignite-connector-0}
Partitions assigned [super_topic-0, super_topic-1]
(org.apache.kafka.connect.runtime.WorkerSinkTask:604)
[2018-07-31 13:28:53,193] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Fetching committed offsets for
partitions: [super_topic-0, super_topic-1]
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:808)
[2018-07-31 13:28:53,195] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Setting offset for partition
super_topic-0 to the committed offset 73
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:450)
[2018-07-31 13:28:53,195] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Setting offset for partition
super_topic-1 to the committed offset 87
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:450)
[2018-07-31 13:28:53,296] DEBUG
org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance@614ca6b1
Assigned topic partition super_topic-0 with offset 73
(org.apache.kafka.connect.runtime.WorkerSinkTask:611)
[2018-07-31 13:28:53,296] DEBUG
org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance@614ca6b1
Assigned topic partition super_topic-1 with offset 87
(org.apache.kafka.connect.runtime.WorkerSinkTask:611)
[2018-07-31 13:28:53,298] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:53,298] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:53,299] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built full fetch (sessionId=INVALID,
epoch=INITIAL) for node 1002 with 2 partition(s).
(org.apache.kafka.clients.FetchSessionHandler:199)
[2018-07-31 13:28:53,299] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
FullFetchRequest(super_topic-0, super_topic-1) to broker trukfk3:9092 (id:
1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:53,300] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating connection to node
trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.NetworkClient:791)
[2018-07-31 13:28:53,301] DEBUG Added sensor with name node-1002.bytes-sent
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,301] DEBUG Added sensor with name
node-1002.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,301] DEBUG Added sensor with name node-1002.latency
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,302] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Created socket with SO_RCVBUF = 65536,
SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 1002
(org.apache.kafka.common.network.Selector:474)
[2018-07-31 13:28:53,302] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Completed connection to node 1002.
Fetching API versions. (org.apache.kafka.clients.NetworkClient:753)
[2018-07-31 13:28:53,302] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Initiating API versions fetch from node
1002. (org.apache.kafka.clients.NetworkClient:767)
[2018-07-31 13:28:53,304] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Recorded API versions for node 1002:
(Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 7 [usable: 7],
ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5],
LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0],
UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1
[usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3
[usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2
[usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1
[usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1
[usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1
[usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2
[usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0
[usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0
[usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0
[usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0],
TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0],
CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0],
DescribeConfigs(32): 0 to 1 [usable: 1], AlterConfigs(33): 0 [usable: 0],
AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0],
SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0],
CreateDelegationToken(38): 0 [usable: 0], RenewDelegationToken(39): 0
[usable: 0], ExpireDelegationToken(40): 0 [usable: 0],
DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42): 0 [usable: 0])
(org.apache.kafka.clients.NetworkClient:720)
[2018-07-31 13:28:53,810] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent a full fetch response
that created a new incremental fetch session 552465624 with 2 response
partition(s) (org.apache.kafka.clients.FetchSessionHandler:404)
[2018-07-31 13:28:53,811] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Fetch READ_UNCOMMITTED at offset 73 for
partition super_topic-0 returned fetch data (error=NONE, highWaterMark=73,
lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null,
recordsSizeInBytes=0)
(org.apache.kafka.clients.consumer.internals.Fetcher:224)
[2018-07-31 13:28:53,812] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Fetch READ_UNCOMMITTED at offset 87 for
partition super_topic-1 returned fetch data (error=NONE, highWaterMark=87,
lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null,
recordsSizeInBytes=0)
(org.apache.kafka.clients.consumer.internals.Fetcher:224)
[2018-07-31 13:28:53,814] DEBUG Added sensor with name
super_topic-0.records-lag (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,815] DEBUG Added sensor with name
topic.super_topic.bytes-fetched
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,815] DEBUG Added sensor with name
topic.super_topic.records-fetched
(org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,815] DEBUG Added sensor with name
super_topic-1.records-lag (org.apache.kafka.common.metrics.Metrics:414)
[2018-07-31 13:28:53,815] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:53,816] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:53,816] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=1) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:53,816] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:54,317] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:54,317] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:54,317] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:54,318] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=2) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:54,318] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:54,819] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:54,820] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:54,820] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:54,820] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=3) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:54,820] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:55,321] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:55,321] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:55,321] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:55,321] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=4) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:55,321] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:55,824] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:55,824] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:55,824] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:55,824] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=5) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:55,824] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:56,193] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending Heartbeat request to
coordinator trukfk2:9092 (id: 2147482646 rack: null)
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:761)
[2018-07-31 13:28:56,195] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Received successful Heartbeat response
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator:774)
[2018-07-31 13:28:56,327] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:56,327] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:56,327] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:56,327] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=6) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:56,327] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:56,829] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:56,830] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:56,830] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:56,830] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=7) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:56,830] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:57,332] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:57,332] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:57,332] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:57,333] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=8) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:57,333] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:57,834] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:57,834] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:57,834] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:57,834] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Built incremental fetch
(sessionId=552465624, epoch=9) for node 1002. Added 0 partition(s), altered
0 partition(s), removed 0 partition(s) out of 2 partition(s)
(org.apache.kafka.clients.FetchSessionHandler:252)
[2018-07-31 13:28:57,834] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Sending READ_UNCOMMITTED
IncrementalFetchRequest(toSend=(), toForget=(), implied=(super_topic-0,
super_topic-1)) to broker trukfk3:9092 (id: 1002 rack: null)
(org.apache.kafka.clients.consumer.internals.Fetcher:199)
[2018-07-31 13:28:58,336] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Node 1002 sent an incremental fetch
response for session 552465624 with 0 response partition(s), 2 implied
partition(s) (org.apache.kafka.clients.FetchSessionHandler:423)
[2018-07-31 13:28:58,336] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-0 at offset 73 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
[2018-07-31 13:28:58,336] DEBUG [Consumer clientId=consumer-1,
groupId=connect-my-ignite-connector] Added READ_UNCOMMITTED fetch request
for partition super_topic-1 at offset 87 to node trukfk3:9092 (id: 1002
rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:843)
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Re: Streaming Data via Kafka Connect
Posted by Denis Mekhanikov <dm...@gmail.com>.
Matvey,
Please don't paste long text files to the message body. Use the file
attachment instead.
I don't see a tuple extractor in your configuration. Did you specify it?
Kafka streamer needs it to convert incoming messages into pairs of keys and
values.
You can find a working example in the following test:
KafkaIgniteStreamerSelfTest
<https://github.com/apache/ignite/blob/master/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/KafkaIgniteStreamerSelfTest.java>
Denis
вт, 31 июл. 2018 г. в 13:43, matvey <ma...@gmail.com>:
> Hello. I want to stream data from Kafka to Ignite cache, and I'm using this
> guide https://apacheignite-mix.readme.io/v2.6/docs/kafka-streamer. I use
> confluent for these purposes.
> The problem is that after I start connector (bin/connect-standalone
> etc/kafka/connect-standalone-ignite.properties
> etc/kafka/ignite-connector.properties), the cache remains empty (I use
> ignitevisor and web console to check). Topic, which I use is not empty.
> Here are my configs. Thank you in advance.
>
> --connect-standalone-ignite.properties--
>
> bootstrap.servers=1.2.3.4:9092
>
> key.converter=org.apache.kafka.connect.storage.StringConverter
> value.converter=org.apache.kafka.connect.storage.StringConverter
> key.converter.schemas.enable=false
> value.converter.schemas.enable=false
>
> internal.key.converter=org.apache.kafka.connect.storage.StringConverter
> internal.value.converter=org.apache.kafka.connect.storage.StringConverter
> internal.key.converter.schemas.enable=false
> internal.value.converter.schemas.enable=false
>
>
> offset.storage.file.filename=/tmp/connect.offsets1
>
>
> --ignite-connector.properties--
>
> # connector
> name=my-ignite-connector
> connector.class=org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> tasks.max=1
> topics=super_topic
>
> # cache
> cacheName=mycache
> cacheAllowOverwrite=true
> igniteCfg=/var/u00/ignite/config/clienttestconf.xml
>
>
> --clienttestconf.xml--
>
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd">
>
> <bean id="ignite.cfg"
> class="org.apache.ignite.configuration.IgniteConfiguration">
> <property name="gridName" value="testGrid"/>
> <property name="clientMode" value="true"/>
>
>
>
> <property name="discoverySpi">
> <bean class="org.apache.ignite.spi.discovery.zk.ZookeeperDiscoverySpi">
> <property name="zkConnectionString"
> value="truzookeepera:2181,truzookeeperb:2181"/>
> <property name="sessionTimeout" value="30000"/>
> <property name="zkRootPath" value="/apacheIgnite"/>
> <property name="joinTimeout" value="10000"/>
> </bean>
> </property>
>
> <property name="cacheConfiguration">
> <bean
> class="org.apache.ignite.configuration.CacheConfiguration">
>
> <property name="name" value="mycache"/>
>
> <property name="atomicityMode"
> value="ATOMIC"/>
>
>
> <property name="cacheMode"
> value="PARTITIONED"/>
>
>
> <property name="backups" value="1"/>
>
> <property name="affinity">
> <bean
>
> class="org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction">
> <property name="excludeNeighbors"
> value="true"/>
> <property name="partitions"
> value="2048"/>
> </bean>
> </property>
> </bean>
> </property>
> </bean>
> </beans>
>
> here is the output messages:
>
> [2018-07-31 13:28:46,014] INFO Kafka Connect standalone worker initializing
> ... (org.apache.kafka.connect.cli.ConnectStandalone:67)
> [2018-07-31 13:28:46,022] INFO WorkerInfo values:
> jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20,
> -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent,
> -Djava.awt.headless=true, -Dcom.sun.management.jmxremote,
> -Dcom.sun.management.jmxremote.authenticate=false,
> -Dcom.sun.management.jmxremote.ssl=false,
> -Dkafka.logs.dir=/var/u00/confluent/bin/../logs,
> -Dlog4j.configuration=file:bin/../etc/kafka/connect-log4j.properties
> jvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_171,
> 25.171-b10
> jvm.classpath =
>
> /var/u00/confluent/share/java/kafka/jackson-databind-2.9.5.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-test-sources.jar:/var/u00/confluent/share/java/kafka/rocksdbjni-5.7.3.jar:/var/u00/confluent/share/java/kafka/javax.inject-1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-test.jar:/var/u00/confluent/share/java/kafka/jackson-module-jaxb-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka/connect-transforms-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka-streams-examples-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/support-metrics-common-4.1.1.jar:/var/u00/confluent/share/java/kafka/javax.ws.rs-api-2.0.1.jar:/var/u00/confluent/share/java/kafka/connect-runtime-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-scaladoc.jar:/var/u00/confluent/share/java/kafka/javassist-3.20.0-GA.jar:/var/u00/confluent/share/java/kafka/jetty-continuation-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-streams-test-utils-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/connect-file-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/jersey-client-2.25.1.jar:/var/u00/confluent/share/java/kafka/validation-api-1.1.0.Final.jar:/var/u00/confluent/share/java/kafka/commons-logging-1.2.jar:/var/u00/confluent/share/java/kafka/lz4-java-1.4.1.jar:/var/u00/confluent/share/java/kafka/jackson-core-2.9.5.jar:/var/u00/confluent/share/java/kafka/connect-api-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/guava-20.0.jar:/var/u00/confluent/share/java/kafka/zookeeper-3.4.10.jar:/var/u00/confluent/share/java/kafka/javassist-3.21.0-GA.jar:/var/u00/confluent/share/java/kafka/javax.servlet-api-3.1.0.jar:/var/u00/confluent/share/java/kafka/commons-validator-1.4.1.jar:/var/u00/confluent/share/java/kafka/hk2-utils-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/hk2-locator-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/jackson-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka/commons-collections-3.2.1.jar:/var/u00/confluent/share/java/kafka/httpclient-4.5.2.jar:/var/u00/confluent/share/java/kafka/metrics-core-2.2.0.jar:/var/u00/confluent/share/java/kafka/avro-1.8.1.jar:/var/u00/confluent/share/java/kafka/support-metrics-client-4.1.1.jar:/var/u00/confluent/share/java/kafka/jersey-container-servlet-core-2.25.1.jar:/var/u00/confluent/share/java/kafka/log4j-1.2.17.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-sources.jar:/var/u00/confluent/share/java/kafka/jetty-io-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-common-2.25.1.jar:/var/u00/confluent/share/java/kafka/commons-lang3-3.5.jar:/var/u00/confluent/share/java/kafka/scala-library-2.11.12.jar:/var/u00/confluent/share/java/kafka/jetty-servlets-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-log4j-appender-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/javax.annotation-api-1.2.jar:/var/u00/confluent/share/java/kafka/netty-3.10.5.Final.jar:/var/u00/confluent/share/java/kafka/plexus-utils-3.1.0.jar:/var/u00/confluent/share/java/kafka/jetty-util-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jackson-core-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka/slf4j-api-1.7.25.jar:/var/u00/confluent/share/java/kafka/xz-1.5.jar:/var/u00/confluent/share/java/kafka/commons-compress-1.8.1.jar:/var/u00/confluent/share/java/kafka/jline-0.9.94.jar:/var/u00/confluent/share/java/kafka/kafka-tools-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/commons-codec-1.9.jar:/var/u00/confluent/share/java/kafka/activation-1.1.1.jar:/var/u00/confluent/share/java/kafka/commons-lang3-3.1.jar:/var/u00/confluent/share/java/kafka/jaxb-api-2.3.0.jar:/var/u00/confluent/share/java/kafka/kafka-streams-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/httpcore-4.4.4.jar:/var/u00/confluent/share/java/kafka/jopt-simple-5.0.4.jar:/var/u00/confluent/share/java/kafka/slf4j-log4j12-1.7.25.jar:/var/u00/confluent/share/java/kafka/jackson-jaxrs-base-2.9.5.jar:/var/u00/confluent/share/java/kafka/paranamer-2.7.jar:/var/u00/confluent/share/java/kafka/reflections-0.9.11.jar:/var/u00/confluent/share/java/kafka/osgi-resource-locator-1.0.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1-javadoc.jar:/var/u00/confluent/share/java/kafka/jersey-container-servlet-2.25.1.jar:/var/u00/confluent/share/java/kafka/connect-json-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/snappy-java-1.1.7.1.jar:/var/u00/confluent/share/java/kafka/jetty-client-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-guava-2.25.1.jar:/var/u00/confluent/share/java/kafka/httpmime-4.5.2.jar:/var/u00/confluent/share/java/kafka/jetty-server-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/kafka-clients-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/jersey-media-jaxb-2.25.1.jar:/var/u00/confluent/share/java/kafka/jackson-jaxrs-json-provider-2.9.5.jar:/var/u00/confluent/share/java/kafka/aopalliance-repackaged-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/hk2-api-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka/zkclient-0.10.jar:/var/u00/confluent/share/java/kafka/jetty-http-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/javax.inject-2.5.0-b32.jar:/var/u00/confluent/share/java/kafka/maven-artifact-3.5.3.jar:/var/u00/confluent/share/java/kafka/scala-reflect-2.11.12.jar:/var/u00/confluent/share/java/kafka/jetty-security-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/jersey-server-2.25.1.jar:/var/u00/confluent/share/java/kafka/jetty-servlet-9.2.24.v20180105.jar:/var/u00/confluent/share/java/kafka/commons-beanutils-1.8.3.jar:/var/u00/confluent/share/java/kafka/argparse4j-0.7.0.jar:/var/u00/confluent/share/java/kafka/scala-logging_2.11-3.8.0.jar:/var/u00/confluent/share/java/kafka/common-utils-4.1.1.jar:/var/u00/confluent/share/java/kafka/commons-digester-1.8.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-1.1.1-cp1.jar:/var/u00/confluent/share/java/kafka/kafka.jar:/var/u00/confluent/share/java/kafka/ignite-kafka-2.5.0.jar:/var/u00/confluent/share/java/kafka/ignite-core-2.5.0.jar:/var/u00/confluent/share/java/kafka/cache-api-1.0.0.jar:/var/u00/confluent/share/java/kafka/ignite-spring-2.5.0.jar:/var/u00/confluent/share/java/kafka/spring-aop-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-beans-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-context-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-core-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/spring-expression-4.3.7.RELEASE.jar:/var/u00/confluent/share/java/kafka/curator-client-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-framework-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-recipes-2.9.1.jar:/var/u00/confluent/share/java/kafka/curator-x-discovery-2.9.1.jar:/var/u00/confluent/share/java/kafka/guava-16.0.1.jar:/var/u00/confluent/share/java/kafka/ignite-zookeeper-2.5.0.jar:/var/u00/confluent/share/java/kafka/zookeeper-3.4.6.jar:/var/u00/confluent/share/java/kafka/connect-api-0.10.0.1.jar:/var/u00/confluent/share/java/kafka/kafka_2.11-0.10.0.1.jar:/var/u00/confluent/share/java/confluent-common/zookeeper-3.4.10.jar:/var/u00/confluent/share/java/confluent-common/build-tools-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/log4j-1.2.17.jar:/var/u00/confluent/share/java/confluent-common/netty-3.10.5.Final.jar:/var/u00/confluent/share/java/confluent-common/common-config-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/slf4j-api-1.7.25.jar:/var/u00/confluent/share/java/confluent-common/jline-0.9.94.jar:/var/u00/confluent/share/java/confluent-common/common-metrics-4.1.1.jar:/var/u00/confluent/share/java/confluent-common/zkclient-0.10.jar:/var/u00/confluent/share/java/confluent-common/common-utils-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-databind-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-schema-registry-client-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-core-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-connect-avro-converter-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-annotations-2.9.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/avro-1.8.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-avro-serializer-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka-serde-tools/xz-1.5.jar:/var/u00/confluent/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-json-serializer-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/paranamer-2.7.jar:/var/u00/confluent/share/java/kafka-serde-tools/kafka-streams-avro-serde-4.1.1.jar:/var/u00/confluent/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-databind-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-test-sources.jar:/var/u00/confluent/bin/../share/java/kafka/rocksdbjni-5.7.3.jar:/var/u00/confluent/bin/../share/java/kafka/javax.inject-1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-test.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-module-jaxb-annotations-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/connect-transforms-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-examples-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/support-metrics-common-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/javax.ws.rs-api-2.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-runtime-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-scaladoc.jar:/var/u00/confluent/bin/../share/java/kafka/javassist-3.20.0-GA.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-continuation-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-test-utils-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-file-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-client-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/validation-api-1.1.0.Final.jar:/var/u00/confluent/bin/../share/java/kafka/commons-logging-1.2.jar:/var/u00/confluent/bin/../share/java/kafka/lz4-java-1.4.1.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-core-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/connect-api-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/guava-20.0.jar:/var/u00/confluent/bin/../share/java/kafka/zookeeper-3.4.10.jar:/var/u00/confluent/bin/../share/java/kafka/javassist-3.21.0-GA.jar:/var/u00/confluent/bin/../share/java/kafka/javax.servlet-api-3.1.0.jar:/var/u00/confluent/bin/../share/java/kafka/commons-validator-1.4.1.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-utils-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-locator-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-annotations-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/commons-collections-3.2.1.jar:/var/u00/confluent/bin/../share/java/kafka/httpclient-4.5.2.jar:/var/u00/confluent/bin/../share/java/kafka/metrics-core-2.2.0.jar:/var/u00/confluent/bin/../share/java/kafka/avro-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/support-metrics-client-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-container-servlet-core-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/log4j-1.2.17.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-sources.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-io-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-common-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-lang3-3.5.jar:/var/u00/confluent/bin/../share/java/kafka/scala-library-2.11.12.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-servlets-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-log4j-appender-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/javax.annotation-api-1.2.jar:/var/u00/confluent/bin/../share/java/kafka/netty-3.10.5.Final.jar:/var/u00/confluent/bin/../share/java/kafka/plexus-utils-3.1.0.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-util-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-core-asl-1.9.13.jar:/var/u00/confluent/bin/../share/java/kafka/slf4j-api-1.7.25.jar:/var/u00/confluent/bin/../share/java/kafka/xz-1.5.jar:/var/u00/confluent/bin/../share/java/kafka/commons-compress-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/jline-0.9.94.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-tools-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-codec-1.9.jar:/var/u00/confluent/bin/../share/java/kafka/activation-1.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-lang3-3.1.jar:/var/u00/confluent/bin/../share/java/kafka/jaxb-api-2.3.0.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-streams-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/httpcore-4.4.4.jar:/var/u00/confluent/bin/../share/java/kafka/jopt-simple-5.0.4.jar:/var/u00/confluent/bin/../share/java/kafka/slf4j-log4j12-1.7.25.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-jaxrs-base-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/paranamer-2.7.jar:/var/u00/confluent/bin/../share/java/kafka/reflections-0.9.11.jar:/var/u00/confluent/bin/../share/java/kafka/osgi-resource-locator-1.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1-javadoc.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-container-servlet-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/connect-json-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/snappy-java-1.1.7.1.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-client-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-guava-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/httpmime-4.5.2.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-server-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/kafka-clients-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-media-jaxb-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-jaxrs-json-provider-2.9.5.jar:/var/u00/confluent/bin/../share/java/kafka/aopalliance-repackaged-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/hk2-api-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/jackson-mapper-asl-1.9.13.jar:/var/u00/confluent/bin/../share/java/kafka/zkclient-0.10.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-http-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/javax.inject-2.5.0-b32.jar:/var/u00/confluent/bin/../share/java/kafka/maven-artifact-3.5.3.jar:/var/u00/confluent/bin/../share/java/kafka/scala-reflect-2.11.12.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-security-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/jersey-server-2.25.1.jar:/var/u00/confluent/bin/../share/java/kafka/jetty-servlet-9.2.24.v20180105.jar:/var/u00/confluent/bin/../share/java/kafka/commons-beanutils-1.8.3.jar:/var/u00/confluent/bin/../share/java/kafka/argparse4j-0.7.0.jar:/var/u00/confluent/bin/../share/java/kafka/scala-logging_2.11-3.8.0.jar:/var/u00/confluent/bin/../share/java/kafka/common-utils-4.1.1.jar:/var/u00/confluent/bin/../share/java/kafka/commons-digester-1.8.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-1.1.1-cp1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-kafka-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-core-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/cache-api-1.0.0.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-spring-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/spring-aop-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-beans-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-context-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-core-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/spring-expression-4.3.7.RELEASE.jar:/var/u00/confluent/bin/../share/java/kafka/curator-client-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-framework-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-recipes-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/curator-x-discovery-2.9.1.jar:/var/u00/confluent/bin/../share/java/kafka/guava-16.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/ignite-zookeeper-2.5.0.jar:/var/u00/confluent/bin/../share/java/kafka/zookeeper-3.4.6.jar:/var/u00/confluent/bin/../share/java/kafka/connect-api-0.10.0.1.jar:/var/u00/confluent/bin/../share/java/kafka/kafka_2.11-0.10.0.1.jar:/var/u00/confluent/bin/../share/java/confluent-support-metrics/*:/usr/share/java/confluent-support-metrics/*
> os.spec = Linux, amd64, 3.10.0-693.21.1.el7.x86_64
> os.vcpus = 2
> (org.apache.kafka.connect.runtime.WorkerInfo:71)
> [2018-07-31 13:28:46,023] INFO Scanning for plugin classes. This might take
> a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:76)
> [2018-07-31 13:28:51,003] INFO Registered loader:
> sun.misc.Launcher$AppClassLoader@764c12b6
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.file.FileStreamSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.file.FileStreamSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.tools.MockSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.tools.MockSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.tools.SchemaSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,004] INFO Added plugin
> 'org.apache.kafka.connect.tools.MockConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,005] INFO Added plugin
> 'org.apache.kafka.connect.tools.VerifiableSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,005] INFO Added plugin
> 'org.apache.kafka.connect.tools.VerifiableSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,005] INFO Added plugin
> 'org.apache.ignite.stream.kafka.connect.IgniteSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,005] INFO Added plugin
> 'org.apache.kafka.connect.converters.ByteArrayConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,005] INFO Added plugin
> 'org.apache.kafka.connect.json.JsonConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.ignite.stream.kafka.connect.serialization.CacheEventConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.storage.StringConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'io.confluent.connect.avro.AvroConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.storage.SimpleHeaderConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.Cast$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.ValueToKey'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.InsertField$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.ExtractField$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,006] INFO Added plugin
> 'org.apache.kafka.connect.transforms.Cast$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.TimestampConverter$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.ExtractField$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.MaskField$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.RegexRouter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.ReplaceField$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.ReplaceField$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.InsertField$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.Flatten$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.TimestampConverter$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.HoistField$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.MaskField$Key'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.HoistField$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.Flatten$Value'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> [2018-07-31 13:28:51,007] INFO Added plugin
> 'org.apache.kafka.connect.transforms.TimestampRouter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)
> Jul 31, 2018 1:28:51 PM java.util.logging.LogManager$RootLogger log
> SEVERE: Failed to resolve default logging config file:
> config/java.util.logging.properties
> [2018-07-31 13:28:51,044] DEBUG Registered java.sql.Driver:
> org.apache.ignite.IgniteJdbcDriver@5a6d5a8f to java.sql.DriverManager
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:250)
> [2018-07-31 13:28:51,044] DEBUG Registered java.sql.Driver:
> org.apache.ignite.IgniteJdbcThinDriver@4a67318f to java.sql.DriverManager
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:250)
> [2018-07-31 13:28:51,045] INFO Added aliases 'IgniteSinkConnector' and
> 'IgniteSink' to plugin
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,045] INFO Added aliases 'IgniteSourceConnector' and
> 'IgniteSource' to plugin
> 'org.apache.ignite.stream.kafka.connect.IgniteSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,045] INFO Added aliases 'FileStreamSinkConnector' and
> 'FileStreamSink' to plugin
> 'org.apache.kafka.connect.file.FileStreamSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,045] INFO Added aliases 'FileStreamSourceConnector'
> and
> 'FileStreamSource' to plugin
> 'org.apache.kafka.connect.file.FileStreamSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,045] INFO Added aliases 'MockConnector' and 'Mock' to
> plugin 'org.apache.kafka.connect.tools.MockConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,045] INFO Added aliases 'MockSinkConnector' and
> 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'MockSourceConnector' and
> 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'SchemaSourceConnector' and
> 'SchemaSource' to plugin
> 'org.apache.kafka.connect.tools.SchemaSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'VerifiableSinkConnector' and
> 'VerifiableSink' to plugin
> 'org.apache.kafka.connect.tools.VerifiableSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'VerifiableSourceConnector'
> and
> 'VerifiableSource' to plugin
> 'org.apache.kafka.connect.tools.VerifiableSourceConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'AvroConverter' and 'Avro' to
> plugin 'io.confluent.connect.avro.AvroConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'CacheEventConverter' and
> 'CacheEvent' to plugin
> 'org.apache.ignite.stream.kafka.connect.serialization.CacheEventConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'ByteArrayConverter' and
> 'ByteArray' to plugin
> 'org.apache.kafka.connect.converters.ByteArrayConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'JsonConverter' and 'Json' to
> plugin 'org.apache.kafka.connect.json.JsonConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,046] INFO Added aliases 'StringConverter' and 'String'
> to plugin 'org.apache.kafka.connect.storage.StringConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,047] INFO Added aliases 'ByteArrayConverter' and
> 'ByteArray' to plugin
> 'org.apache.kafka.connect.converters.ByteArrayConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,047] INFO Added aliases 'JsonConverter' and 'Json' to
> plugin 'org.apache.kafka.connect.json.JsonConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,047] INFO Added alias 'SimpleHeaderConverter' to
> plugin
> 'org.apache.kafka.connect.storage.SimpleHeaderConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
> [2018-07-31 13:28:51,047] INFO Added aliases 'StringConverter' and 'String'
> to plugin 'org.apache.kafka.connect.storage.StringConverter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)
> [2018-07-31 13:28:51,048] INFO Added alias 'RegexRouter' to plugin
> 'org.apache.kafka.connect.transforms.RegexRouter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
> [2018-07-31 13:28:51,048] INFO Added alias 'TimestampRouter' to plugin
> 'org.apache.kafka.connect.transforms.TimestampRouter'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
> [2018-07-31 13:28:51,048] INFO Added alias 'ValueToKey' to plugin
> 'org.apache.kafka.connect.transforms.ValueToKey'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)
> [2018-07-31 13:28:51,058] INFO StandaloneConfig values:
> access.control.allow.methods =
> access.control.allow.origin =
> bootstrap.servers = [1.2.3.4:9092]
> header.converter = class
> org.apache.kafka.connect.storage.SimpleHeaderConverter
> internal.key.converter = class
> org.apache.kafka.connect.storage.StringConverter
> internal.value.converter = class
> org.apache.kafka.connect.storage.StringConverter
> key.converter = class
> org.apache.kafka.connect.storage.StringConverter
> listeners = null
> metric.reporters = []
> metrics.num.samples = 2
> metrics.recording.level = INFO
> metrics.sample.window.ms = 30000
> offset.flush.interval.ms = 60000
> offset.flush.timeout.ms = 5000
> offset.storage.file.filename = /tmp/connect.offsets1
> plugin.path = null
> rest.advertised.host.name = null
> rest.advertised.listener = null
> rest.advertised.port = null
> rest.host.name = null
> rest.port = 8083
> ssl.client.auth = none
> task.shutdown.graceful.timeout.ms = 5000
> value.converter = class
> org.apache.kafka.connect.storage.StringConverter
> (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:279)
> [2018-07-31 13:28:51,059] INFO Creating Kafka admin client
> (org.apache.kafka.connect.util.ConnectUtils:43)
> [2018-07-31 13:28:51,065] INFO AdminClientConfig values:
> bootstrap.servers = [1.2.3.4:9092]
> client.id =
> connections.max.idle.ms = 300000
> metadata.max.age.ms = 300000
> metric.reporters = []
> metrics.num.samples = 2
> metrics.recording.level = INFO
> metrics.sample.window.ms = 30000
> receive.buffer.bytes = 65536
> reconnect.backoff.max.ms = 1000
> reconnect.backoff.ms = 50
> request.timeout.ms = 120000
> retries = 5
> retry.backoff.ms = 100
> sasl.jaas.config = null
> sasl.kerberos.kinit.cmd = /usr/bin/kinit
> sasl.kerberos.min.time.before.relogin = 60000
> sasl.kerberos.service.name = null
> sasl.kerberos.ticket.renew.jitter = 0.05
> sasl.kerberos.ticket.renew.window.factor = 0.8
> sasl.mechanism = GSSAPI
> security.protocol = PLAINTEXT
> send.buffer.bytes = 131072
> ssl.cipher.suites = null
> ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
> ssl.endpoint.identification.algorithm = null
> ssl.key.password = null
> ssl.keymanager.algorithm = SunX509
> ssl.keystore.location = null
> ssl.keystore.password = null
> ssl.keystore.type = JKS
> ssl.protocol = TLS
> ssl.provider = null
> ssl.secure.random.implementation = null
> ssl.trustmanager.algorithm = PKIX
> ssl.truststore.location = null
> ssl.truststore.password = null
> ssl.truststore.type = JKS
> (org.apache.kafka.clients.admin.AdminClientConfig:279)
> [2018-07-31 13:28:51,084] DEBUG Added sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,086] DEBUG Added sensor with name connections-created:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,086] DEBUG Added sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,086] DEBUG Added sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,086] DEBUG Added sensor with name bytes-sent-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,087] DEBUG Added sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,088] DEBUG Added sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,088] DEBUG Added sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,089] DEBUG Added sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,094] DEBUG Updated cluster metadata version 1 to
> Cluster(id = null, nodes = [1.2.3.4:9092 (id: -1 rack: null)], partitions
> =
> []) (org.apache.kafka.clients.Metadata:270)
> [2018-07-31 13:28:51,097] WARN The configuration
> 'key.converter.schemas.enable' was supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration 'internal.key.converter'
> was supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration
> 'offset.storage.file.filename' was supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration
> 'internal.value.converter.schemas.enable' was supplied but isn't a known
> config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration
> 'value.converter.schemas.enable' was supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration 'internal.value.converter'
> was supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration 'value.converter' was
> supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration
> 'internal.key.converter.schemas.enable' was supplied but isn't a known
> config. (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] WARN The configuration 'key.converter' was
> supplied but isn't a known config.
> (org.apache.kafka.clients.admin.AdminClientConfig:287)
> [2018-07-31 13:28:51,097] INFO Kafka version : 1.1.1-cp1
> (org.apache.kafka.common.utils.AppInfoParser:109)
> [2018-07-31 13:28:51,098] INFO Kafka commitId : 440b1a581a04ac59
> (org.apache.kafka.common.utils.AppInfoParser:110)
> [2018-07-31 13:28:51,099] DEBUG [AdminClient clientId=adminclient-1] Kafka
> admin client initialized
> (org.apache.kafka.clients.admin.KafkaAdminClient:381)
> [2018-07-31 13:28:51,100] DEBUG Looking up Kafka cluster ID
> (org.apache.kafka.connect.util.ConnectUtils:50)
> [2018-07-31 13:28:51,101] DEBUG [AdminClient clientId=adminclient-1]
> Queueing Call(callName=listNodes, deadlineMs=1533033051100) with a timeout
> 120000 ms from now. (org.apache.kafka.clients.admin.KafkaAdminClient:1045)
> [2018-07-31 13:28:51,101] DEBUG Fetching Kafka cluster ID
> (org.apache.kafka.connect.util.ConnectUtils:57)
> [2018-07-31 13:28:51,194] DEBUG [AdminClient clientId=adminclient-1]
> Initialize connection to node 1.2.3.4:9092 (id: -1 rack: null) for sending
> metadata request (org.apache.kafka.clients.NetworkClient:943)
> [2018-07-31 13:28:51,195] DEBUG [AdminClient clientId=adminclient-1]
> Initiating connection to node 1.2.3.4:9092 (id: -1 rack: null)
> (org.apache.kafka.clients.NetworkClient:791)
> [2018-07-31 13:28:51,202] DEBUG Added sensor with name node--1.bytes-sent
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,203] DEBUG Added sensor with name
> node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,203] DEBUG Added sensor with name node--1.latency
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,203] DEBUG [AdminClient clientId=adminclient-1]
> Created
> socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node
> -1
> (org.apache.kafka.common.network.Selector:474)
> [2018-07-31 13:28:51,318] DEBUG [AdminClient clientId=adminclient-1]
> Completed connection to node -1. Fetching API versions.
> (org.apache.kafka.clients.NetworkClient:753)
> [2018-07-31 13:28:51,318] DEBUG [AdminClient clientId=adminclient-1]
> Initiating API versions fetch from node -1.
> (org.apache.kafka.clients.NetworkClient:767)
> [2018-07-31 13:28:51,326] DEBUG [AdminClient clientId=adminclient-1]
> Recorded API versions for node -1: (Produce(0): 0 to 5 [usable: 5],
> Fetch(1): 0 to 7 [usable: 7], ListOffsets(2): 0 to 2 [usable: 2],
> Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1],
> StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4],
> ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable:
> 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1
> [usable:
> 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1],
> LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1],
> DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1],
> SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1],
> CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1],
> DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0],
> OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable:
> 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0],
> WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0],
> DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0],
> DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 to 1 [usable: 1],
> AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0],
> DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0],
> CreatePartitions(37): 0 [usable: 0], CreateDelegationToken(38): 0 [usable:
> 0], RenewDelegationToken(39): 0 [usable: 0], ExpireDelegationToken(40): 0
> [usable: 0], DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42):
> 0
> [usable: 0]) (org.apache.kafka.clients.NetworkClient:720)
> [2018-07-31 13:28:51,326] DEBUG [AdminClient clientId=adminclient-1]
> Sending
> metadata request (type=MetadataRequest, topics=) to node 1.2.3.4:9092 (id:
> -1 rack: null) (org.apache.kafka.clients.NetworkClient:927)
> [2018-07-31 13:28:51,327] INFO Cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
> (org.apache.kafka.clients.Metadata:265)
> [2018-07-31 13:28:51,327] DEBUG Updated cluster metadata version 2 to
> Cluster(id = AGRLoUkJQ0GzKKfZwUj1wQ, nodes = [trukfk3:9092 (id: 1002 rack:
> null), trukfk2:9092 (id: 1001 rack: null)], partitions = [])
> (org.apache.kafka.clients.Metadata:270)
> [2018-07-31 13:28:51,327] DEBUG [AdminClient clientId=adminclient-1]
> Initiating connection to node trukfk3:9092 (id: 1002 rack: null)
> (org.apache.kafka.clients.NetworkClient:791)
> [2018-07-31 13:28:51,329] DEBUG Added sensor with name node-1002.bytes-sent
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,330] DEBUG Added sensor with name
> node-1002.bytes-received (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,330] DEBUG Added sensor with name node-1002.latency
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1]
> Created
> socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node
> 1002 (org.apache.kafka.common.network.Selector:474)
> [2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1]
> Completed connection to node 1002. Fetching API versions.
> (org.apache.kafka.clients.NetworkClient:753)
> [2018-07-31 13:28:51,331] DEBUG [AdminClient clientId=adminclient-1]
> Initiating API versions fetch from node 1002.
> (org.apache.kafka.clients.NetworkClient:767)
> [2018-07-31 13:28:51,332] DEBUG [AdminClient clientId=adminclient-1]
> Recorded API versions for node 1002: (Produce(0): 0 to 5 [usable: 5],
> Fetch(1): 0 to 7 [usable: 7], ListOffsets(2): 0 to 2 [usable: 2],
> Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1],
> StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4],
> ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable:
> 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1
> [usable:
> 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1],
> LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1],
> DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1],
> SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1],
> CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1],
> DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0],
> OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable:
> 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0],
> WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0],
> DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0],
> DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 to 1 [usable: 1],
> AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0],
> DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0],
> CreatePartitions(37): 0 [usable: 0], CreateDelegationToken(38): 0 [usable:
> 0], RenewDelegationToken(39): 0 [usable: 0], ExpireDelegationToken(40): 0
> [usable: 0], DescribeDelegationToken(41): 0 [usable: 0], DeleteGroups(42):
> 0
> [usable: 0]) (org.apache.kafka.clients.NetworkClient:720)
> [2018-07-31 13:28:51,334] INFO Kafka cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
> (org.apache.kafka.connect.util.ConnectUtils:59)
> [2018-07-31 13:28:51,334] DEBUG [AdminClient clientId=adminclient-1]
> Initiating close operation.
> (org.apache.kafka.clients.admin.KafkaAdminClient:399)
> [2018-07-31 13:28:51,334] DEBUG [AdminClient clientId=adminclient-1]
> Waiting
> for the I/O thread to exit. Hard shutdown in 31536000000 ms.
> (org.apache.kafka.clients.admin.KafkaAdminClient:415)
> [2018-07-31 13:28:51,335] DEBUG Removed sensor with name
> connections-closed:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,335] DEBUG Removed sensor with name
> connections-created: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,335] DEBUG Removed sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,335] DEBUG Removed sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,336] DEBUG Removed sensor with name
> bytes-sent-received: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,336] DEBUG Removed sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,336] DEBUG Removed sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,336] DEBUG Removed sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,336] DEBUG Removed sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,337] DEBUG Removed sensor with name node--1.bytes-sent
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,337] DEBUG Removed sensor with name
> node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,337] DEBUG Removed sensor with name node--1.latency
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,337] DEBUG Removed sensor with name
> node-1002.bytes-sent (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,338] DEBUG Removed sensor with name
> node-1002.bytes-received (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,338] DEBUG Removed sensor with name node-1002.latency
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-07-31 13:28:51,338] DEBUG [AdminClient clientId=adminclient-1]
> Exiting
> AdminClientRunnable thread.
> (org.apache.kafka.clients.admin.KafkaAdminClient:1030)
> [2018-07-31 13:28:51,338] DEBUG [AdminClient clientId=adminclient-1] Kafka
> admin client closed. (org.apache.kafka.clients.admin.KafkaAdminClient:423)
> [2018-07-31 13:28:51,338] DEBUG Kafka cluster ID: AGRLoUkJQ0GzKKfZwUj1wQ
> (org.apache.kafka.connect.cli.ConnectStandalone:82)
> [2018-07-31 13:28:51,346] DEBUG Logging to
> org.slf4j.impl.Log4jLoggerAdapter(org.eclipse.jetty.util.log) via
> org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:176)
> [2018-07-31 13:28:51,348] INFO Logging initialized @5609ms
> (org.eclipse.jetty.util.log:186)
> [2018-07-31 13:28:51,355] DEBUG org.eclipse.jetty.server.Server@1500e009
> added {qtp916958177{STOPPED,8<=0<=200,i=0,q=0},AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,363] DEBUG HttpConnectionFactory@7dc51783{HTTP/1.1}
> added {HttpConfiguration@4b61d0c6{32768/8192,8192/8192,https://
> :0,[]},POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
> added {org.eclipse.jetty.server.Server@1500e009,UNMANAGED}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
> added {qtp916958177{STOPPED,8<=0<=200,i=0,q=0},AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,365] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
> added
> {org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,366] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
> added {org.eclipse.jetty.io.ArrayByteBufferPool@6e4ea0bd,POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,366] DEBUG ServerConnector@62315f22{null}{0.0.0.0:0}
> added {HttpConnectionFactory@7dc51783{HTTP/1.1},AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,367] DEBUG
> ServerConnector@62315f22{HTTP/1.1}{0.0.0.0:0} added
> {org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2
> ,MANAGED}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,367] INFO Added connector for http://:8083
> (org.apache.kafka.connect.runtime.rest.RestServer:110)
> [2018-07-31 13:28:51,367] DEBUG org.eclipse.jetty.server.Server@1500e009
> added {http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083},AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,475] INFO Advertised URI: http://1.2.3.4:8083/
> (org.apache.kafka.connect.runtime.rest.RestServer:248)
> [2018-07-31 13:28:51,483] DEBUG Registering Connect metrics with JMX for
> worker '1.2.3.4:8083' (org.apache.kafka.connect.runtime.ConnectMetrics:78)
> [2018-07-31 13:28:51,483] INFO Kafka version : 1.1.1-cp1
> (org.apache.kafka.common.utils.AppInfoParser:109)
> [2018-07-31 13:28:51,483] INFO Kafka commitId : 440b1a581a04ac59
> (org.apache.kafka.common.utils.AppInfoParser:110)
> [2018-07-31 13:28:51,486] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;connector-startup-results
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,486] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;connector-startup-attempts
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;connector-startup-successes
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;connector-startup-failures
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;task-startup-results
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;task-startup-attempts
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;task-startup-successes
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,487] DEBUG Added sensor with name
> connect-sensor-group:
> connect-worker-metrics;task-startup-failures
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-07-31 13:28:51,489] DEBUG Configuring the key converter with
> configuration:
> {schemas.enable=false}
> (org.apache.kafka.connect.runtime.isolation.Plugins:237)
> [2018-07-31 13:28:51,489] INFO StringConverterConfig values:
> converter.encoding = UTF8
> converter.type = key
> (org.apache.kafka.connect.storage.StringConverterConfig:279)
> [2018-07-31 13:28:51,490] DEBUG Configuring the value converter with
> configuration:
> {schemas.enable=false}
> (org.apache.kafka.connect.runtime.isolation.Plugins:237)
> [2018-07-31 13:28:51,490] INFO StringConverterConfig values:
> converter.encoding = UTF8
> converter.type = value
> (org.apache.kafka.connect.storage.StringConverterConfig:279)
> [2018-07-31 13:28:51,495] DEBUG Kafka Connect instance created
> (org.apache.kafka.connect.runtime.Connect:41)
> [2018-07-31 13:28:51,495] INFO Kafka Connect standalone worker
> initialization took 5480ms
> (org.apache.kafka.connect.cli.ConnectStandalone:92)
> [2018-07-31 13:28:51,495] INFO Kafka Connect starting
> (org.apache.kafka.connect.runtime.Connect:49)
> [2018-07-31 13:28:51,496] INFO Herder starting
> (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)
> [2018-07-31 13:28:51,496] INFO Worker starting
> (org.apache.kafka.connect.runtime.Worker:139)
> [2018-07-31 13:28:51,496] INFO Starting FileOffsetBackingStore with file
> /tmp/connect.offsets1
> (org.apache.kafka.connect.storage.FileOffsetBackingStore:59)
> [2018-07-31 13:28:51,498] INFO Worker started
> (org.apache.kafka.connect.runtime.Worker:144)
> [2018-07-31 13:28:51,498] INFO Herder started
> (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)
> [2018-07-31 13:28:51,498] INFO Starting REST server
> (org.apache.kafka.connect.runtime.rest.RestServer:155)
> [2018-07-31 13:28:51,546] DEBUG
> org.eclipse.jetty.server.session.SessionHandler@320494b6 added
> {org.eclipse.jetty.server.session.HashSessionManager@652ab8d9,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,546] DEBUG
> o.e.j.s.ServletContextHandler@14fc5d40{/,null,null} added
> {org.eclipse.jetty.server.session.SessionHandler@320494b6,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,548] DEBUG
> org.eclipse.jetty.server.session.SessionHandler@320494b6 added
> {org.eclipse.jetty.servlet.ServletHandler@50d3bf39,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,548] DEBUG
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
> {org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,549] DEBUG
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
> {[/*]=>org.glassfish.jersey.servlet.ServletContainer-281f23f2,POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,550] DEBUG
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c added
> {org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,556] DEBUG
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
> {o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,556] DEBUG
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
> {org.eclipse.jetty.server.handler.DefaultHandler@59429fac,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,556] DEBUG
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c] added
> {org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,557] DEBUG
> org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5 added
> {org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c],AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,557] DEBUG org.eclipse.jetty.server.Server@1500e009
> added {org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,557] DEBUG starting
> org.eclipse.jetty.server.Server@1500e009
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,559] INFO jetty-9.2.24.v20180105
> (org.eclipse.jetty.server.Server:327)
> [2018-07-31 13:28:51,568] DEBUG starting
> org.eclipse.jetty.server.Server@1500e009
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,568] DEBUG starting
> qtp916958177{STOPPED,8<=0<=200,i=0,q=0}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,569] DEBUG STARTED @5831ms
> qtp916958177{STARTED,8<=8<=200,i=7,q=0}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,569] DEBUG starting
> org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,569] DEBUG starting
> org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,569] DEBUG starting
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,570] DEBUG starting
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,null},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,570] DEBUG starting
> o.e.j.s.ServletContextHandler@14fc5d40{/,null,null}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,574] DEBUG starting
> o.e.j.s.ServletContextHandler@14fc5d40{/,null,STARTING}
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,574] DEBUG starting
> org.eclipse.jetty.server.session.SessionHandler@320494b6
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,574] DEBUG starting
> org.eclipse.jetty.server.session.SessionHandler@320494b6
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,574] DEBUG starting
> org.eclipse.jetty.server.session.HashSessionManager@652ab8d9
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,574] DEBUG
> org.eclipse.jetty.server.session.HashSessionManager@652ab8d9 added
> {org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969
> ,MANAGED}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,575] DEBUG starting
> org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,575] DEBUG STARTED @5837ms
> org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,575] DEBUG org.eclipse.jetty.server.Server@1500e009
> added
> {org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7,MANAGED}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,576] DEBUG
> org.eclipse.jetty.server.session.HashSessionManager@652ab8d9 added
> {org.eclipse.jetty.server.session.HashSessionIdManager@77b9d0c7,UNMANAGED}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,576] DEBUG starting
> org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,576] DEBUG STARTED @5838ms
> org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@7f9ab969
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,577] DEBUG STARTED @5839ms
> org.eclipse.jetty.server.session.HashSessionManager@652ab8d9
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,577] DEBUG starting
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,578] DEBUG Chose path=/* mapped to
> servlet=org.glassfish.jersey.servlet.ServletContainer-281f23f2 from
> default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
> [2018-07-31 13:28:51,579] DEBUG filterNameMap={}
> (org.eclipse.jetty.servlet.ServletHandler:1516)
> [2018-07-31 13:28:51,579] DEBUG pathFilters=null
> (org.eclipse.jetty.servlet.ServletHandler:1517)
> [2018-07-31 13:28:51,579] DEBUG servletFilterMap=null
> (org.eclipse.jetty.servlet.ServletHandler:1518)
> [2018-07-31 13:28:51,579] DEBUG
>
> servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true}
> (org.eclipse.jetty.servlet.ServletHandler:1519)
> [2018-07-31 13:28:51,580] DEBUG
>
> servletNameMap={org.glassfish.jersey.servlet.ServletContainer-281f23f2=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true}
> (org.eclipse.jetty.servlet.ServletHandler:1520)
> [2018-07-31 13:28:51,580] DEBUG Adding Default404Servlet to
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39
> (org.eclipse.jetty.servlet.ServletHandler:165)
> [2018-07-31 13:28:51,580] DEBUG
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
>
> {org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf
> ==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false,AUTO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,581] DEBUG
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39 added
>
> {[/]=>org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa,POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,581] DEBUG Chose path=/* mapped to
> servlet=org.glassfish.jersey.servlet.ServletContainer-281f23f2 from
> default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
> [2018-07-31 13:28:51,581] DEBUG Chose path=/ mapped to
> servlet=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa
> from default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
> [2018-07-31 13:28:51,581] DEBUG filterNameMap={}
> (org.eclipse.jetty.servlet.ServletHandler:1516)
> [2018-07-31 13:28:51,582] DEBUG pathFilters=null
> (org.eclipse.jetty.servlet.ServletHandler:1517)
> [2018-07-31 13:28:51,582] DEBUG servletFilterMap=null
> (org.eclipse.jetty.servlet.ServletHandler:1518)
> [2018-07-31 13:28:51,582] DEBUG
>
> servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true,
>
> /=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf
> ==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false}
> (org.eclipse.jetty.servlet.ServletHandler:1519)
> [2018-07-31 13:28:51,582] DEBUG
>
> servletNameMap={org.glassfish.jersey.servlet.ServletContainer-281f23f2=org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true,
>
> org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf
> ==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false}
> (org.eclipse.jetty.servlet.ServletHandler:1520)
> [2018-07-31 13:28:51,582] DEBUG starting
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,582] DEBUG STARTED @5844ms
> org.eclipse.jetty.servlet.ServletHandler@50d3bf39
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,582] DEBUG STARTED @5844ms
> org.eclipse.jetty.server.session.SessionHandler@320494b6
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,582] DEBUG starting
>
> org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf
> ==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,583] DEBUG STARTED @5845ms
>
> org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-796065aa@d4b017cf
> ==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,583] DEBUG starting
> org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,583] DEBUG STARTED @5845ms
> org.glassfish.jersey.servlet.ServletContainer-281f23f2@ea4a0b6
> ==org.glassfish.jersey.servlet.ServletContainer,-1,true
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,584] DEBUG Servlet.init
> org.glassfish.jersey.servlet.ServletContainer@38a1c423 for
> org.glassfish.jersey.servlet.ServletContainer-281f23f2
> (org.eclipse.jetty.servlet.ServletHolder:615)
> [2018-07-31 13:28:51,902] INFO Started
> o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:744)
> [2018-07-31 13:28:51,902] DEBUG STARTED @6164ms
> o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,902] DEBUG starting
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,902] DEBUG starting
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,902] DEBUG STARTED @6164ms
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,902] DEBUG starting
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,902] DEBUG starting
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
> (org.eclipse.jetty.server.handler.AbstractHandler:58)
> [2018-07-31 13:28:51,902] DEBUG starting
> org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
> org.eclipse.jetty.server.Slf4jRequestLog@7ac9af2a
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
> org.eclipse.jetty.server.handler.HandlerCollection@5cd61783
> [o.e.j.s.ServletContextHandler@14fc5d40{/,null,AVAILABLE},
> org.eclipse.jetty.server.handler.DefaultHandler@59429fac,
> org.eclipse.jetty.server.handler.RequestLogHandler@17814b1c]
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,903] DEBUG STARTED @6165ms
> org.eclipse.jetty.server.handler.StatisticsHandler@19ccca5
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,903] DEBUG starting
> http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,906] DEBUG http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
> added {sun.nio.ch.ServerSocketChannelImpl[/0:0:0:0:0:0:0:0:8083],POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,907] DEBUG starting
> org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,907] DEBUG STARTED @6169ms
> org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@304b9f1a
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,907] DEBUG starting
> HttpConnectionFactory@7dc51783{HTTP/1.1}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,907] DEBUG STARTED @6169ms
> HttpConnectionFactory@7dc51783{HTTP/1.1}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,907] DEBUG starting
> org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2
> (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,909] DEBUG starting
> org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=-1
> selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
> [2018-07-31 13:28:51,909] DEBUG STARTED @6171ms
> org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=0
> selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,910] DEBUG STARTED @6172ms
> org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@48e7b3d2
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,910] DEBUG http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
> added {acceptor-0@7718a40f,POJO}
> (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
> [2018-07-31 13:28:51,910] INFO Started
> http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
> (org.eclipse.jetty.server.ServerConnector:266)
> [2018-07-31 13:28:51,911] DEBUG STARTED @6173ms
> http_8083@62315f22{HTTP/1.1}{0.0.0.0:8083}
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,911] INFO Started @6173ms
> (org.eclipse.jetty.server.Server:379)
> [2018-07-31 13:28:51,911] DEBUG STARTED @6173ms
> org.eclipse.jetty.server.Server@1500e009
> (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
> [2018-07-31 13:28:51,911] INFO Advertised URI: http://1.2.3.4:8083/
> (org.apache.kafka.connect.runtime.rest.RestServer:248)
> [2018-07-31 13:28:51,911] INFO REST server listening at
> http://1.2.3.4:8083/, advertising URL http://1.2.3.4:8083/
> (org.apache.kafka.connect.runtime.rest.RestServer:207)
> [2018-07-31 13:28:51,911] INFO Kafka Connect started
> (org.apache.kafka.connect.runtime.Connect:55)
> [2018-07-31 13:28:51,912] DEBUG Getting plugin class loader for connector:
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
> [2018-07-31 13:28:51,915] INFO ConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> transforms = []
> value.converter = null
> (org.apache.kafka.connect.runtime.ConnectorConfig:279)
> [2018-07-31 13:28:51,916] INFO EnrichedConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> transforms = []
> value.converter = null
>
>
> (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
> [2018-07-31 13:28:51,916] INFO Creating connector my-ignite-connector of
> type org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> (org.apache.kafka.connect.runtime.Worker:202)
> [2018-07-31 13:28:51,918] INFO Instantiated connector my-ignite-connector
> with version 1.1.1-cp1 of type class
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> (org.apache.kafka.connect.runtime.Worker:205)
> [2018-07-31 13:28:51,918] DEBUG Getting plugin class loader for connector:
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
> [2018-07-31 13:28:51,918] DEBUG WorkerConnector{id=my-ignite-connector}
> Initializing connector my-ignite-connector with config
>
> {connector.class=org.apache.ignite.stream.kafka.connect.IgniteSinkConnector,
> cacheName=mycache, tasks.max=1, topics=super_topic,
> name=my-ignite-connector, cacheAllowOverwrite=true,
> igniteCfg=/var/u00/ignite/config/clienttestconf.xml}
> (org.apache.kafka.connect.runtime.WorkerConnector:79)
> [2018-07-31 13:28:51,918] DEBUG WorkerConnector{id=my-ignite-connector}
> Transition connector to STARTED
> (org.apache.kafka.connect.runtime.WorkerConnector:190)
> [2018-07-31 13:28:51,918] DEBUG Starting
> Thread[qtp916958177-18-selector-ServerConnectorManager@48e7b3d2/0,5,main]
> on
> org.eclipse.jetty.io.SelectorManager$ManagedSelector@711d1a52 keys=0
> selected=0 (org.eclipse.jetty.io.SelectorManager:548)
> [2018-07-31 13:28:51,919] DEBUG Selector loop waiting on select
> (org.eclipse.jetty.io.SelectorManager:600)
> [2018-07-31 13:28:51,919] INFO Finished creating connector
> my-ignite-connector (org.apache.kafka.connect.runtime.Worker:224)
> [2018-07-31 13:28:51,919] DEBUG Getting plugin class loader for connector:
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
> [2018-07-31 13:28:51,920] INFO SinkConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> topics = [super_topic]
> topics.regex =
> transforms = []
> value.converter = null
> (org.apache.kafka.connect.runtime.SinkConnectorConfig:279)
> [2018-07-31 13:28:51,920] INFO EnrichedConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> topics = [super_topic]
> topics.regex =
> transforms = []
> value.converter = null
>
>
> (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
> [2018-07-31 13:28:51,920] DEBUG Getting plugin class loader for connector:
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
> [2018-07-31 13:28:51,921] INFO Creating task my-ignite-connector-0
> (org.apache.kafka.connect.runtime.Worker:362)
> [2018-07-31 13:28:51,921] INFO ConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> transforms = []
> value.converter = null
> (org.apache.kafka.connect.runtime.ConnectorConfig:279)
> [2018-07-31 13:28:51,921] INFO EnrichedConnectorConfig values:
> connector.class =
> org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
> header.converter = null
> key.converter = null
> name = my-ignite-connector
> tasks.max = 1
> transforms = []
> value.converter = null
>
>
> (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)
> [2018-07-31 13:28:51,921] DEBUG Getting plugin class loader for connector:
> 'org.apache.ignite.stream.kafka.connect.IgniteSinkConnector'
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:107)
> [2018-07-31 13:28:51,922] INFO TaskConfig values:
> task.class = class
> org.apache.ignite.stream.kafka.connect.IgniteSinkTask
> (org.apache.kafka.connect.runtime.TaskConfig:279)
> [2018-07-31 13:28:51,922] INFO Instantiated task my-ignite-connector-0 with
> version 1.1.1-cp1 of type
> org.apache.ignite.stream.kafka.connect.IgniteSinkTask
> (org.apache.kafka.connect.runtime.Worker:377)
> [2018-07-31 13:28:51,922] DEBUG Configuring the key converter with
> configuration:
> {schemas.enable=false}
> (org.apache.kafka.connect.runtime.isolation.Plugins:237)
> [2018-07-31 13:28:51,922] INFO StringConverterConfig values:
> converter.encoding = UTF8
> converter.type = key
> (org.apache.kafka.connect.storage.StringConverterConfig:279)
> [2018-07-31 13:28:51,922] INFO Set up the key converter class
> org.apache.kafka.connect.storage.StringConverter for task
> my-ignite-connector-0 using the worker config
>