Skip to content

Instantly share code, notes, and snippets.

@crcastle

crcastle/tweet-producer-exception.log

Created September 27, 2016 17:06
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save crcastle/6f78b025d29840c626d9ba995a92850e to your computer and use it in GitHub Desktop.
Save crcastle/6f78b025d29840c626d9ba995a92850e to your computer and use it in GitHub Desktop.
Download ZIP
Tweet Producer Log
Raw
tweet-producer-exception.log
Sep 27 08:00:49 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:00:59 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:01:09 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:01:19 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:01:29 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:01:39 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:01:49 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 11 ms
Sep 27 08:01:59 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 13 ms
Sep 27 08:02:09 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:02:19 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 12 ms
Sep 27 08:02:29 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 17 ms
Sep 27 08:02:36 twitter-ingest app/web.1: [pool-2-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 11 ms
Sep 27 08:02:36 twitter-ingest app/web.1: [pool-2-thread-1] ERROR org.apache.kafka.connect.runtime.WorkerTask - Task twitter-source-0 threw an uncaught and unrecoverable exception
Sep 27 08:02:36 twitter-ingest app/web.1: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:210)
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.data.Struct.put(Struct.java:215)
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.data.Struct.put(Struct.java:204)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.domain.Entities$$anonfun$struct$4.apply(TwitterStatus.scala:55)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.domain.Entities$$anonfun$struct$4.apply(TwitterStatus.scala:52)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:35)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$class.map(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.AbstractTraversable.map(Traversable.scala:104)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.domain.Entities$.struct(TwitterStatus.scala:52)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.domain.TwitterStatus$.struct(TwitterStatus.scala:103)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.StatusToTwitterStatusStructure$.convert(TwitterStatusReader.scala:57)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.TwitterStatusReader$$anonfun$poll$1.apply(TwitterStatusReader.scala:96)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.TwitterStatusReader$$anonfun$poll$1.apply(TwitterStatusReader.scala:96)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.Iterator$class.foreach(Iterator.scala:742)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.AbstractIterator.foreach(Iterator.scala:1194)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.TraversableLike$class.map(TraversableLike.scala:245)
Sep 27 08:02:36 twitter-ingest app/web.1: at scala.collection.AbstractTraversable.map(Traversable.scala:104)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.TwitterStatusReader.poll(TwitterStatusReader.scala:96)
Sep 27 08:02:36 twitter-ingest app/web.1: at com.eneco.trading.kafka.connect.twitter.TwitterSourceTask.poll(TwitterSourceTask.scala:15)
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:155)
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
Sep 27 08:02:36 twitter-ingest app/web.1: at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
Sep 27 08:02:36 twitter-ingest app/web.1: at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
Sep 27 08:02:36 twitter-ingest app/web.1: at java.util.concurrent.FutureTask.run(FutureTask.java:266)
Sep 27 08:02:36 twitter-ingest app/web.1: at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
Sep 27 08:02:36 twitter-ingest app/web.1: at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
Sep 27 08:02:36 twitter-ingest app/web.1: at java.lang.Thread.run(Thread.java:745)
Sep 27 08:02:36 twitter-ingest app/web.1: [pool-2-thread-1] ERROR org.apache.kafka.connect.runtime.WorkerTask - Task is being killed and will not recover until manually restarted
Sep 27 08:04:44 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 165
Sep 27 08:04:44 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 200
Raw
tweet-producer-startup.log
Sep 26 20:17:31 twitter-ingest app/web.1: Setting JAVA_TOOL_OPTIONS defaults based on dyno size. Custom settings will override them.
Sep 26 20:17:31 twitter-ingest app/web.1: Picked up JAVA_TOOL_OPTIONS: -Xmx2g -Dfile.encoding=UTF-8
Sep 26 20:17:31 twitter-ingest app/web.1: Certificate was added to keystore
Sep 26 20:17:31 twitter-ingest app/web.1: Picked up JAVA_TOOL_OPTIONS: -Xmx2g -Dfile.encoding=UTF-8
Sep 26 20:17:31 twitter-ingest app/web.1: Entry for alias 1 successfully imported.
Sep 26 20:17:32 twitter-ingest app/web.1: Import command completed: 1 entries successfully imported, 0 entries failed or cancelled
Sep 26 20:17:32 twitter-ingest app/web.1: Picked up JAVA_TOOL_OPTIONS: -Xmx2g -Dfile.encoding=UTF-8
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Class path contains multiple SLF4J bindings.
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Found binding in [jar:file:/app/target/kafka-connect-twitter-0.1-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class]
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Found binding in [jar:file:/app/share/java/confluent-common/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Found binding in [jar:file:/app/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Found binding in [jar:file:/app/share/java/kafka/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
Sep 26 20:17:32 twitter-ingest app/web.1: SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.standalone.StandaloneConfig - StandaloneConfig values:
Sep 26 20:17:32 twitter-ingest app/web.1: cluster = connect
Sep 26 20:17:32 twitter-ingest app/web.1: rest.advertised.host.name = null
Sep 26 20:17:32 twitter-ingest app/web.1: task.shutdown.graceful.timeout.ms = 5000
Sep 26 20:17:32 twitter-ingest app/web.1: rest.host.name = null
Sep 26 20:17:32 twitter-ingest app/web.1: rest.advertised.port = null
Sep 26 20:17:32 twitter-ingest app/web.1: bootstrap.servers = [ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096]
Sep 26 20:17:32 twitter-ingest app/web.1: offset.flush.timeout.ms = 5000
Sep 26 20:17:32 twitter-ingest app/web.1: offset.flush.interval.ms = 10000
Sep 26 20:17:32 twitter-ingest app/web.1: rest.port = 13266
Sep 26 20:17:32 twitter-ingest app/web.1: internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
Sep 26 20:17:32 twitter-ingest app/web.1: access.control.allow.methods =
Sep 26 20:17:32 twitter-ingest app/web.1: access.control.allow.origin =
Sep 26 20:17:32 twitter-ingest app/web.1: offset.storage.file.filename = /tmp/connect.offsets
Sep 26 20:17:32 twitter-ingest app/web.1: internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
Sep 26 20:17:32 twitter-ingest app/web.1: value.converter = class org.apache.kafka.connect.json.JsonConverter
Sep 26 20:17:32 twitter-ingest app/web.1: key.converter = class org.apache.kafka.connect.json.JsonConverter
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Connect - Kafka Connect starting
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.standalone.StandaloneHerder - Herder starting
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Worker starting
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
Sep 26 20:17:32 twitter-ingest app/web.1: metric.reporters = []
Sep 26 20:17:32 twitter-ingest app/web.1: metadata.max.age.ms = 300000
Sep 26 20:17:32 twitter-ingest app/web.1: reconnect.backoff.ms = 50
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.ticket.renew.window.factor = 0.8
Sep 26 20:17:32 twitter-ingest app/web.1: bootstrap.servers = [ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096]
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.type = JKS
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.mechanism = GSSAPI
Sep 26 20:17:32 twitter-ingest app/web.1: max.block.ms = 9223372036854775807
Sep 26 20:17:32 twitter-ingest app/web.1: interceptor.classes = null
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: client.id =
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.endpoint.identification.algorithm = null
Sep 26 20:17:32 twitter-ingest app/web.1: request.timeout.ms = 2147483647
Sep 26 20:17:32 twitter-ingest app/web.1: acks = all
Sep 26 20:17:32 twitter-ingest app/web.1: receive.buffer.bytes = 32768
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.type = JKS
Sep 26 20:17:32 twitter-ingest app/web.1: retries = 2147483647
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.location = /app/.truststore.jks
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: send.buffer.bytes = 131072
Sep 26 20:17:32 twitter-ingest app/web.1: compression.type = none
Sep 26 20:17:32 twitter-ingest app/web.1: metadata.fetch.timeout.ms = 60000
Sep 26 20:17:32 twitter-ingest app/web.1: retry.backoff.ms = 100
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.kinit.cmd = /usr/bin/kinit
Sep 26 20:17:32 twitter-ingest app/web.1: buffer.memory = 33554432
Sep 26 20:17:32 twitter-ingest app/web.1: timeout.ms = 30000
Sep 26 20:17:32 twitter-ingest app/web.1: key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.service.name = null
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.ticket.renew.jitter = 0.05
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.trustmanager.algorithm = PKIX
Sep 26 20:17:32 twitter-ingest app/web.1: block.on.buffer.full = false
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.key.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.min.time.before.relogin = 60000
Sep 26 20:17:32 twitter-ingest app/web.1: connections.max.idle.ms = 540000
Sep 26 20:17:32 twitter-ingest app/web.1: max.in.flight.requests.per.connection = 1
Sep 26 20:17:32 twitter-ingest app/web.1: metrics.num.samples = 2
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.protocol = TLS
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.provider = null
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
Sep 26 20:17:32 twitter-ingest app/web.1: batch.size = 16384
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.location = /app/.keystore.jks
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.cipher.suites = null
Sep 26 20:17:32 twitter-ingest app/web.1: security.protocol = SSL
Sep 26 20:17:32 twitter-ingest app/web.1: max.request.size = 1048576
Sep 26 20:17:32 twitter-ingest app/web.1: value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keymanager.algorithm = SunX509
Sep 26 20:17:32 twitter-ingest app/web.1: metrics.sample.window.ms = 30000
Sep 26 20:17:32 twitter-ingest app/web.1: partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
Sep 26 20:17:32 twitter-ingest app/web.1: linger.ms = 0
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
Sep 26 20:17:32 twitter-ingest app/web.1: metric.reporters = []
Sep 26 20:17:32 twitter-ingest app/web.1: metadata.max.age.ms = 300000
Sep 26 20:17:32 twitter-ingest app/web.1: reconnect.backoff.ms = 50
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.ticket.renew.window.factor = 0.8
Sep 26 20:17:32 twitter-ingest app/web.1: bootstrap.servers = [ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096, ec2-xx-xx-xx-xx.compute-1.amazonaws.com:9096]
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.type = JKS
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.mechanism = GSSAPI
Sep 26 20:17:32 twitter-ingest app/web.1: max.block.ms = 9223372036854775807
Sep 26 20:17:32 twitter-ingest app/web.1: interceptor.classes = null
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: client.id = producer-1
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.endpoint.identification.algorithm = null
Sep 26 20:17:32 twitter-ingest app/web.1: request.timeout.ms = 2147483647
Sep 26 20:17:32 twitter-ingest app/web.1: acks = all
Sep 26 20:17:32 twitter-ingest app/web.1: receive.buffer.bytes = 32768
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.type = JKS
Sep 26 20:17:32 twitter-ingest app/web.1: retries = 2147483647
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.truststore.location = /app/.truststore.jks
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: send.buffer.bytes = 131072
Sep 26 20:17:32 twitter-ingest app/web.1: compression.type = none
Sep 26 20:17:32 twitter-ingest app/web.1: metadata.fetch.timeout.ms = 60000
Sep 26 20:17:32 twitter-ingest app/web.1: retry.backoff.ms = 100
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.kinit.cmd = /usr/bin/kinit
Sep 26 20:17:32 twitter-ingest app/web.1: buffer.memory = 33554432
Sep 26 20:17:32 twitter-ingest app/web.1: timeout.ms = 30000
Sep 26 20:17:32 twitter-ingest app/web.1: key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.service.name = null
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.ticket.renew.jitter = 0.05
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.trustmanager.algorithm = PKIX
Sep 26 20:17:32 twitter-ingest app/web.1: block.on.buffer.full = false
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.key.password = [hidden]
Sep 26 20:17:32 twitter-ingest app/web.1: sasl.kerberos.min.time.before.relogin = 60000
Sep 26 20:17:32 twitter-ingest app/web.1: connections.max.idle.ms = 540000
Sep 26 20:17:32 twitter-ingest app/web.1: max.in.flight.requests.per.connection = 1
Sep 26 20:17:32 twitter-ingest app/web.1: metrics.num.samples = 2
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.protocol = TLS
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.provider = null
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
Sep 26 20:17:32 twitter-ingest app/web.1: batch.size = 16384
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keystore.location = /app/.keystore.jks
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.cipher.suites = null
Sep 26 20:17:32 twitter-ingest app/web.1: security.protocol = SSL
Sep 26 20:17:32 twitter-ingest app/web.1: max.request.size = 1048576
Sep 26 20:17:32 twitter-ingest app/web.1: value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
Sep 26 20:17:32 twitter-ingest app/web.1: ssl.keymanager.algorithm = SunX509
Sep 26 20:17:32 twitter-ingest app/web.1: metrics.sample.window.ms = 30000
Sep 26 20:17:32 twitter-ingest app/web.1: partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
Sep 26 20:17:32 twitter-ingest app/web.1: linger.ms = 0
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.0.0
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : b8642491e78c5a13
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.storage.FileOffsetBackingStore - Starting FileOffsetBackingStore with file /tmp/connect.offsets
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Worker started
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.standalone.StandaloneHerder - Herder started
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.rest.RestServer - Starting REST server
Sep 26 20:17:32 twitter-ingest app/web.1: [main] INFO org.eclipse.jetty.util.log - Logging initialized @523ms
Sep 26 20:17:33 twitter-ingest app/web.1: [main] INFO org.eclipse.jetty.server.Server - jetty-9.2.15.v20160210
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector - Starting Twitter source task with {connector.class=com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector, twitter.token=3259381-PfOw6L14UPLjQ0IkLemgQH555GNRASa91l3fmNNyQ4, tasks.max=1, twitter.secret=RAT4vJ1am2SbxN7U3denHPcgxeEmbiVNdKNb1v6Pm8KF7, track.terms=news,music,dog,cat,fish, stream.type=filter, name=twitter-source, topic=ingest, twitter.consumersecret=M2tp2bkoqYhtE18ZBA9muQ77EPMCxf7DjG9PXvXqc8PAX1xcnf, language=en, twitter.consumerkey=c5kafi61aLUjdTszD3rYDv5op}.
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO com.eneco.trading.kafka.connect.twitter.TwitterSourceConfig - TwitterSourceConfig values:
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.token = 3259381-PfOw6L14UPLjQ0IkLemgQH555GNRASa91l3fmNNyQ4
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.secret = [hidden]
Sep 26 20:17:34 twitter-ingest app/web.1: stream.type = filter
Sep 26 20:17:34 twitter-ingest app/web.1: track.terms = [news, music, dog, cat, fish]
Sep 26 20:17:34 twitter-ingest app/web.1: batch.size = 100
Sep 26 20:17:34 twitter-ingest app/web.1: language = [en]
Sep 26 20:17:34 twitter-ingest app/web.1: track.follow = []
Sep 26 20:17:34 twitter-ingest app/web.1: track.locations = []
Sep 26 20:17:34 twitter-ingest app/web.1: output.format = structured
Sep 26 20:17:34 twitter-ingest app/web.1: topic = ingest
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.consumersecret = [hidden]
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.consumerkey = c5kafi61aLUjdTszD3rYDv5op
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.app.name = KafkaConnectTwitterSource
Sep 26 20:17:34 twitter-ingest app/web.1: batch.timeout = 0.1
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Finished creating connector twitter-source
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.SourceConnectorConfig - SourceConnectorConfig values:
Sep 26 20:17:34 twitter-ingest app/web.1: connector.class = com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector
Sep 26 20:17:34 twitter-ingest app/web.1: tasks.max = 1
Sep 26 20:17:34 twitter-ingest app/web.1: name = twitter-source
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector - Setting task configurations for 1 workers.
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.TaskConfig - TaskConfig values:
Sep 26 20:17:34 twitter-ingest app/web.1: task.class = class com.eneco.trading.kafka.connect.twitter.TwitterSourceTask
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Creating task twitter-source-0
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Instantiated task twitter-source-0 with version of type com.eneco.trading.kafka.connect.twitter.TwitterSourceTask
Sep 26 20:17:34 twitter-ingest app/web.1: [pool-2-thread-1] INFO com.eneco.trading.kafka.connect.twitter.TwitterSourceConfig - TwitterSourceConfig values:
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.token = 3259381-PfOw6L14UPLjQ0IkLemgQH555GNRASa91l3fmNNyQ4
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.secret = [hidden]
Sep 26 20:17:34 twitter-ingest app/web.1: Sep 27, 2016 3:17:33 AM org.glassfish.jersey.internal.Errors logErrors
Sep 26 20:17:34 twitter-ingest app/web.1: stream.type = filter
Sep 26 20:17:34 twitter-ingest app/web.1: track.terms = [news, music, dog, cat, fish]
Sep 26 20:17:34 twitter-ingest app/web.1: batch.size = 100
Sep 26 20:17:34 twitter-ingest app/web.1: language = [en]
Sep 26 20:17:34 twitter-ingest app/web.1: track.follow = []
Sep 26 20:17:34 twitter-ingest app/web.1: track.locations = []
Sep 26 20:17:34 twitter-ingest app/web.1: output.format = structured
Sep 26 20:17:34 twitter-ingest app/web.1: topic = ingest
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.consumersecret = [hidden]
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.consumerkey = c5kafi61aLUjdTszD3rYDv5op
Sep 26 20:17:34 twitter-ingest app/web.1: twitter.app.name = KafkaConnectTwitterSource
Sep 26 20:17:34 twitter-ingest app/web.1: batch.timeout = 0.1
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.cli.ConnectStandalone - Created connector twitter-source
Sep 26 20:17:34 twitter-ingest app/web.1: WARNING: The following warnings have been detected: WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
Sep 26 20:17:34 twitter-ingest app/web.1: WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
Sep 26 20:17:34 twitter-ingest app/web.1: WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
Sep 26 20:17:34 twitter-ingest app/web.1: WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@56c698e3{/,null,AVAILABLE}
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.eclipse.jetty.server.ServerConnector - Started ServerConnector@4740f95d{HTTP/1.1}{0.0.0.0:13266}
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.eclipse.jetty.server.Server - Started @2661ms
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.rest.RestServer - REST server listening at http://172.17.36.238:13266/, advertising URL http://172.17.36.238:13266/
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Connect - Kafka Connect started
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.ConnectorConfig - ConnectorConfig values:
Sep 26 20:17:34 twitter-ingest app/web.1: connector.class = com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector
Sep 26 20:17:34 twitter-ingest app/web.1: tasks.max = 1
Sep 26 20:17:34 twitter-ingest app/web.1: name = twitter-source
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Creating connector twitter-source of type com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector
Sep 26 20:17:34 twitter-ingest app/web.1: [main] INFO org.apache.kafka.connect.runtime.Worker - Instantiated connector twitter-source with version of type com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector
Sep 26 20:17:35 twitter-ingest app/web.1: [pool-2-thread-1] INFO com.eneco.trading.kafka.connect.twitter.TwitterStatusReader - Initialising Twitter Stream Reader
Sep 26 20:17:35 twitter-ingest app/web.1: [pool-2-thread-1] INFO com.twitter.hbc.httpclient.BasicClient - New connection executed: KafkaConnectTwitterSource, endpoint: /1.1/statuses/filter.json?delimited=length&language=en
Sep 26 20:17:35 twitter-ingest app/web.1: [pool-2-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Source task WorkerSourceTask{id=twitter-source-0} finished initialization and start
Sep 26 20:17:35 twitter-ingest app/web.1: [hosebird-client-io-thread-0] INFO com.twitter.hbc.httpclient.ClientBase - KafkaConnectTwitterSource Establishing a connection
Sep 26 20:17:36 twitter-ingest app/web.1: [hosebird-client-io-thread-0] INFO com.twitter.hbc.httpclient.ClientBase - KafkaConnectTwitterSource Processing connection data
Sep 26 20:17:37 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 13
Sep 26 20:17:37 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 7
Sep 26 20:17:37 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 3
Sep 26 20:17:38 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 6
Sep 26 20:17:39 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 19
Sep 26 20:17:39 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 28
Sep 26 20:17:39 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 22
Sep 26 20:17:39 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 13
Sep 26 20:17:39 twitter-ingest app/web.1: [CLASSPATH traversal thread.] INFO org.reflections.Reflections - Reflections took 6875 ms to scan 122 urls, producing 4852 keys and 36110 values
Sep 26 20:17:40 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 23
Sep 26 20:17:43 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 14
Sep 26 20:17:43 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 27
Sep 26 20:17:44 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 29
Sep 26 20:17:44 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 48 ms
Sep 26 20:17:45 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 15
Sep 26 20:17:47 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 18
Sep 26 20:17:47 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 31
Sep 26 20:17:48 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 27
Sep 26 20:17:48 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 21
Sep 26 20:17:50 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 28
Sep 26 20:17:51 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 39
Sep 26 20:17:51 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 32
Sep 26 20:17:53 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 23
Sep 26 20:17:53 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 34
Sep 26 20:17:55 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 4 ms
Sep 26 20:17:56 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 24
Sep 26 20:17:57 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 25
Sep 26 20:17:58 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 36
Sep 26 20:18:02 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 40
Sep 26 20:18:03 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 37
Sep 26 20:18:03 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 27
Sep 26 20:18:04 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 4 ms
Sep 26 20:18:07 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 40
Sep 26 20:18:07 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 43
Sep 26 20:18:07 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 34
Sep 26 20:18:09 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 43
Sep 26 20:18:12 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 28
Sep 26 20:18:13 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 47
Sep 26 20:18:14 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 4 ms
Sep 26 20:18:16 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 46
Sep 26 20:18:20 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 48
Sep 26 20:18:21 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 49
Sep 26 20:18:22 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 35
Sep 26 20:18:23 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 35
Sep 26 20:18:24 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 51
Sep 26 20:18:24 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 39
Sep 26 20:18:25 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 3 ms
Sep 26 20:18:25 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 49
Sep 26 20:18:27 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 43
Sep 26 20:18:27 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 37
Sep 26 20:18:27 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 54
Sep 26 20:18:30 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 50
Sep 26 20:18:33 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 52
Sep 26 20:18:34 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 2 ms
Sep 26 20:18:35 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 45
Sep 26 20:18:36 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 46
Sep 26 20:18:39 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 57
Sep 26 20:18:40 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 60
Sep 26 20:18:41 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 50
Sep 26 20:18:41 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 62
Sep 26 20:18:41 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 39
Sep 26 20:18:42 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 67
Sep 26 20:18:44 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 54
Sep 26 20:18:44 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 2 ms
Sep 26 20:18:45 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 40
Sep 26 20:18:48 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 68
Sep 26 20:18:48 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 41
Sep 26 20:18:51 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 57
Sep 26 20:18:51 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 53
Sep 26 20:18:53 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 56
Sep 26 20:18:54 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 60
Sep 26 20:18:54 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 2 ms
Sep 26 20:18:55 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 44
Sep 26 20:18:55 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 61
Sep 26 20:18:57 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 47
Sep 26 20:18:58 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 48
Sep 26 20:18:58 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 63
Sep 26 20:19:00 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 67
Sep 26 20:19:01 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 57
Sep 26 20:19:03 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 68
Sep 26 20:19:04 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 49
Sep 26 20:19:04 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 70
Sep 26 20:19:04 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 3 ms
Sep 26 20:19:05 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 71
Sep 26 20:19:06 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 55
Sep 26 20:19:07 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 72
Sep 26 20:19:07 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 57
Sep 26 20:19:09 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 58
Sep 26 20:19:09 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 74
Sep 26 20:19:10 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 61
Sep 26 20:19:11 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 62
Sep 26 20:19:11 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 76
Sep 26 20:19:12 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 76
Sep 26 20:19:15 twitter-ingest app/web.1: [pool-3-thread-1] INFO org.apache.kafka.connect.runtime.WorkerSourceTask - Finished WorkerSourceTask{id=twitter-source-0} commitOffsets successfully in 3 ms
Sep 26 20:19:17 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 78
Sep 26 20:19:18 twitter-ingest app/web.1: [pool-7-thread-1] INFO com.eneco.trading.kafka.connect.twitter.StatusEnqueuer - onTrackLimitationNotice 82
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment