search

lensesio / stream-reactor

A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.
https://lenses.io
Apache License 2.0
1k stars 362 forks source link

Cassandra Source Connector produce infinite events for same row even if it's consumed #631

Closed KabDeveloper closed 4 years ago

KabDeveloper commented 4 years ago

Kafka Version

Kafka 2.12-2.3.0

Cassandra Version

Cassandra 3.11.4

This is my connect config file:

name=cassandra-source-orders
connector.class=com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
tasks.max=1
connect.cassandra.key.space=demo
connect.cassandra.import.mode=incremental
connect.cassandra.contact.points=localhost
connect.cassandra.username=cassandra
connect.cassandra.password=cassandra
connect.cassandra.timestamp.type=timeuuid
connect.cassandra.mapping.collection.to.json=true
connect.cassandra.kcql=INSERT INTO orders-topic SELECT * FROM orders IGNORE id PK id WITHUNWRAP INCREMENTALMODE=INT
connect.progress.enabled=true

My Keyspace and table:

CREATE KEYSPACE demo WITH REPLICATION = {'class' : 'SimpleStrategy', 'replication_factor' : 3};
use demo;

create table orders (id int, created timeuuid, product text, qty int, price float, PRIMARY KEY (id, created))
WITH CLUSTERING ORDER BY (created asc);

When I insert new row: INSERT INTO orders (id, created, product, qty, price) VALUES (1, now(), 'OP-DAX-P-20150201-95.7', 100, 94.2); The connector produce it in infinite time.

When I launch this command to consume from orders-topic: ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic orders-topic

Each second he consume it again and again !

From the connector side, we have:


[2019-10-19 12:24:45,316] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:69)
[2019-10-19 12:24:45,326] 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=./../logs, -Dlog4j.configuration=file:./../config/connect-log4j.properties
    jvm.spec = Private Build, OpenJDK 64-Bit Server VM, 1.8.0_222, 25.222-b10
    jvm.classpath = ./../libs/activation-1.1.1.jar:./../libs/aopalliance-repackaged-2.5.0.jar:./../libs/argparse4j-0.7.0.jar:./../libs/audience-annotations-0.5.0.jar:./../libs/commons-lang3-3.8.1.jar:./../libs/connect-api-2.3.0.jar:./../libs/connect-basic-auth-extension-2.3.0.jar:./../libs/connect-file-2.3.0.jar:./../libs/connect-json-2.3.0.jar:./../libs/connect-runtime-2.3.0.jar:./../libs/connect-transforms-2.3.0.jar:./../libs/guava-20.0.jar:./../libs/hk2-api-2.5.0.jar:./../libs/hk2-locator-2.5.0.jar:./../libs/hk2-utils-2.5.0.jar:./../libs/jackson-annotations-2.9.9.jar:./../libs/jackson-core-2.9.9.jar:./../libs/jackson-databind-2.9.9.jar:./../libs/jackson-dataformat-csv-2.9.9.jar:./../libs/jackson-datatype-jdk8-2.9.9.jar:./../libs/jackson-jaxrs-base-2.9.9.jar:./../libs/jackson-jaxrs-json-provider-2.9.9.jar:./../libs/jackson-module-jaxb-annotations-2.9.9.jar:./../libs/jackson-module-paranamer-2.9.9.jar:./../libs/jackson-module-scala_2.12-2.9.9.jar:./../libs/jakarta.annotation-api-1.3.4.jar:./../libs/jakarta.inject-2.5.0.jar:./../libs/jakarta.ws.rs-api-2.1.5.jar:./../libs/javassist-3.22.0-CR2.jar:./../libs/javax.servlet-api-3.1.0.jar:./../libs/javax.ws.rs-api-2.1.1.jar:./../libs/jaxb-api-2.3.0.jar:./../libs/jersey-client-2.28.jar:./../libs/jersey-common-2.28.jar:./../libs/jersey-container-servlet-2.28.jar:./../libs/jersey-container-servlet-core-2.28.jar:./../libs/jersey-hk2-2.28.jar:./../libs/jersey-media-jaxb-2.28.jar:./../libs/jersey-server-2.28.jar:./../libs/jetty-client-9.4.18.v20190429.jar:./../libs/jetty-continuation-9.4.18.v20190429.jar:./../libs/jetty-http-9.4.18.v20190429.jar:./../libs/jetty-io-9.4.18.v20190429.jar:./../libs/jetty-security-9.4.18.v20190429.jar:./../libs/jetty-server-9.4.18.v20190429.jar:./../libs/jetty-servlet-9.4.18.v20190429.jar:./../libs/jetty-servlets-9.4.18.v20190429.jar:./../libs/jetty-util-9.4.18.v20190429.jar:./../libs/jopt-simple-5.0.4.jar:./../libs/jsr305-3.0.2.jar:./../libs/kafka_2.12-2.3.0.jar:./../libs/kafka_2.12-2.3.0-sources.jar:./../libs/kafka-clients-2.3.0.jar:./../libs/kafka-log4j-appender-2.3.0.jar:./../libs/kafka-streams-2.3.0.jar:./../libs/kafka-streams-examples-2.3.0.jar:./../libs/kafka-streams-scala_2.12-2.3.0.jar:./../libs/kafka-streams-test-utils-2.3.0.jar:./../libs/kafka-tools-2.3.0.jar:./../libs/log4j-1.2.17.jar:./../libs/lz4-java-1.6.0.jar:./../libs/maven-artifact-3.6.1.jar:./../libs/metrics-core-2.2.0.jar:./../libs/osgi-resource-locator-1.0.1.jar:./../libs/paranamer-2.8.jar:./../libs/plexus-utils-3.2.0.jar:./../libs/reflections-0.9.11.jar:./../libs/rocksdbjni-5.18.3.jar:./../libs/scala-library-2.12.8.jar:./../libs/scala-logging_2.12-3.9.0.jar:./../libs/scala-reflect-2.12.8.jar:./../libs/slf4j-api-1.7.26.jar:./../libs/slf4j-log4j12-1.7.26.jar:./../libs/snappy-java-1.1.7.3.jar:./../libs/spotbugs-annotations-3.1.9.jar:./../libs/validation-api-2.0.1.Final.jar:./../libs/zkclient-0.11.jar:./../libs/zookeeper-3.4.14.jar:./../libs/zstd-jni-1.4.0-1.jar
    os.spec = Linux, amd64, 4.13.0-41-generic
    os.vcpus = 8
 (org.apache.kafka.connect.runtime.WorkerInfo:71)
[2019-10-19 12:24:45,331] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:78)
[2019-10-19 12:24:45,353] INFO Loading plugin from: /usr/local/kafka/plugins/lib/guava-16.0.1.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,652] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/guava-16.0.1.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,653] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:45,653] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:45,653] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:45,654] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jnr-ffi-2.0.7.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,704] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jnr-ffi-2.0.7.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,705] INFO Loading plugin from: /usr/local/kafka/plugins/lib/netty-handler-4.0.37.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,735] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/netty-handler-4.0.37.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,736] INFO Loading plugin from: /usr/local/kafka/plugins/lib/cassandra-driver-core-3.1.4.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,813] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/cassandra-driver-core-3.1.4.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,814] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jnr-constants-0.9.0.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,834] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jnr-constants-0.9.0.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,835] INFO Loading plugin from: /usr/local/kafka/plugins/lib/asm-tree-5.0.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,840] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/asm-tree-5.0.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,841] INFO Loading plugin from: /usr/local/kafka/plugins/lib/metrics-core-3.1.2.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,853] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/metrics-core-3.1.2.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,853] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jffi-1.2.10-native.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,857] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jffi-1.2.10-native.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,857] INFO Loading plugin from: /usr/local/kafka/plugins/lib/netty-buffer-4.0.37.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,875] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/netty-buffer-4.0.37.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,876] INFO Loading plugin from: /usr/local/kafka/plugins/lib/asm-commons-5.0.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,883] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/asm-commons-5.0.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,884] INFO Loading plugin from: /usr/local/kafka/plugins/lib/asm-5.0.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,890] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/asm-5.0.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,891] INFO Loading plugin from: /usr/local/kafka/plugins/lib/netty-codec-4.0.37.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,905] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/netty-codec-4.0.37.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,905] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jnr-x86asm-1.0.2.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,922] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jnr-x86asm-1.0.2.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,923] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jffi-1.2.10.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,936] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jffi-1.2.10.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,936] INFO Loading plugin from: /usr/local/kafka/plugins/lib/slf4j-api-1.7.21.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,943] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/slf4j-api-1.7.21.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,943] INFO Loading plugin from: /usr/local/kafka/plugins/lib/asm-analysis-5.0.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:45,949] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/asm-analysis-5.0.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:45,949] INFO Loading plugin from: /usr/local/kafka/plugins/lib/kafka-connect-cassandra-1.2.3-2.1.0-all.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:48,470] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/kafka-connect-cassandra-1.2.3-2.1.0-all.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:48,471] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:48,471] INFO Added plugin 'com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:48,471] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:48,471] INFO Added plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:48,471] INFO Added plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:48,490] INFO Loading plugin from: /usr/local/kafka/plugins/lib/netty-common-4.0.37.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:48,512] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/netty-common-4.0.37.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:48,513] INFO Loading plugin from: /usr/local/kafka/plugins/lib/asm-util-5.0.3.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:48,517] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/asm-util-5.0.3.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:48,517] INFO Loading plugin from: /usr/local/kafka/plugins/lib/kafka-connect-cassandra-1.2.2-2.1.0-all.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:50,411] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/kafka-connect-cassandra-1.2.2-2.1.0-all.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:50,420] INFO Loading plugin from: /usr/local/kafka/plugins/lib/jnr-posix-3.0.27.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:50,431] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/jnr-posix-3.0.27.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:50,431] INFO Loading plugin from: /usr/local/kafka/plugins/lib/netty-transport-4.0.37.Final.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2019-10-19 12:24:50,447] INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/local/kafka/plugins/lib/netty-transport-4.0.37.Final.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:50,891] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2019-10-19 12:24:50,891] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,891] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,892] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,893] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,894] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2019-10-19 12:24:50,895] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,895] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,895] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,896] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,897] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,897] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,897] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,897] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,898] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,898] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,898] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,898] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,898] INFO Added aliases 'JsonResilientConverter' and 'JsonResilient' to plugin 'com.datamountaineer.streamreactor.connect.converters.source.JsonResilientConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,899] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,900] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,900] INFO Added alias 'Transformation' to plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,900] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,901] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,901] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,901] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2019-10-19 12:24:50,901] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,901] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,901] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2019-10-19 12:24:50,913] INFO StandaloneConfig values: 
    access.control.allow.methods = 
    access.control.allow.origin = 
    bootstrap.servers = [localhost:9092]
    client.dns.lookup = default
    config.providers = []
    connector.client.config.override.policy = None
    header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
    internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
    internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
    key.converter = class org.apache.kafka.connect.json.JsonConverter
    listeners = null
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    offset.flush.interval.ms = 10000
    offset.flush.timeout.ms = 5000
    offset.storage.file.filename = /tmp/connect.offsets
    plugin.path = [/usr/local/kafka/plugins/lib]
    rest.advertised.host.name = null
    rest.advertised.listener = null
    rest.advertised.port = null
    rest.extension.classes = []
    rest.host.name = null
    rest.port = 8083
    ssl.client.auth = none
    task.shutdown.graceful.timeout.ms = 5000
    value.converter = class org.apache.kafka.connect.json.JsonConverter
 (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:347)
[2019-10-19 12:24:50,914] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
[2019-10-19 12:24:50,918] INFO AdminClientConfig values: 
    bootstrap.servers = [localhost:9092]
    client.dns.lookup = default
    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.client.callback.handler.class = null
    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.login.callback.handler.class = null
    sasl.login.class = null
    sasl.login.refresh.buffer.seconds = 300
    sasl.login.refresh.min.period.seconds = 60
    sasl.login.refresh.window.factor = 0.8
    sasl.login.refresh.window.jitter = 0.05
    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 = https
    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:347)
[2019-10-19 12:24:50,950] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,950] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2019-10-19 12:24:50,951] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2019-10-19 12:24:50,951] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2019-10-19 12:24:50,951] INFO Kafka startTimeMs: 1571484290950 (org.apache.kafka.common.utils.AppInfoParser:119)
[2019-10-19 12:24:51,091] INFO Kafka cluster ID: xrJk-1v6RQiGQpzJQjse8Q (org.apache.kafka.connect.util.ConnectUtils:59)
[2019-10-19 12:24:51,109] INFO Logging initialized @6048ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
[2019-10-19 12:24:51,156] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:122)
[2019-10-19 12:24:51,156] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:166)
[2019-10-19 12:24:51,165] INFO jetty-9.4.18.v20190429; built: 2019-04-29T20:42:08.989Z; git: e1bc35120a6617ee3df052294e433f3a25ce7097; jvm 1.8.0_222-8u222-b10-1ubuntu1~16.04.1-b10 (org.eclipse.jetty.server.Server:370)
[2019-10-19 12:24:51,195] INFO Started http_8083@4c7a078{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292)
[2019-10-19 12:24:51,196] INFO Started @6134ms (org.eclipse.jetty.server.Server:410)
[2019-10-19 12:24:51,219] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2019-10-19 12:24:51,219] INFO REST server listening at http://127.0.1.1:8083/, advertising URL http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:181)
[2019-10-19 12:24:51,219] INFO Advertised URI: http://127.0.1.1:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2019-10-19 12:24:51,220] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2019-10-19 12:24:51,229] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2019-10-19 12:24:51,244] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2019-10-19 12:24:51,244] INFO Kafka startTimeMs: 1571484291229 (org.apache.kafka.common.utils.AppInfoParser:119)
[2019-10-19 12:24:51,361] INFO JsonConverterConfig values: 
    converter.type = key
    schemas.cache.size = 1000
    schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-10-19 12:24:51,362] INFO JsonConverterConfig values: 
    converter.type = value
    schemas.cache.size = 1000
    schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-10-19 12:24:51,369] INFO Kafka Connect standalone worker initialization took 6051ms (org.apache.kafka.connect.cli.ConnectStandalone:100)
[2019-10-19 12:24:51,369] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
[2019-10-19 12:24:51,369] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:91)
[2019-10-19 12:24:51,369] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:182)
[2019-10-19 12:24:51,369] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:58)
[2019-10-19 12:24:51,375] INFO Worker started (org.apache.kafka.connect.runtime.Worker:187)
[2019-10-19 12:24:51,375] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:93)
[2019-10-19 12:24:51,375] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:186)
[2019-10-19 12:24:51,478] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
[2019-10-19 12:24:51,478] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
[2019-10-19 12:24:51,479] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
Oct 19, 2019 12:24:51 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. 
Oct 19, 2019 12:24:51 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. 
Oct 19, 2019 12:24:51 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime
WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. 
Oct 19, 2019 12:24:51 PM org.glassfish.jersey.internal.Errors logErrors
WARNING: The following warnings have been detected: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

[2019-10-19 12:24:51,981] INFO Started o.e.j.s.ServletContextHandler@78faea5f{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
[2019-10-19 12:24:51,982] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:233)
[2019-10-19 12:24:51,982] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2019-10-19 12:24:51,988] INFO AbstractConfig values: 
 (org.apache.kafka.common.config.AbstractConfig:347)
[2019-10-19 12:24:51,994] INFO ConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2019-10-19 12:24:51,994] INFO EnrichedConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2019-10-19 12:24:51,995] INFO Creating connector cassandra-source-orders of type com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector (org.apache.kafka.connect.runtime.Worker:246)
[2019-10-19 12:24:51,997] INFO Instantiated connector cassandra-source-orders with version 1.2.3 of type class com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector (org.apache.kafka.connect.runtime.Worker:249)
[2019-10-19 12:24:51,998] INFO Finished creating connector cassandra-source-orders (org.apache.kafka.connect.runtime.Worker:268)
[2019-10-19 12:24:51,998] INFO SourceConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:347)
[2019-10-19 12:24:51,999] INFO EnrichedConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2019-10-19 12:24:52,076] INFO Setting task configurations for 1 workers. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector:64)
[2019-10-19 12:24:52,085] INFO Creating task cassandra-source-orders-0 (org.apache.kafka.connect.runtime.Worker:414)
[2019-10-19 12:24:52,085] INFO ConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2019-10-19 12:24:52,085] INFO EnrichedConnectorConfig values: 
    config.action.reload = restart
    connector.class = com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector
    errors.log.enable = false
    errors.log.include.messages = false
    errors.retry.delay.max.ms = 60000
    errors.retry.timeout = 0
    errors.tolerance = none
    header.converter = null
    key.converter = null
    name = cassandra-source-orders
    tasks.max = 1
    transforms = []
    value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2019-10-19 12:24:52,086] INFO TaskConfig values: 
    task.class = class com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2019-10-19 12:24:52,087] INFO Instantiated task cassandra-source-orders-0 with version 1.2.3 of type com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask (org.apache.kafka.connect.runtime.Worker:428)
[2019-10-19 12:24:52,087] INFO JsonConverterConfig values: 
    converter.type = key
    schemas.cache.size = 1000
    schemas.enable = true
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-10-19 12:24:52,088] INFO Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task cassandra-source-orders-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2019-10-19 12:24:52,088] INFO JsonConverterConfig values: 
    converter.type = value
    schemas.cache.size = 1000
    schemas.enable = true
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2019-10-19 12:24:52,088] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task cassandra-source-orders-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2019-10-19 12:24:52,088] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task cassandra-source-orders-0 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2019-10-19 12:24:52,093] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:507)
[2019-10-19 12:24:52,098] INFO ProducerConfig values: 
    acks = all
    batch.size = 16384
    bootstrap.servers = [localhost:9092]
    buffer.memory = 33554432
    client.dns.lookup = default
    client.id = connector-producer-cassandra-source-orders-0
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 2147483647
    enable.idempotence = false
    interceptor.classes = []
    key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
    linger.ms = 0
    max.block.ms = 9223372036854775807
    max.in.flight.requests.per.connection = 1
    max.request.size = 1048576
    metadata.max.age.ms = 300000
    metric.reporters = []
    metrics.num.samples = 2
    metrics.recording.level = INFO
    metrics.sample.window.ms = 30000
    partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
    receive.buffer.bytes = 32768
    reconnect.backoff.max.ms = 1000
    reconnect.backoff.ms = 50
    request.timeout.ms = 2147483647
    retries = 2147483647
    retry.backoff.ms = 100
    sasl.client.callback.handler.class = null
    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.login.callback.handler.class = null
    sasl.login.class = null
    sasl.login.refresh.buffer.seconds = 300
    sasl.login.refresh.min.period.seconds = 60
    sasl.login.refresh.window.factor = 0.8
    sasl.login.refresh.window.jitter = 0.05
    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 = https
    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
    transaction.timeout.ms = 60000
    transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig:347)
[2019-10-19 12:24:52,125] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2019-10-19 12:24:52,126] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2019-10-19 12:24:52,126] INFO Kafka startTimeMs: 1571484292125 (org.apache.kafka.common.utils.AppInfoParser:119)
[2019-10-19 12:24:52,135] INFO Created connector cassandra-source-orders (org.apache.kafka.connect.cli.ConnectStandalone:112)
[2019-10-19 12:24:52,142] INFO 
    __                    __
   / /   ____ _____  ____/ /___  ____  ____
  / /   / __ `/ __ \/ __  / __ \/ __ \/ __ \
 / /___/ /_/ / / / / /_/ / /_/ / /_/ / /_/ /
/_____/\__,_/_/ /_/\__,_/\____/\____/ .___/
                                   /_/
       ______                                __           _____
      / ____/___ _______________ _____  ____/ /________ _/ ___/____  __  _______________
     / /   / __ `/ ___/ ___/ __ `/ __ \/ __  / ___/ __ `/\__ \/ __ \/ / / / ___/ ___/ _ \
    / /___/ /_/ (__  |__  ) /_/ / / / / /_/ / /  / /_/ /___/ / /_/ / /_/ / /  / /__/  __/
    \____/\__,_/____/____/\__,_/_/ /_/\__,_/_/   \__,_//____/\____/\__,_/_/   \___/\___/

 By Andrew Stevenson.1.2.3 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:63)
[2019-10-19 12:24:52,143] INFO 
StreamReactor-Version:       1.2.3
Kafka-Version:               2.1.0
Git-Repo:                    
Git-Commit-Hash:             42a7d40f78de0d2cf52f95e80ba3c62387eb758c
Git-Tag:                     1.2.3
StreamReactor-Docs:          https://docs.lenses.io/connectors/
       (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:64)
[2019-10-19 12:24:52,146] INFO CassandraConfigSource values: 
    connect.cassandra.assigned.tables = orders
    connect.cassandra.batch.size = 100
    connect.cassandra.consistency.level = 
    connect.cassandra.contact.points = localhost
    connect.cassandra.error.policy = THROW
    connect.cassandra.fetch.size = 5000
    connect.cassandra.import.allow.filtering = true
    connect.cassandra.import.poll.interval = 1000
    connect.cassandra.initial.offset = 1900-01-01 00:00:00.0000000Z
    connect.cassandra.kcql = INSERT INTO orders-topic SELECT * FROM orders
    connect.cassandra.key.space = demo
    connect.cassandra.key.store.password = [hidden]
    connect.cassandra.key.store.path = 
    connect.cassandra.key.store.type = JKS
    connect.cassandra.mapping.collection.to.json = true
    connect.cassandra.max.retries = 20
    connect.cassandra.password = [hidden]
    connect.cassandra.port = 9042
    connect.cassandra.retry.interval = 60000
    connect.cassandra.slice.delay.ms = 30000
    connect.cassandra.slice.duration = 10000
    connect.cassandra.ssl.client.cert.auth = false
    connect.cassandra.ssl.enabled = false
    connect.cassandra.task.buffer.size = 10000
    connect.cassandra.time.slice.ms = 10000
    connect.cassandra.trust.store.password = [hidden]
    connect.cassandra.trust.store.path = 
    connect.cassandra.trust.store.type = JKS
    connect.cassandra.username = cassandra
 (com.datamountaineer.streamreactor.connect.cassandra.config.CassandraConfigSource:347)
[2019-10-19 12:24:52,151] INFO DataStax Java driver 3.7.1 for Apache Cassandra (com.datastax.driver.core:261)
[2019-10-19 12:24:52,156] INFO Detected Guava >= 19 in the classpath, using modern compatibility layer (com.datastax.driver.core.GuavaCompatibility:185)
[2019-10-19 12:24:52,226] INFO [Producer clientId=connector-producer-cassandra-source-orders-0] Cluster ID: xrJk-1v6RQiGQpzJQjse8Q (org.apache.kafka.clients.Metadata:266)
[2019-10-19 12:24:52,339] INFO Using native clock to generate timestamps. (com.datastax.driver.core.ClockFactory:57)
[2019-10-19 12:24:52,430] INFO Found Netty's native epoll transport in the classpath, using it (com.datastax.driver.core.NettyUtil:72)
[2019-10-19 12:24:52,691] INFO Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor) (com.datastax.driver.core.policies.DCAwareRoundRobinPolicy:110)
[2019-10-19 12:24:52,692] INFO New Cassandra host localhost/127.0.0.1:9042 added (com.datastax.driver.core.Cluster:1621)
[2019-10-19 12:24:52,714] INFO Connection to Cassandra established. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:82)
[2019-10-19 12:24:52,748] INFO generated CQL: SELECT * FROM demo.orders (com.datamountaineer.streamreactor.connect.cassandra.source.CqlGenerator:79)
[2019-10-19 12:24:52,755] INFO Generated CQL: SELECT * FROM demo.orders (com.datamountaineer.streamreactor.connect.cassandra.source.CqlGenerator:55)
[2019-10-19 12:24:52,757] WARN Re-preparing already prepared query is generally an anti-pattern and will likely affect performance. Consider preparing the statement only once. Query='SELECT * FROM demo.orders' (com.datastax.driver.core.Cluster:2345)
[2019-10-19 12:24:52,785] INFO Recovered offset 1900-01-01 00:00:00.000Z for connector cassandra-source-orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:88)
[2019-10-19 12:24:52,863] INFO WorkerSourceTask{id=cassandra-source-orders-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:200)
[2019-10-19 12:24:52,864] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,879] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:52,879] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,880] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,881] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,882] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,883] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,884] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,885] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:52,886] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:52,887] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:52,887] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:52,888] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:52,912] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,914] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,915] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,915] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,915] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,916] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,916] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,916] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,917] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,917] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,918] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,918] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,918] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,918] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:53,919] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,920] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,920] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,920] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:53,920] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:53,921] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,922] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,923] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,923] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,923] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,924] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,924] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,924] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,924] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,924] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:53,925] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:53,926] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:53,927] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,928] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,929] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,930] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,930] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,930] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,931] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,931] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,932] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:54,932] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,932] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,933] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,933] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:54,933] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,934] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:54,934] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,936] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,937] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,937] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,937] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:54,938] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:54,939] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,940] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,941] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,942] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,942] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,942] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,943] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,943] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,943] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,944] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,945] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:55,945] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,945] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:55,945] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,946] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,947] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,947] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,947] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,947] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:55,947] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,948] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,948] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:55,948] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:55,948] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:55,948] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:55,949] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:55,949] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,950] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,952] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,952] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,952] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,953] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,953] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,953] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,954] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,954] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,954] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,955] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:56,955] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,955] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:56,956] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,957] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,958] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,958] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,958] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,958] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,959] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,959] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,959] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,959] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:56,960] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,961] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:57,962] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,963] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,963] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,964] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,964] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,965] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,965] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,965] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,966] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:57,966] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,966] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,967] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:57,967] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,968] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:57,968] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,968] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,969] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,969] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,969] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,969] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,969] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:57,970] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:57,971] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,972] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,972] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,973] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:58,974] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,975] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,975] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,975] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,975] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:58,975] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,976] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:58,976] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,977] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,978] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,978] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,978] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,979] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:58,980] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:58,981] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:58,982] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,983] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,984] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,984] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,984] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,985] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,985] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,985] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,985] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,986] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,986] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,986] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,986] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,986] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,987] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:59,987] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,988] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,988] INFO Connector cassandra-source-orders end of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,988] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:59,988] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,990] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:59,990] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,991] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,992] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:24:59,993] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:24:59,993] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:24:59,993] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:24:59,993] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:24:59,993] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:00,994] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:00,996] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:00,996] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:00,996] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:00,997] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:00,997] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:00,997] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:00,998] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:00,998] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:00,998] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:00,999] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:00,999] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,000] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:01,000] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,000] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:01,000] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,001] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:01,002] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,003] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:01,004] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:01,005] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:01,005] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:01,005] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:01,005] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,006] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,007] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,008] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,008] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,008] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,009] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,009] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,009] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,009] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,009] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,010] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,010] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:02,010] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,011] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,011] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,012] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,012] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:02,012] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:02,012] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,014] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,015] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,015] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,015] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,016] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:02,017] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,018] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,018] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:02,018] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:02,018] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:02,018] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:02,019] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:02,135] INFO WorkerSourceTask{id=cassandra-source-orders-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
[2019-10-19 12:25:02,135] INFO WorkerSourceTask{id=cassandra-source-orders-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
[2019-10-19 12:25:02,141] INFO WorkerSourceTask{id=cassandra-source-orders-0} Finished commitOffsets successfully in 6 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:497)
[2019-10-19 12:25:03,020] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,020] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,020] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,020] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,021] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,021] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,021] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,022] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,022] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,022] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,022] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,023] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,023] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,023] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:03,023] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,023] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,024] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,024] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:03,024] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,025] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:03,025] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,027] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,027] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,027] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,028] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,029] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:03,029] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:03,029] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:03,029] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:03,029] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:03,030] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,030] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,031] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,032] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,032] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,032] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,032] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,033] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,033] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,033] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,033] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,034] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:04,035] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,036] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,036] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,036] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,036] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,036] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,037] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,038] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:04,039] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:04,039] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:04,039] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:04,039] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:04,040] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,041] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,042] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,042] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,042] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,043] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,043] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,043] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,044] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,044] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,044] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,044] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:05,045] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,045] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,045] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,046] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,046] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,046] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:05,046] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:05,047] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,048] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,049] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,050] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:05,051] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:05,051] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:05,051] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:05,051] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:05,051] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,052] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,053] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,053] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,053] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,054] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,054] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,054] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,054] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,054] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,055] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,055] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,055] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,055] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,055] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,056] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,057] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,057] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:06,057] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,057] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:06,057] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,058] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,059] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,059] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,060] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,060] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,060] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,060] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,061] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,061] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,061] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,061] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:06,062] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:06,063] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:06,063] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:06,063] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,064] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:07,065] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,066] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,067] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,067] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,067] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,067] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,067] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,068] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,068] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,068] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,069] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,069] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:07,069] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,069] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,070] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,070] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:07,070] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,071] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:07,071] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,072] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,073] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,073] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,074] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,074] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,074] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,074] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,074] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:07,075] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:07,076] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:07,076] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:07,076] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,077] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:08,077] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,079] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,079] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,079] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,080] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,080] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,080] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,081] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,081] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,081] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,081] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:08,081] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,082] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,082] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,082] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,082] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,083] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:08,083] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:08,083] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,084] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,084] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,085] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,086] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:08,087] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,088] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:09,089] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,090] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,090] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,090] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,090] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,091] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:09,092] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,093] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,093] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,094] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,095] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:09,096] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:09,097] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
^A[2019-10-19 12:25:10,098] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,099] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,099] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,099] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,100] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,100] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,100] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,100] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,100] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,101] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,101] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,101] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,102] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,102] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:10,102] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,102] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,102] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,103] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:10,103] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,104] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:10,104] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,105] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:10,106] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,108] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:11,108] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,109] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,110] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,110] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,110] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,110] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,111] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,111] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,111] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,111] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,112] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,112] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:11,112] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,112] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,113] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,113] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,113] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:11,113] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:11,114] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,115] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,115] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,115] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,116] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:11,117] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:11,118] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:11,118] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:11,118] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:11,118] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,119] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:12,120] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,121] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,121] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,121] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,122] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,122] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,122] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:12,122] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,123] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,123] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,123] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:12,123] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:12,124] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,125] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,126] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,126] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,126] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,127] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,127] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,127] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,127] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,128] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,128] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,128] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,128] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,128] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:12,129] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:12,130] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:12,130] INFO Connector cassandra-source-orders start of poll queue size for orders is: 1 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:12,141] INFO WorkerSourceTask{id=cassandra-source-orders-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
[2019-10-19 12:25:12,141] INFO WorkerSourceTask{id=cassandra-source-orders-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
[2019-10-19 12:25:12,142] INFO WorkerSourceTask{id=cassandra-source-orders-0} Finished commitOffsets successfully in 1 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:497)
[2019-10-19 12:25:13,131] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:13,131] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,133] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,133] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,134] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,134] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,134] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:13,134] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:13,135] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,136] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,136] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,136] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,137] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:13,138] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,139] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
[2019-10-19 12:25:13,139] INFO Connector cassandra-source-orders reader for table orders is still querying... (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:162)
[2019-10-19 12:25:13,139] INFO Connector cassandra-source-orders processed 1 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:13,139] INFO Connector cassandra-source-orders attempting to drain Some(100) items from the queue for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:168)
[2019-10-19 12:25:13,139] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,140] INFO Connector cassandra-source-orders start of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:147)
^C[2019-10-19 12:25:13,613] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:66)
[2019-10-19 12:25:13,614] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:241)
[2019-10-19 12:25:13,622] INFO Stopped http_8083@4c7a078{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:341)
[2019-10-19 12:25:13,622] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
[2019-10-19 12:25:13,624] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:258)
[2019-10-19 12:25:13,624] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:98)
[2019-10-19 12:25:13,625] INFO Stopping task cassandra-source-orders-0 (org.apache.kafka.connect.runtime.Worker:684)
[2019-10-19 12:25:13,625] INFO Stopping Cassandra source cassandra-source-orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:183)
[2019-10-19 12:25:13,625] INFO Connector cassandra-source-orders end of poll queue size for orders is: 0 (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:174)
[2019-10-19 12:25:13,625] INFO WorkerSourceTask{id=cassandra-source-orders-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
[2019-10-19 12:25:13,625] INFO Connector cassandra-source-orders shutting down queries. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:379)
[2019-10-19 12:25:13,626] INFO Connector cassandra-source-orders processing results for demo.orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:223)
[2019-10-19 12:25:13,627] INFO Connector cassandra-source-orders processed 0 row(-s) into orders-topic topic for table orders (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:246)
[2019-10-19 12:25:15,626] INFO Connector cassandra-source-orders querying stopped for demo.orders-topic. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:394)
[2019-10-19 12:25:15,626] INFO Connector cassandra-source-orders all stopped. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraTableReader:381)
[2019-10-19 12:25:15,626] INFO Shutting down Cassandra driver connections for cassandra-source-orders. (com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceTask:189)
[2019-10-19 12:25:17,852] INFO WorkerSourceTask{id=cassandra-source-orders-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
[2019-10-19 12:25:17,854] INFO WorkerSourceTask{id=cassandra-source-orders-0} Finished commitOffsets successfully in 4229 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:497)

I want the incrementation will be by ID and not TIMESTAMP

Can you help to find what is the problem here please ?

Thanks in advance.

andrewstevenson commented 4 years ago

From the docs

In incremental mode the connector supports querying based on a column in the tables with CQL data type of Timestamp or TimeUUID. Incremental mode is set by specifying INCREMENTALMODE in the kcql statement as either TIMESTAMP, TIMEUUID or TOKEN.

Int is not supported. Are you up for contributing and creating a PR?

KabDeveloper commented 4 years ago

@andrewstevenson I am not familiar with scala, but I will try to apport my help if I find something or my changes once applied will give the waited result :)

Thank you