fetch.min.bytes = 1
send.buffer.bytes = 131072
auto.offset.reset = earliest
(org.apache.kafka.clients.consumer.ConsumerConfig:165)
[2016-04-12 23:22:14,940] DEBUG Starting the Kafka consumer (org.apache.kafka.clients.consumer.KafkaConsumer:552)
[2016-04-12 23:22:14,940] DEBUG Updated cluster metadata version 1 to Cluster(nodes = [Node(-1, localhost, 9092)], partitions = []) (org.apache.kafka.clients.Metadata:172)
[2016-04-12 23:22:14,940] DEBUG Added sensor with name connections-closed:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,940] DEBUG Added sensor with name connections-created:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,940] DEBUG Added sensor with name bytes-sent-received:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,941] DEBUG Added sensor with name bytes-sent:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,941] DEBUG Added sensor with name bytes-received:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,941] DEBUG Added sensor with name select-time:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,941] DEBUG Added sensor with name io-time:client-id-consumer-2 (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,942] DEBUG Added sensor with name heartbeat-latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,942] DEBUG Added sensor with name join-latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,942] DEBUG Added sensor with name sync-latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,942] DEBUG Added sensor with name commit-latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] DEBUG Added sensor with name bytes-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] DEBUG Added sensor with name records-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] DEBUG Added sensor with name fetch-latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] DEBUG Added sensor with name records-lag (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] DEBUG Added sensor with name fetch-throttle-time (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,943] WARN The configuration config.storage.topic = connect-configs was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration internal.key.converter.schemas.enable = false was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration value.converter.schema.registry.url =
http://localhost:8081 was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration internal.key.converter = org.apache.kafka.connect.json.JsonConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration internal.value.converter.schemas.enable = false was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration internal.value.converter = org.apache.kafka.connect.json.JsonConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration offset.storage.topic = connect-offsets was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration value.converter = io.confluent.connect.avro.AvroConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration key.converter = io.confluent.connect.avro.AvroConverter was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] WARN The configuration key.converter.schema.registry.url =
http://localhost:8081 was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:173)
[2016-04-12 23:22:14,944] INFO Kafka version : 0.9.0.1-cp1 (org.apache.kafka.common.utils.AppInfoParser:82)
[2016-04-12 23:22:14,944] INFO Kafka commitId : 7113452b3e7d5638 (org.apache.kafka.common.utils.AppInfoParser:83)
[2016-04-12 23:22:14,944] DEBUG Kafka consumer created (org.apache.kafka.clients.consumer.KafkaConsumer:642)
[2016-04-12 23:22:14,944] DEBUG Initiating connection to node -1 at localhost:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:14,945] DEBUG Added sensor with name node--1.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,945] DEBUG Added sensor with name node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,945] DEBUG Added sensor with name node--1.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:14,946] DEBUG Completed connection to node -1 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,024] DEBUG org.eclipse.jetty.server.session.SessionHandler@dbd8e44 added {org.eclipse.jetty.server.session.HashSessionManager@51acdf2e,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,024] DEBUG o.e.j.s.ServletContextHandler@6a55299e{/,null,null} added {org.eclipse.jetty.server.session.SessionHandler@dbd8e44,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,028] DEBUG org.eclipse.jetty.server.session.SessionHandler@dbd8e44 added {org.eclipse.jetty.servlet.ServletHandler@4c51cf28,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,029] DEBUG org.eclipse.jetty.servlet.ServletHandler@4c51cf28 added {org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,029] DEBUG org.eclipse.jetty.servlet.ServletHandler@4c51cf28 added {[/*]=>org.glassfish.jersey.servlet.ServletContainer-29a0cdb,POJO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,032] DEBUG org.eclipse.jetty.server.handler.RequestLogHandler@525575 added {org.eclipse.jetty.server.Slf4jRequestLog@46dffdc3,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,042] DEBUG org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] added {o.e.j.s.ServletContextHandler@6a55299e{/,null,null},AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,042] DEBUG org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] added {org.eclipse.jetty.server.handler.DefaultHandler@512535ff,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,042] DEBUG org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] added {org.eclipse.jetty.server.handler.RequestLogHandler@525575,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,044] DEBUG org.eclipse.jetty.server.handler.StatisticsHandler@3f270e0a added {org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575],AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,044] DEBUG org.eclipse.jetty.server.Server@561b6512 added {org.eclipse.jetty.server.handler.StatisticsHandler@3f270e0a,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,044] DEBUG starting org.eclipse.jetty.server.Server@561b6512 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,046] DEBUG Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=2,client_id=consumer-2}, body={topics=[]}), isInitiatedByNetworkClient, createdTimeMs=1460517735046, sendTimeMs=0) to node -1 (org.apache.kafka.clients.NetworkClient:619)
[2016-04-12 23:22:15,048] INFO jetty-9.2.12.v20150709 (org.eclipse.jetty.server.Server:327)
[2016-04-12 23:22:15,051] DEBUG Updated cluster metadata version 2 to Cluster(nodes = [Node(0, sd-4261-f1e1, 9092), Node(2, sd-023d-317b, 9092), Node(1, sd-6286-1278, 9092)], partitions = [Partition(topic = __consumer_offsets, partition = 13, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 46, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 9, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 42, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = connect-offsets, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 21, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 17, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 30, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 26, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 5, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 38, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 1, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 34, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = _schemas, partition = 0, leader = 0, replicas = [0,1,2,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 16, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 45, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 12, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 41, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 24, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 20, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 49, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 0, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 29, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 25, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 8, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 37, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 4, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = test_oracle_jdbc_USERYM, partition = 0, leader = 0, replicas = [0,], isr = [0,], Partition(topic = __consumer_offsets, partition = 33, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = connect-configs, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 15, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 48, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 11, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 44, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 23, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 19, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 32, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 28, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 7, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = message-topic-test1, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 40, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 3, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 36, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 47, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 14, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 43, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = test, partition = 0, leader = 0, replicas = [0,], isr = [0,], Partition(topic = __consumer_offsets, partition = 10, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 22, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 18, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 31, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 27, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 39, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 6, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 35, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 2, leader = 0, replicas = [0,2,1,], isr = [0,2,1,]]) (org.apache.kafka.clients.Metadata:172)
[2016-04-12 23:22:15,060] DEBUG starting org.eclipse.jetty.server.Server@561b6512 (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,060] DEBUG starting qtp1886491834{STOPPED,8<=0<=200,i=0,q=0} (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,062] DEBUG STARTED @1694ms qtp1886491834{STARTED,8<=8<=200,i=7,q=0} (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,062] DEBUG starting org.eclipse.jetty.server.handler.StatisticsHandler@3f270e0a (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,062] DEBUG starting org.eclipse.jetty.server.handler.StatisticsHandler@3f270e0a (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,062] DEBUG starting org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,062] DEBUG starting org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,null}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,062] DEBUG starting o.e.j.s.ServletContextHandler@6a55299e{/,null,null} (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,070] DEBUG starting o.e.j.s.ServletContextHandler@6a55299e{/,null,STARTING} (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,070] DEBUG starting org.eclipse.jetty.server.session.SessionHandler@dbd8e44 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,070] DEBUG starting org.eclipse.jetty.server.session.SessionHandler@dbd8e44 (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,070] DEBUG starting org.eclipse.jetty.server.session.HashSessionManager@51acdf2e (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,070] DEBUG org.eclipse.jetty.server.session.HashSessionManager@51acdf2e added {org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@146587a2,MANAGED} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,072] DEBUG starting org.eclipse.jetty.server.session.HashSessionIdManager@16c63f5 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,072] DEBUG STARTED @1705ms org.eclipse.jetty.server.session.HashSessionIdManager@16c63f5 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,072] DEBUG org.eclipse.jetty.server.Server@561b6512 added {org.eclipse.jetty.server.session.HashSessionIdManager@16c63f5,MANAGED} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,072] DEBUG org.eclipse.jetty.server.session.HashSessionManager@51acdf2e added {org.eclipse.jetty.server.session.HashSessionIdManager@16c63f5,UNMANAGED} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,073] DEBUG starting org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@146587a2 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,073] DEBUG STARTED @1706ms org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@146587a2 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,075] DEBUG STARTED @1707ms org.eclipse.jetty.server.session.HashSessionManager@51acdf2e (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,075] DEBUG starting org.eclipse.jetty.servlet.ServletHandler@4c51cf28 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,076] DEBUG Chose path=/* mapped to servlet=org.glassfish.jersey.servlet.ServletContainer-29a0cdb from default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2016-04-12 23:22:15,077] DEBUG filterNameMap={} (org.eclipse.jetty.servlet.ServletHandler:1516)
[2016-04-12 23:22:15,077] DEBUG pathFilters=null (org.eclipse.jetty.servlet.ServletHandler:1517)
[2016-04-12 23:22:15,077] DEBUG servletFilterMap=null (org.eclipse.jetty.servlet.ServletHandler:1518)
[2016-04-12 23:22:15,077] DEBUG servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true} (org.eclipse.jetty.servlet.ServletHandler:1519)
[2016-04-12 23:22:15,077] DEBUG servletNameMap={org.glassfish.jersey.servlet.ServletContainer-29a0cdb=org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true} (org.eclipse.jetty.servlet.ServletHandler:1520)
[2016-04-12 23:22:15,077] DEBUG Adding Default404Servlet to org.eclipse.jetty.servlet.ServletHandler@4c51cf28 (org.eclipse.jetty.servlet.ServletHandler:165)
[2016-04-12 23:22:15,078] DEBUG org.eclipse.jetty.servlet.ServletHandler@4c51cf28 added {org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61@ebef5243==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false,AUTO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,078] DEBUG org.eclipse.jetty.servlet.ServletHandler@4c51cf28 added {[/]=>org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61,POJO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,078] DEBUG Chose path=/* mapped to servlet=org.glassfish.jersey.servlet.ServletContainer-29a0cdb from default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2016-04-12 23:22:15,078] DEBUG Chose path=/ mapped to servlet=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61 from default=false (org.eclipse.jetty.servlet.ServletHandler:1495)
[2016-04-12 23:22:15,078] DEBUG filterNameMap={} (org.eclipse.jetty.servlet.ServletHandler:1516)
[2016-04-12 23:22:15,079] DEBUG pathFilters=null (org.eclipse.jetty.servlet.ServletHandler:1517)
[2016-04-12 23:22:15,079] DEBUG servletFilterMap=null (org.eclipse.jetty.servlet.ServletHandler:1518)
[2016-04-12 23:22:15,079] DEBUG servletPathMap={/*=org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true, /=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61@ebef5243==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false} (org.eclipse.jetty.servlet.ServletHandler:1519)
[2016-04-12 23:22:15,079] DEBUG servletNameMap={org.glassfish.jersey.servlet.ServletContainer-29a0cdb=org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true, org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61@ebef5243==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false} (org.eclipse.jetty.servlet.ServletHandler:1520)
[2016-04-12 23:22:15,079] DEBUG starting org.eclipse.jetty.servlet.ServletHandler@4c51cf28 (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,079] DEBUG STARTED @1712ms org.eclipse.jetty.servlet.ServletHandler@4c51cf28 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,080] DEBUG STARTED @1712ms org.eclipse.jetty.server.session.SessionHandler@dbd8e44 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,080] DEBUG starting org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61@ebef5243==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,081] DEBUG STARTED @1714ms org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2826f61@ebef5243==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,-1,false (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,081] DEBUG starting org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,082] DEBUG STARTED @1714ms org.glassfish.jersey.servlet.ServletContainer-29a0cdb@2e04b19d==org.glassfish.jersey.servlet.ServletContainer,-1,true (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,083] DEBUG Servlet.init org.glassfish.jersey.servlet.ServletContainer@4ce7fffa for org.glassfish.jersey.servlet.ServletContainer-29a0cdb (org.eclipse.jetty.servlet.ServletHolder:611)
[2016-04-12 23:22:15,158] DEBUG Subscribed to partition(s): connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:809)
[2016-04-12 23:22:15,158] TRACE Reading to end of offset log (org.apache.kafka.connect.util.KafkaBasedLog:244)
[2016-04-12 23:22:15,159] DEBUG Issuing group metadata request to broker 0 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:465)
[2016-04-12 23:22:15,159] DEBUG Initiating connection to node 0 at sd-4261-f1e1:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,159] DEBUG Initialize connection to node 2 for sending metadata request (org.apache.kafka.clients.NetworkClient:623)
[2016-04-12 23:22:15,159] DEBUG Initiating connection to node 2 at sd-023d-317b:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,159] DEBUG Added sensor with name node-0.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,160] DEBUG Added sensor with name node-0.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,160] DEBUG Added sensor with name node-0.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,160] DEBUG Completed connection to node 0 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,160] DEBUG Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=4,client_id=consumer-2}, body={topics=[connect-configs]}), isInitiatedByNetworkClient, createdTimeMs=1460517735160, sendTimeMs=0) to node 0 (org.apache.kafka.clients.NetworkClient:619)
[2016-04-12 23:22:15,161] DEBUG Added sensor with name node-2.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,161] DEBUG Added sensor with name node-2.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,161] DEBUG Added sensor with name node-2.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,161] DEBUG Completed connection to node 2 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,162] DEBUG Updated cluster metadata version 3 to Cluster(nodes = [Node(0, sd-4261-f1e1, 9092), Node(1, sd-6286-1278, 9092), Node(2, sd-023d-317b, 9092)], partitions = [Partition(topic = connect-configs, partition = 0, leader = 1, replicas = [1,], isr = [1,]]) (org.apache.kafka.clients.Metadata:172)
[2016-04-12 23:22:15,162] DEBUG Issuing group metadata request to broker 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:465)
[2016-04-12 23:22:15,164] DEBUG Group metadata response ClientResponse(receivedTimeMs=1460517735164, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@27b6526e, request=RequestSend(header={api_key=10,api_version=0,correlation_id=5,client_id=consumer-2}, body={group_id=connect-cluster}), createdTimeMs=1460517735162, sendTimeMs=1460517735162), responseBody={error_code=0,coordinator={node_id=2,host=sd-023d-317b,port=9092}}) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:478)
[2016-04-12 23:22:15,164] DEBUG Initiating connection to node
2147483645 at sd-023d-317b:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,165] DEBUG Fetching committed offsets for partitions: [connect-configs-0] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:581)
[2016-04-12 23:22:15,165] DEBUG Added sensor with name node-
2147483645.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,165] DEBUG Added sensor with name node-
2147483645.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,165] DEBUG Added sensor with name node-
2147483645.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,166] DEBUG Completed connection to node
2147483645 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,166] DEBUG No committed offset for partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:628)
[2016-04-12 23:22:15,167] DEBUG Resetting offset for partition connect-configs-0 to earliest offset. (org.apache.kafka.clients.consumer.internals.Fetcher:290)
[2016-04-12 23:22:15,167] DEBUG Initiating connection to node 1 at sd-6286-1278:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,167] DEBUG Added sensor with name node-1.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,168] DEBUG Added sensor with name node-1.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,168] DEBUG Added sensor with name node-1.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,168] DEBUG Completed connection to node 1 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,169] DEBUG Fetched offset 0 for partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.Fetcher:483)
[2016-04-12 23:22:15,169] DEBUG Seeking to end of partition connect-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1078)
[2016-04-12 23:22:15,169] DEBUG Resetting offset for partition connect-configs-0 to latest offset. (org.apache.kafka.clients.consumer.internals.Fetcher:290)
[2016-04-12 23:22:15,170] DEBUG Fetched offset 0 for partition connect-configs-0 (org.apache.kafka.clients.consumer.internals.Fetcher:483)
[2016-04-12 23:22:15,170] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:15,170] TRACE Reading to end of log for connect-configs-0: starting offset 0 to ending offset 0 (org.apache.kafka.connect.util.KafkaBasedLog:269)
[2016-04-12 23:22:15,171] INFO Finished reading KafakBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:143)
[2016-04-12 23:22:15,171] INFO Started KafakBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:145)
[2016-04-12 23:22:15,171] INFO Started KafkaConfigStorage (org.apache.kafka.connect.storage.KafkaConfigStorage:242)
[2016-04-12 23:22:15,171] INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder:156)
[2016-04-12 23:22:15,171] DEBUG Issuing group metadata request to broker -1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:465)
[2016-04-12 23:22:15,171] DEBUG Initiating connection to node -1 at localhost:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,171] DEBUG Added sensor with name node--1.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,172] DEBUG Added sensor with name node--1.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,172] DEBUG Added sensor with name node--1.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,172] DEBUG Completed connection to node -1 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,272] DEBUG Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=1,client_id=connect-1}, body={topics=[]}), isInitiatedByNetworkClient, createdTimeMs=1460517735272, sendTimeMs=0) to node -1 (org.apache.kafka.clients.NetworkClient:619)
[2016-04-12 23:22:15,275] DEBUG Updated cluster metadata version 2 to Cluster(nodes = [Node(1, sd-6286-1278, 9092), Node(0, sd-4261-f1e1, 9092), Node(2, sd-023d-317b, 9092)], partitions = [Partition(topic = __consumer_offsets, partition = 13, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 46, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 9, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 42, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = connect-offsets, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 21, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 17, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 30, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 26, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 5, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 38, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 1, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 34, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = _schemas, partition = 0, leader = 0, replicas = [0,1,2,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 16, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 45, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 12, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 41, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 24, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 20, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 49, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 0, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 29, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 25, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 8, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 37, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 4, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = test_oracle_jdbc_USERYM, partition = 0, leader = 0, replicas = [0,], isr = [0,], Partition(topic = __consumer_offsets, partition = 33, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = connect-configs, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 15, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 48, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 11, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 44, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 23, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 19, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 32, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 28, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 7, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = message-topic-test1, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = __consumer_offsets, partition = 40, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 3, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 36, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 47, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 14, leader = 0, replicas = [0,2,1,], isr = [0,2,1,], Partition(topic = __consumer_offsets, partition = 43, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = test, partition = 0, leader = 0, replicas = [0,], isr = [0,], Partition(topic = __consumer_offsets, partition = 10, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 22, leader = 2, replicas = [2,0,1,], isr = [2,0,1,], Partition(topic = __consumer_offsets, partition = 18, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 31, leader = 2, replicas = [2,1,0,], isr = [2,1,0,], Partition(topic = __consumer_offsets, partition = 27, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 39, leader = 1, replicas = [1,2,0,], isr = [1,2,0,], Partition(topic = __consumer_offsets, partition = 6, leader = 1, replicas = [1,0,2,], isr = [1,0,2,], Partition(topic = __consumer_offsets, partition = 35, leader = 0, replicas = [0,1,2,], isr = [0,1,2,], Partition(topic = __consumer_offsets, partition = 2, leader = 0, replicas = [0,2,1,], isr = [0,2,1,]]) (org.apache.kafka.clients.Metadata:172)
[2016-04-12 23:22:15,275] DEBUG Issuing group metadata request to broker 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:465)
[2016-04-12 23:22:15,275] DEBUG Initiating connection to node 2 at sd-023d-317b:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,276] DEBUG Added sensor with name node-2.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,276] DEBUG Added sensor with name node-2.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,277] DEBUG Added sensor with name node-2.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,277] DEBUG Completed connection to node 2 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,279] DEBUG Group metadata response ClientResponse(receivedTimeMs=1460517735279, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7ca97b34, request=RequestSend(header={api_key=10,api_version=0,correlation_id=2,client_id=connect-1}, body={group_id=connect-cluster}), createdTimeMs=1460517735275, sendTimeMs=1460517735277), responseBody={error_code=0,coordinator={node_id=2,host=sd-023d-317b,port=9092}}) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:478)
[2016-04-12 23:22:15,279] DEBUG Initiating connection to node
2147483645 at sd-023d-317b:9092. (org.apache.kafka.clients.NetworkClient:487)
[2016-04-12 23:22:15,280] DEBUG Revoking previous assignment null (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:234)
[2016-04-12 23:22:15,280] DEBUG (Re-)joining group connect-cluster (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:309)
[2016-04-12 23:22:15,282] DEBUG Issuing request (JOIN_GROUP: {group_id=connect-cluster,session_timeout=30000,member_id=,protocol_type=connect,group_protocols=[{protocol_name=default,protocol_metadata=java.nio.HeapByteBuffer[pos=0 lim=40 cap=40]}]}) to coordinator
2147483645 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:318)
[2016-04-12 23:22:15,283] DEBUG Added sensor with name node-
2147483645.bytes-sent (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,284] DEBUG Added sensor with name node-
2147483645.bytes-received (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,284] DEBUG Added sensor with name node-
2147483645.latency (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,284] DEBUG Completed connection to node
2147483645 (org.apache.kafka.clients.NetworkClient:467)
[2016-04-12 23:22:15,286] DEBUG Joined group: {error_code=0,generation_id=1,group_protocol=default,leader_id=connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e,member_id=connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e,members=[{member_id=connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=40 cap=40]}]} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:336)
[2016-04-12 23:22:15,286] DEBUG Performing task assignment (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:123)
[2016-04-12 23:22:15,286] DEBUG Max config offset root: -1, local snapshot config offsets root: -1 (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:151)
[2016-04-12 23:22:15,287] DEBUG Assignment: connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e -> Assignment{error=0, leader='connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e', leaderUrl='
http://169.172.134.169:8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:225)
[2016-04-12 23:22:15,287] DEBUG Finished assignment (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator:228)
[2016-04-12 23:22:15,288] DEBUG Issuing leader SyncGroup (SYNC_GROUP: {group_id=connect-cluster,generation_id=1,member_id=connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e,group_assignment=[{member_id=connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=94 cap=94]}]}) to coordinator 2147483645 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:397)
[2016-04-12 23:22:15,293] DEBUG Received successful sync group response for group connect-cluster: {error_code=0,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=94 cap=94]} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:423)
[2016-04-12 23:22:15,294] INFO Joined group and got assignment: Assignment{error=0, leader='connect-1-1b945979-ff36-4b4e-85ff-bbc00a9f462e', leaderUrl='
http://169.172.134.169:8083/', offset=-1, connectorIds=[], taskIds=[]} (org.apache.kafka.connect.runtime.distributed.DistributedHerder:868)
[2016-04-12 23:22:15,294] INFO Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder:639)
[2016-04-12 23:22:15,295] INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder:659)
[2016-04-12 23:22:15,436] DEBUG Added sensor with name topic.connect-offsets.bytes-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,436] DEBUG Added sensor with name topic.connect-offsets.records-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,436] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:15,563] INFO Started o.e.j.s.ServletContextHandler@6a55299e{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)
[2016-04-12 23:22:15,563] DEBUG STARTED @2196ms o.e.j.s.ServletContextHandler@6a55299e{/,null,AVAILABLE} (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,563] DEBUG starting org.eclipse.jetty.server.handler.DefaultHandler@512535ff (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,564] DEBUG starting org.eclipse.jetty.server.handler.DefaultHandler@512535ff (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,564] DEBUG STARTED @2196ms org.eclipse.jetty.server.handler.DefaultHandler@512535ff (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,564] DEBUG starting org.eclipse.jetty.server.handler.RequestLogHandler@525575 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,564] DEBUG starting org.eclipse.jetty.server.handler.RequestLogHandler@525575 (org.eclipse.jetty.server.handler.AbstractHandler:58)
[2016-04-12 23:22:15,564] DEBUG starting org.eclipse.jetty.server.Slf4jRequestLog@46dffdc3 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,565] DEBUG STARTED @2198ms org.eclipse.jetty.server.Slf4jRequestLog@46dffdc3 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,565] DEBUG STARTED @2198ms org.eclipse.jetty.server.handler.RequestLogHandler@525575 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,565] DEBUG STARTED @2198ms org.eclipse.jetty.server.handler.HandlerCollection@e19bb76[o.e.j.s.ServletContextHandler@6a55299e{/,null,AVAILABLE}, org.eclipse.jetty.server.handler.DefaultHandler@512535ff, org.eclipse.jetty.server.handler.RequestLogHandler@525575] (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,565] DEBUG STARTED @2198ms org.eclipse.jetty.server.handler.StatisticsHandler@3f270e0a (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,565] DEBUG starting ServerConnector@fd07cbb{HTTP/1.1}{
0.0.0.0:8083} (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,567] DEBUG ServerConnector@fd07cbb{HTTP/1.1}{
0.0.0.0:8083} added {sun.nio.ch.ServerSocketChannelImpl[/
0.0.0.0:8083],POJO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,567] DEBUG starting org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@fa36558 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,568] DEBUG STARTED @2200ms org.eclipse.jetty.util.thread.ScheduledExecutorScheduler@fa36558 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,568] DEBUG starting HttpConnectionFactory@68567e20{HTTP/1.1} (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,568] DEBUG STARTED @2201ms HttpConnectionFactory@68567e20{HTTP/1.1} (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,568] DEBUG starting org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@7748410a (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,572] DEBUG starting org.eclipse.jetty.io.SelectorManager$ManagedSelector@42deb43a keys=-1 selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,572] DEBUG STARTED @2205ms org.eclipse.jetty.io.SelectorManager$ManagedSelector@42deb43a keys=0 selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,573] DEBUG starting org.eclipse.jetty.io.SelectorManager$ManagedSelector@1cefc4b3 keys=-1 selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,573] DEBUG STARTED @2206ms org.eclipse.jetty.io.SelectorManager$ManagedSelector@1cefc4b3 keys=0 selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,573] DEBUG starting org.eclipse.jetty.io.SelectorManager$ManagedSelector@2b27cc70 keys=-1 selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,573] DEBUG STARTED @2206ms org.eclipse.jetty.io.SelectorManager$ManagedSelector@2b27cc70 keys=0 selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,574] DEBUG Starting Thread[qtp1886491834-21-selector-ServerConnectorManager@7748410a/0,5,main] on org.eclipse.jetty.io.SelectorManager$ManagedSelector@42deb43a keys=0 selected=0 (org.eclipse.jetty.io.SelectorManager:547)
[2016-04-12 23:22:15,574] DEBUG starting org.eclipse.jetty.io.SelectorManager$ManagedSelector@6f6a7463 keys=-1 selected=-1 (org.eclipse.jetty.util.component.AbstractLifeCycle:185)
[2016-04-12 23:22:15,574] DEBUG Starting Thread[qtp1886491834-23-selector-ServerConnectorManager@7748410a/2,5,main] on org.eclipse.jetty.io.SelectorManager$ManagedSelector@2b27cc70 keys=0 selected=0 (org.eclipse.jetty.io.SelectorManager:547)
[2016-04-12 23:22:15,574] DEBUG STARTED @2206ms org.eclipse.jetty.io.SelectorManager$ManagedSelector@6f6a7463 keys=0 selected=0 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,574] DEBUG Starting Thread[qtp1886491834-22-selector-ServerConnectorManager@7748410a/1,5,main] on org.eclipse.jetty.io.SelectorManager$ManagedSelector@1cefc4b3 keys=0 selected=0 (org.eclipse.jetty.io.SelectorManager:547)
[2016-04-12 23:22:15,574] DEBUG STARTED @2207ms org.eclipse.jetty.server.ServerConnector$ServerConnectorManager@7748410a (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,574] DEBUG Selector loop waiting on select (org.eclipse.jetty.io.SelectorManager:599)
[2016-04-12 23:22:15,574] DEBUG Starting Thread[qtp1886491834-24-selector-ServerConnectorManager@7748410a/3,5,main] on org.eclipse.jetty.io.SelectorManager$ManagedSelector@6f6a7463 keys=0 selected=0 (org.eclipse.jetty.io.SelectorManager:547)
[2016-04-12 23:22:15,574] DEBUG Selector loop waiting on select (org.eclipse.jetty.io.SelectorManager:599)
[2016-04-12 23:22:15,574] DEBUG Selector loop waiting on select (org.eclipse.jetty.io.SelectorManager:599)
[2016-04-12 23:22:15,574] DEBUG Selector loop waiting on select (org.eclipse.jetty.io.SelectorManager:599)
[2016-04-12 23:22:15,575] DEBUG ServerConnector@fd07cbb{HTTP/1.1}{
0.0.0.0:8083} added {acceptor-0@6ca320ab,POJO} (org.eclipse.jetty.util.component.ContainerLifeCycle:324)
[2016-04-12 23:22:15,575] INFO Started ServerConnector@fd07cbb{HTTP/1.1}{
0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector:266)
[2016-04-12 23:22:15,575] DEBUG STARTED @2208ms ServerConnector@fd07cbb{HTTP/1.1}{
0.0.0.0:8083} (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,575] INFO Started @2208ms (org.eclipse.jetty.server.Server:379)
[2016-04-12 23:22:15,575] DEBUG STARTED @2208ms org.eclipse.jetty.server.Server@561b6512 (org.eclipse.jetty.util.component.AbstractLifeCycle:177)
[2016-04-12 23:22:15,576] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:60)
[2016-04-12 23:22:15,671] DEBUG Added sensor with name topic.connect-configs.bytes-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,671] DEBUG Added sensor with name topic.connect-configs.records-fetched (org.apache.kafka.common.metrics.Metrics:201)
[2016-04-12 23:22:15,671] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:15,937] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:16,173] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:16,439] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:16,675] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:16,939] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:17,176] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:17,441] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:17,677] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:17,943] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:18,178] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:18,300] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:18,444] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:18,680] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:18,946] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:19,182] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:19,447] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:19,683] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:19,949] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:20,185] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:20,450] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:20,687] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:20,952] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:21,188] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:21,300] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:21,454] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:21,689] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:21,955] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:22,191] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:22,457] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:22,693] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:22,957] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:23,194] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:23,458] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:23,696] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:23,960] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:24,198] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:24,303] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:24,462] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:24,699] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:24,964] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:25,200] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:25,465] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:25,702] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:25,967] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:26,203] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:26,468] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:26,705] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:26,969] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:27,206] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:27,306] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:27,471] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:27,708] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:27,972] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:28,209] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:28,473] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:28,710] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:28,973] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:29,212] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:29,475] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:29,716] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:29,976] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:30,218] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:30,309] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:30,478] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:30,719] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:30,980] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:31,221] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:31,481] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:31,722] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:31,983] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:32,225] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:32,484] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:32,726] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:32,985] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:33,228] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:33,312] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:33,487] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:33,729] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:33,988] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:34,230] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:34,490] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:34,732] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:34,991] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:35,233] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:35,493] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:35,735] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:35,995] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:36,236] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:36,315] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:36,497] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:36,738] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:36,998] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:37,239] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:37,499] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:37,740] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:38,001] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:38,242] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:38,502] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:38,743] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:39,003] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:39,244] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:39,318] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:39,505] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:39,746] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:40,006] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:40,248] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:40,508] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:40,750] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:41,010] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:41,252] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:41,511] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:41,754] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:42,016] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:42,255] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:42,321] DEBUG Received successful heartbeat response. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:615)
[2016-04-12 23:22:42,518] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:42,757] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:43,019] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:43,258] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:43,520] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:43,759] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:44,023] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:44,260] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:44,525] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:44,762] TRACE Added fetch request for partition connect-configs-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:45,026] TRACE Added fetch request for partition connect-offsets-0 at offset 0 (org.apache.kafka.clients.consumer.internals.Fetcher:519)
[2016-04-12 23:22:45,074] DEBUG Scavenging sessions at 1460517765074 (org.eclipse.jetty.server.session:347)
... repeat the following message
...