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/
