Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0} ... #3

Closed
mcandre opened this issue Jul 21, 2016 · 2 comments
Closed

ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0} ... #3

mcandre opened this issue Jul 21, 2016 · 2 comments

Comments

@mcandre
Copy link

mcandre commented Jul 21, 2016 •
edited
Loading

Summary

I'm trying to setup a hello world example with Kafka Connect and a Redis source and Redis sink. However, when I start seeding values into Redis, Kafka Connect dies with what appears to be internal commit errors. Have I configured something wrong?

Source:

https://github.com/mcandre/hello-kafka-connect

Trace:

$ gradle clean shadowJar
$ docker-compose build --no-cache
$ docker-compose rm -f && docker-compose up --force-recreate
...

$ curl -XPOST $(docker-machine ip dev):8083/connectors \
       -H "Content-Type: application/json" \
       -d "{
             \"name\": \"name-source\",
             \"config\": {
               \"connector.class\": \"us.yellosoft.hellokafkaconnect.NameSource\",
               \"tasks.max\": \"1\",
               \"topics\": \"names\",
               \"kafka_partitions\": \"1\",
               \"redis_address\": \"redis://$(docker-machine ip dev):6379\",
               \"name_list_key\": \"names\"
              }
           }" | jq .

{
  "name": "name-source",
  "config": {
    "connector.class": "us.yellosoft.hellokafkaconnect.NameSource",
    "tasks.max": "1",
    "topics": "names",
    "kafka_partitions": "1",
    "redis_address": "redis://192.168.99.101:6379",
    "name_list_key": "names",
    "name": "name-source"
  },
  "tasks": []
}

$ curl -XPOST $(docker-machine ip dev):8083/connectors \
       -H "Content-Type: application/json" \
       -d "{
             \"name\": \"greeting-sink\",
             \"config\": {
               \"connector.class\": \"us.yellosoft.hellokafkaconnect.GreeterSink\",
               \"tasks.max\": \"1\",
               \"topics\": \"names\",
               \"redis_address\": \"redis://$(docker-machine ip dev):6379\",
               \"greeting_list_key\": \"greetings\"
              }
           }" | jq .

{
  "name": "greeting-sink",
  "config": {
    "connector.class": "us.yellosoft.hellokafkaconnect.GreeterSink",
    "tasks.max": "1",
    "topics": "names",
    "redis_address": "redis://192.168.99.101:6379",
    "greeting_list_key": "greetings",
    "name": "greeting-sink"
  },
  "tasks": []
}

$ curl $(docker-machine ip dev):8083/connectors | jq .

[
  "greeting-sink",
  "name-source"
]

$ redis-cli -h $(docker-machine ip dev) lpush names 'Alice'
(integer) 1

At this point, the docker-compose terminal begins erroring:

kafka_1    | [2016-07-19 16:15:49,349] INFO Partition [names,0] on broker 0: No checkpointed highwatermark is found for partition [names,0] (kafka.cluster.Partition)
kafka_1    | [2016-07-19 16:15:49,353] INFO [GroupCoordinator 0]: Assignment received from leader for group connect-greeting-sink for generation 1 (kafka.coordinator.GroupCoordinator)
connect_1  | [2016-07-19 16:15:49,366] INFO Successfully joined group connect-greeting-sink with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:434)
connect_1  | [2016-07-19 16:15:49,366] INFO Setting newly assigned partitions [] for group connect-greeting-sink (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:219)
connect_1  | [2016-07-19 16:16:09,163] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | java.lang.NullPointerException
connect_1  | at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.set(KafkaOffsetBackingStore.java:122)
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.doFlush(OffsetStorageWriter.java:165)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:319)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:16:19,164] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:16:19,165] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:16:29,166] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:16:29,166] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:16:39,169] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:16:39,170] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:16:49,187] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:16:49,188] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:16:59,190] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:16:59,190] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:09,191] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:09,192] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:19,194] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:19,195] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:29,199] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:29,200] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:39,202] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:39,208] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:49,209] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:49,209] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:17:59,213] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:17:59,214] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:09,215] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:09,216] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:19,218] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:19,218] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:29,220] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:29,221] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:39,223] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:39,223] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:49,224] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:49,225] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:18:59,227] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:18:59,228] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:09,230] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:09,231] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:19,232] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:19,233] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:29,239] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:29,239] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:39,244] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:39,245] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:49,246] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:49,246] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:19:59,248] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:19:59,249] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:09,250] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:09,251] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:19,253] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:19,254] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:29,506] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:29,507] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:39,509] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:39,509] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:49,281] INFO Revoking previously assigned partitions [] for group connect-greeting-sink (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:280)
connect_1  | [2016-07-19 16:20:49,281] INFO (Re-)joining group connect-greeting-sink (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:326)
kafka_1    | [2016-07-19 16:20:49,282] INFO [GroupCoordinator 0]: Preparing to restabilize group connect-greeting-sink with old generation 1 (kafka.coordinator.GroupCoordinator)
kafka_1    | [2016-07-19 16:20:49,285] INFO [GroupCoordinator 0]: Stabilized group connect-greeting-sink generation 2 (kafka.coordinator.GroupCoordinator)
kafka_1    | [2016-07-19 16:20:49,287] INFO [GroupCoordinator 0]: Assignment received from leader for group connect-greeting-sink for generation 2 (kafka.coordinator.GroupCoordinator)
connect_1  | [2016-07-19 16:20:49,288] INFO Successfully joined group connect-greeting-sink with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:434)
connect_1  | [2016-07-19 16:20:49,289] INFO Setting newly assigned partitions [names-0] for group connect-greeting-sink (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:219)
connect_1  | [2016-07-19 16:20:49,516] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:49,516] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:20:59,118] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:20:59,518] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:20:59,518] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:09,137] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:09,521] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:09,521] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:19,124] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:19,523] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:19,523] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:29,121] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:29,525] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:29,528] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:39,124] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:39,534] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:39,534] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:49,120] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:49,538] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:49,539] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
connect_1  | [2016-07-19 16:21:59,120] INFO WorkerSinkTask{id=greeting-sink-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:244)
connect_1  | [2016-07-19 16:21:59,541] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:110)
connect_1  | [2016-07-19 16:21:59,543] ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0}:  (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:115)
connect_1  | org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
connect_1  | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
connect_1  | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
connect_1  | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
connect_1  | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1  | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
connect_1  | at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
connect_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
connect_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
connect_1  | at java.lang.Thread.run(Thread.java:745)
^CGracefully stopping... (press Ctrl+C again to force)
Stopping hellokafkaconnect_connect_1 ... done
Stopping hellokafkaconnect_kafka_1 ... done
Stopping hellokafkaconnect_zk_1 ... done
Stopping hellokafkaconnect_redis_1 ... done

System

As specified in docker-compose.yml, I'm using Kafka Connect 0.10.0.0, Kafka 0.10.0.0, ZooKeeper 3.4.8, and Redis 3.2.1.

For what it's worth, I'm using Docker 1.11.2 via Docker Toolbox on Mac OS 10.11.5 El Capitan.
This was referenced Jul 26, 2016
Open
Open
@1ambda
Copy link
Owner

1ambda commented Jul 27, 2016

@mcandre Thanks for reporting this bug. I will investigate the issue at this weekend :)

@mcandre
Copy link
Author

mcandre commented Jul 28, 2016

This appears to be an issue internal to Kafka (Connect), and does not prevent the overall Connect setup from working.

@mcandre mcandre closed this as completed Jul 28, 2016
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@mcandre @1ambda