Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- {
- "name": "xxxxxxx",
- "config": {
- "connector.class": "io.confluent.connect.s3.S3SinkConnector",
- "s3.region": "us-east-1",
- "partition.duration.ms": "600000",
- "topics.dir": "xxxxx",
- "flush.size": "100000",
- "schema.compatibility": "NONE",
- "topics": "xxxxxx,xxxxxx",
- "tasks.max": "16",
- "s3.part.size": "52428800",
- "timezone": "UTC",
- "locale": "en",
- "format.class": "xxx.xxxx.xxx.CustomByteArrayFormat",
- "partitioner.class": "xxx.xxxx.xxx.CustomTimeBasedPartitioner",
- "schema.generator.class": "io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator",
- "name": "xxxxxxxxx",
- "storage.class": "io.confluent.connect.s3.storage.S3Storage",
- "s3.bucket.name": "xxxxxxx",
- "rotate.schedule.interval.ms": "600000",
- "path.format": "YYYY/MM/dd/HH/mm",
- "timestamp.extractor": "Record"
- }
- bootstrap.servers=XXXXXX
- key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
- value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
- internal.key.converter=org.apache.kafka.connect.json.JsonConverter
- internal.value.converter=org.apache.kafka.connect.json.JsonConverter
- internal.key.converter.schemas.enable=false
- internal.value.converter.schemas.enable=false
- consumer.auto.offset.reset=earliest
- consumer.max.partition.fetch.bytes=2097152
- consumer.partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor
- group.id=xxxxxxx
- config.storage.topic=connect-configs
- offset.storage.topic=connect-offsets
- status.storage.topic=connect-status
- rest.advertised.host.name=XXXX
- 2018-06-21 14:54:48,644] ERROR Task XXXXXXXXXXXXX-15 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerSinkTask:482)
- java.lang.OutOfMemoryError: Java heap space
- [2018-06-21 14:54:48,645] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerSinkTask:483)
- [2018-06-21 14:54:48,645] ERROR Task XXXXXXXXXXXXXXXX-15 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:148)
- org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
- at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:484)
- at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:265)
- at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:182)
- at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:150)
- at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
- at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
- at java.lang.Thread.run(Thread.java:745)
Add Comment
Please, Sign In to add comment