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

Commit of offsets timed out - Many thread exceptions #221

Open
jonathanendy opened this issue May 21, 2020 · 4 comments
Open

Commit of offsets timed out - Many thread exceptions #221

jonathanendy opened this issue May 21, 2020 · 4 comments

Comments

@jonathanendy
Copy link

jonathanendy commented May 21, 2020 •
edited
Loading

Hi,
Suddenly we got exceptions with the connector.
I'm not sure but it seems that sending data to pubsub got exceptions for all parallel threads
I don't think it is Kafka issue because we have another tool that works fine but sending to kinesis.
Can someone help me to pinpoint the issue?

Thanks

[2020-05-21 06:10:03,533] INFO WorkerSinkTask{id=data-output-stream-0} Committing offsets asynchronously using sequence number 1483: {data-output-stream-0=OffsetAndMetadata{offset=599325844, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:344)
[2020-05-21 06:11:03,623] ERROR WorkerSinkTask{id=data-output-stream-0} Offset commit failed, rewinding to last committed offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:384)
java.lang.RuntimeException: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999884670ns
        at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:324)
        at org.apache.kafka.connect.sink.SinkTask.preCommit(SinkTask.java:125)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:378)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:208)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:192)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999884670ns
        at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
        at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479)
        at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
        at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:62)
        at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:322)
        ... 11 more
Caused by: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999884670ns
        at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:51)
        at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
        at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
        at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
        at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:68)
        at com.google.common.util.concurrent.Futures$4.run(Futures.java:1123)
        at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:435)
        at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:900)
        at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:811)
        at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:675)
        at io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:507)
        at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:482)
        at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
        at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
        at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
        at io.grpc.internal.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:678)
        at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
        at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
        at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
        at io.grpc.internal.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:397)
        at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:459)
        at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:63)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:546)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$600(ClientCallImpl.java:467)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:584)
        at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
        at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        ... 3 more
Caused by: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999884670ns
        at io.grpc.Status.asRuntimeException(Status.java:526)
        ... 23 more

and

ERROR WorkerSinkTask{id=data-output-stream-0} Commit of offsets threw an unexpected exception for sequence number 1486: null (org.apache.kafka.connect.runtime.WorkerSinkTask:259)
java.lang.RuntimeException: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999859478ns
        at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:324)
        at org.apache.kafka.connect.sink.SinkTask.preCommit(SinkTask.java:125)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:378)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:208)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:192)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999859478ns
        at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
        at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479)
        at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
        at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:62)
        at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:322)
        ... 11 more
Caused by: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9999859478ns
        at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:51)
        at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
        at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
        at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
        at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:68)
        at com.google.common.util.concurrent.Futures$4.run(Futures.java:1123)
        at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:435)
        at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:900)
        at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:811)
        at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:675)
        at io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:507)
        at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:482)
        at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
        at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
        at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
        at io.grpc.internal.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:678)
        at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
        at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
        at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
        at io.grpc.internal.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:397)
        at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:459)
        at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:63)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:546)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$600(ClientCallImpl.java:467)
        at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:584)
        at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
        at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        ... 3 more
@jonathanendy jonathanendy changed the title Commit of offsets timed out - Manny thread exceptions Commit of offsets timed out - Many thread exceptions May 21, 2020
@kamalaboulhosn
Copy link
Collaborator

From where are you running the connector? Is it in GCP or elsewhere? It could be an issue with the connection between wherever Kafka Connect is running and GCP. I see that the default retry settings in the connector are not set properly, so I will fix that. In the meantime, you could try setting the maxTotalTimeoutMs property to 60000.

@kamalaboulhosn
Copy link
Collaborator

Actually, sorry, I was mistaken. The default is indeed 60s. Did you by chance change the value of maxTotalTimeoutMs?

@jonathanendy
Copy link
Author

jonathanendy commented May 22, 2020 •
edited
Loading

I didn't touch the default, I'm adding the full logs:
The architecture is a local site (on prem) Kafka with the connector on the same CPU passing the data to pubsub

#####  /opt/kafka-latest/config/connect-standalone.properties  ####
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# These are defaults. This file just demonstrates how to override some settings.
bootstrap.servers=kafka:29092
# The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
# need to configure these based on the format they want their data in when loaded from or stored into Kafka
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
# Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply
# it to
key.converter.schemas.enable=false
value.converter.schemas.enable=false
offset.storage.file.filename=/tmp/connect.offsets
# Flush much faster than normal, which is useful for testing/debugging
offset.flush.interval.ms=10000
# Set to a list of filesystem paths separated by commas (,) to enable class loading isolation for plugins
# (connectors, converters, transformations). The list should consist of top level directories that include 
# any combination of: 
# a) directories immediately containing jars with plugins and their dependencies
# b) uber-jars with plugins and their dependencies
# c) directories immediately containing the package directory structure of classes of plugins and their dependencies
# Note: symlinks will be followed to discover dependencies or plugins.
# Examples: 
#plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors,
plugin.path=/opt/kafka-latest/connectors#####  /opt/kafka-latest/config/cps-sink-connector.properties  ####
### INFO: 
### kafka connect offical site: http://kafka.apache.org/documentation.html#connect
### GCP kafka connect: https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

# name - Unique name for the connector. Attempting to register again with the same name will fail.
name=data-output-stream

# connector.class - The Java class for the connector
connector.class=com.google.pubsub.kafka.sink.CloudPubSubSinkConnector

# tasks.max - The maximum number of tasks that should be created for this connector. 
#  The connector may create fewer tasks if it cannot achieve this level of parallelism.
tasks.max=10

# topics - A comma-separated list of topics to use as input for this connector
topics=data-output-stream

# cps.topic - The topic in Cloud Pub/Sub to publish to, e.g. "foo" for topic "/projects/bar/topics/foo".
cps.topic=data-output-stream
cps.project=fabric-data-252413
[2020-05-22 03:45:23,296] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:69)
[2020-05-22 03:45:23,328] INFO WorkerInfo values: 
	jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/opt/kafka-latest/bin/../logs, -Dlog4j.configuration=file:/opt/kafka-latest/bin/../config/connect-log4j.properties
	jvm.spec = Private Build, OpenJDK 64-Bit Server VM, 1.8.0_232, 25.232-b09
	jvm.classpath = /opt/kafka-latest/bin/../libs/activation-1.1.1.jar:/opt/kafka-latest/bin/../libs/aopalliance-repackaged-2.5.0.jar:/opt/kafka-latest/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka-latest/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka-latest/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka-latest/bin/../libs/connect-api-2.3.0.jar:/opt/kafka-latest/bin/../libs/connect-basic-auth-extension-2.3.0.jar:/opt/kafka-latest/bin/../libs/connect-file-2.3.0.jar:/opt/kafka-latest/bin/../libs/connect-json-2.3.0.jar:/opt/kafka-latest/bin/../libs/connect-runtime-2.3.0.jar:/opt/kafka-latest/bin/../libs/connect-transforms-2.3.0.jar:/opt/kafka-latest/bin/../libs/guava-20.0.jar:/opt/kafka-latest/bin/../libs/hk2-api-2.5.0.jar:/opt/kafka-latest/bin/../libs/hk2-locator-2.5.0.jar:/opt/kafka-latest/bin/../libs/hk2-utils-2.5.0.jar:/opt/kafka-latest/bin/../libs/jackson-annotations-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-core-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-databind-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-dataformat-csv-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-datatype-jdk8-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-jaxrs-base-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-jaxrs-json-provider-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-module-jaxb-annotations-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-module-paranamer-2.9.9.jar:/opt/kafka-latest/bin/../libs/jackson-module-scala_2.12-2.9.9.jar:/opt/kafka-latest/bin/../libs/jakarta.annotation-api-1.3.4.jar:/opt/kafka-latest/bin/../libs/jakarta.inject-2.5.0.jar:/opt/kafka-latest/bin/../libs/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka-latest/bin/../libs/javassist-3.22.0-CR2.jar:/opt/kafka-latest/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka-latest/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka-latest/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka-latest/bin/../libs/jersey-client-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-common-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-container-servlet-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-container-servlet-core-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-hk2-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-media-jaxb-2.28.jar:/opt/kafka-latest/bin/../libs/jersey-server-2.28.jar:/opt/kafka-latest/bin/../libs/jetty-client-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-continuation-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-http-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-io-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-security-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-server-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-servlet-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-servlets-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jetty-util-9.4.18.v20190429.jar:/opt/kafka-latest/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka-latest/bin/../libs/jsr305-3.0.2.jar:/opt/kafka-latest/bin/../libs/kafka-clients-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-log4j-appender-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-streams-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-streams-examples-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-streams-scala_2.12-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-streams-test-utils-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka-tools-2.3.0.jar:/opt/kafka-latest/bin/../libs/kafka_2.12-2.3.0-sources.jar:/opt/kafka-latest/bin/../libs/kafka_2.12-2.3.0.jar:/opt/kafka-latest/bin/../libs/log4j-1.2.17.jar:/opt/kafka-latest/bin/../libs/lz4-java-1.6.0.jar:/opt/kafka-latest/bin/../libs/maven-artifact-3.6.1.jar:/opt/kafka-latest/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka-latest/bin/../libs/osgi-resource-locator-1.0.1.jar:/opt/kafka-latest/bin/../libs/paranamer-2.8.jar:/opt/kafka-latest/bin/../libs/plexus-utils-3.2.0.jar:/opt/kafka-latest/bin/../libs/reflections-0.9.11.jar:/opt/kafka-latest/bin/../libs/rocksdbjni-5.18.3.jar:/opt/kafka-latest/bin/../libs/scala-library-2.12.8.jar:/opt/kafka-latest/bin/../libs/scala-logging_2.12-3.9.0.jar:/opt/kafka-latest/bin/../libs/scala-reflect-2.12.8.jar:/opt/kafka-latest/bin/../libs/slf4j-api-1.7.26.jar:/opt/kafka-latest/bin/../libs/slf4j-log4j12-1.7.26.jar:/opt/kafka-latest/bin/../libs/snappy-java-1.1.7.3.jar:/opt/kafka-latest/bin/../libs/spotbugs-annotations-3.1.9.jar:/opt/kafka-latest/bin/../libs/validation-api-2.0.1.Final.jar:/opt/kafka-latest/bin/../libs/zkclient-0.11.jar:/opt/kafka-latest/bin/../libs/zookeeper-3.4.14.jar:/opt/kafka-latest/bin/../libs/zstd-jni-1.4.0-1.jar
	os.spec = Linux, amd64, 4.15.0-99-generic
	os.vcpus = 4
 (org.apache.kafka.connect.runtime.WorkerInfo:71)
[2020-05-22 03:45:23,354] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:78)
[2020-05-22 03:45:23,433] INFO Loading plugin from: /opt/kafka-latest/connectors/cps-kafka-connector.jar (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)
[2020-05-22 03:45:26,789] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka-latest/connectors/cps-kafka-connector.jar} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2020-05-22 03:45:26,790] INFO Added plugin 'com.google.pubsub.kafka.sink.CloudPubSubSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:26,790] INFO Added plugin 'com.google.pubsub.kafka.source.CloudPubSubSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:26,790] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:26,790] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:26,790] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,574] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)
[2020-05-22 03:45:29,574] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,575] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,576] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,578] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,579] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,581] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,582] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,583] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,583] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,583] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,584] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,584] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,584] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,585] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,585] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,585] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,585] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,586] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,587] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,587] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,591] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,591] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,591] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,594] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,595] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,596] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,596] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,597] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,597] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,599] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,599] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,600] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,600] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,601] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,601] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,602] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,603] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,603] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,604] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,605] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)
[2020-05-22 03:45:29,607] INFO Added aliases 'CloudPubSubSinkConnector' and 'CloudPubSubSink' to plugin 'com.google.pubsub.kafka.sink.CloudPubSubSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,608] INFO Added aliases 'CloudPubSubSourceConnector' and 'CloudPubSubSource' to plugin 'com.google.pubsub.kafka.source.CloudPubSubSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,609] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,610] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,610] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,611] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,612] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,613] INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,614] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,614] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,615] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,616] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,616] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,617] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,618] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,618] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,619] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,620] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,621] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,622] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,623] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,623] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,624] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,624] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,625] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,626] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2020-05-22 03:45:29,627] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,628] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2020-05-22 03:45:29,630] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2020-05-22 03:45:29,630] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2020-05-22 03:45:29,631] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:394)
[2020-05-22 03:45:29,632] INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,632] INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,633] INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:397)
[2020-05-22 03:45:29,644] INFO StandaloneConfig values: 
	access.control.allow.methods = 
	access.control.allow.origin = 
	bootstrap.servers = [kafka:29092]
	client.dns.lookup = default
	config.providers = []
	connector.client.config.override.policy = None
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	internal.key.converter = class org.apache.kafka.connect.json.JsonConverter
	internal.value.converter = class org.apache.kafka.connect.json.JsonConverter
	key.converter = class org.apache.kafka.connect.storage.StringConverter
	listeners = null
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	offset.flush.interval.ms = 10000
	offset.flush.timeout.ms = 5000
	offset.storage.file.filename = /tmp/connect.offsets
	plugin.path = [/opt/kafka-latest/connectors]
	rest.advertised.host.name = null
	rest.advertised.listener = null
	rest.advertised.port = null
	rest.extension.classes = []
	rest.host.name = null
	rest.port = 8083
	ssl.client.auth = none
	task.shutdown.graceful.timeout.ms = 5000
	value.converter = class org.apache.kafka.connect.storage.StringConverter
 (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:347)
[2020-05-22 03:45:29,648] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)
[2020-05-22 03:45:29,663] INFO AdminClientConfig values: 
	bootstrap.servers = [kafka:29092]
	client.dns.lookup = default
	client.id = 
	connections.max.idle.ms = 300000
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 120000
	retries = 5
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:347)
[2020-05-22 03:45:29,838] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,839] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,842] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,843] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,843] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,844] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,847] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:355)
[2020-05-22 03:45:29,848] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:29,848] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:29,849] INFO Kafka startTimeMs: 1590119129847 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:30,166] INFO Kafka cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.connect.util.ConnectUtils:59)
[2020-05-22 03:45:30,211] INFO Logging initialized @9179ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
[2020-05-22 03:45:30,439] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:122)
[2020-05-22 03:45:30,440] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:166)
[2020-05-22 03:45:30,456] INFO jetty-9.4.18.v20190429; built: 2019-04-29T20:42:08.989Z; git: e1bc35120a6617ee3df052294e433f3a25ce7097; jvm 1.8.0_232-8u232-b09-0ubuntu1~18.04.1-b09 (org.eclipse.jetty.server.Server:370)
[2020-05-22 03:45:30,549] INFO Started http_8083@48d5f34e{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:292)
[2020-05-22 03:45:30,550] INFO Started @9519ms (org.eclipse.jetty.server.Server:410)
[2020-05-22 03:45:30,595] INFO Advertised URI: http://172.18.0.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2020-05-22 03:45:30,596] INFO REST server listening at http://172.18.0.5:8083/, advertising URL http://172.18.0.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:181)
[2020-05-22 03:45:30,597] INFO Advertised URI: http://172.18.0.5:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:285)
[2020-05-22 03:45:30,599] INFO Setting up None Policy for ConnectorClientConfigOverride. This will disallow any client configuration to be overridden (org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy:45)
[2020-05-22 03:45:30,620] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:30,620] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:30,621] INFO Kafka startTimeMs: 1590119130620 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:30,882] INFO JsonConverterConfig values: 
	converter.type = key
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-05-22 03:45:30,884] INFO JsonConverterConfig values: 
	converter.type = value
	schemas.cache.size = 1000
	schemas.enable = false
 (org.apache.kafka.connect.json.JsonConverterConfig:347)
[2020-05-22 03:45:30,893] INFO Kafka Connect standalone worker initialization took 7594ms (org.apache.kafka.connect.cli.ConnectStandalone:100)
[2020-05-22 03:45:30,893] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:50)
[2020-05-22 03:45:30,893] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:91)
[2020-05-22 03:45:30,894] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:182)
[2020-05-22 03:45:30,894] INFO Starting FileOffsetBackingStore with file /tmp/connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:58)
[2020-05-22 03:45:30,897] INFO Worker started (org.apache.kafka.connect.runtime.Worker:187)
[2020-05-22 03:45:30,897] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:93)
[2020-05-22 03:45:30,897] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:186)
[2020-05-22 03:45:31,025] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)
[2020-05-22 03:45:31,025] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
[2020-05-22 03:45:31,027] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session:149)
[2020-05-22 03:45:31,856] INFO Started o.e.j.s.ServletContextHandler@70fab835{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:855)
[2020-05-22 03:45:31,856] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:233)
[2020-05-22 03:45:31,856] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2020-05-22 03:45:31,869] INFO AbstractConfig values: 
 (org.apache.kafka.common.config.AbstractConfig:347)
[2020-05-22 03:45:31,882] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:31,883] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:31,884] INFO Creating connector data-output-stream of type com.google.pubsub.kafka.sink.CloudPubSubSinkConnector (org.apache.kafka.connect.runtime.Worker:246)
[2020-05-22 03:45:31,890] INFO Instantiated connector data-output-stream with version 2.3.0 of type class com.google.pubsub.kafka.sink.CloudPubSubSinkConnector (org.apache.kafka.connect.runtime.Worker:249)
[2020-05-22 03:45:31,892] INFO Started the CloudPubSubSinkConnector. (com.google.pubsub.kafka.sink.CloudPubSubSinkConnector:66)
[2020-05-22 03:45:31,893] INFO Finished creating connector data-output-stream (org.apache.kafka.connect.runtime.Worker:268)
[2020-05-22 03:45:31,895] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:31,896] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:31,900] INFO Creating task data-output-stream-0 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:31,901] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:31,902] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:31,906] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:31,909] INFO Instantiated task data-output-stream-0 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:31,911] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:31,912] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-0 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:31,912] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:31,913] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-0 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:31,913] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-0 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:31,922] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:31,923] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:31,924] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:31,941] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-0
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:31,994] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:31,995] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:31,995] INFO Kafka startTimeMs: 1590119131994 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,005] INFO Creating task data-output-stream-1 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,006] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,009] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,009] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,009] INFO Instantiated task data-output-stream-1 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,010] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,010] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-1 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,010] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,010] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-1 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,011] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-1 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,015] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,016] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,016] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,017] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,034] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,036] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,037] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,037] INFO Kafka startTimeMs: 1590119132036 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,047] INFO Creating task data-output-stream-2 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,047] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,048] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,048] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,049] INFO Instantiated task data-output-stream-2 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,050] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,050] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-2 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,051] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,051] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-2 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,052] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-2 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,055] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,056] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,058] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,059] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,060] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-2
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,075] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,076] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,076] INFO Kafka startTimeMs: 1590119132075 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,083] INFO Creating task data-output-stream-3 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,084] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,085] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,087] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,087] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,087] INFO Instantiated task data-output-stream-3 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,088] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,088] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-3 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,088] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,089] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-3 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,090] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-3 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,092] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,092] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,094] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,095] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-3
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,107] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,107] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,108] INFO Kafka startTimeMs: 1590119132107 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,113] INFO Creating task data-output-stream-4 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,114] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,114] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,115] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,115] INFO Instantiated task data-output-stream-4 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,116] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,116] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-4 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,116] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,117] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-4 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,117] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-4 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,121] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,121] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,122] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,124] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-4
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,130] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,141] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,142] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,142] INFO Kafka startTimeMs: 1590119132141 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,150] INFO Creating task data-output-stream-5 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,152] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,152] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,153] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,154] INFO Instantiated task data-output-stream-5 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,154] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,155] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-5 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,155] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,156] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-5 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,157] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-5 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,160] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,160] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,161] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,163] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-5
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,169] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,180] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,181] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,181] INFO Kafka startTimeMs: 1590119132180 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,191] INFO Creating task data-output-stream-6 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,197] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,198] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,199] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,199] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,200] INFO Instantiated task data-output-stream-6 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,206] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,206] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-6 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,211] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,212] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-6 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,213] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-6 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,215] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,216] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,217] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,231] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-6
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,244] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,244] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,245] INFO Kafka startTimeMs: 1590119132244 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,248] INFO Creating task data-output-stream-7 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,249] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,250] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,250] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,251] INFO Instantiated task data-output-stream-7 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,251] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,252] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-7 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,253] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,253] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-7 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,253] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-7 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,255] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,255] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,256] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,257] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-7
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,270] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,273] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,274] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,274] INFO Kafka startTimeMs: 1590119132272 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,284] INFO Creating task data-output-stream-8 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,284] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,284] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,285] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,285] INFO Instantiated task data-output-stream-8 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,285] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,286] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-8 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,286] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,286] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-8 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,286] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-8 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,287] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,288] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,288] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,291] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-8
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,305] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,311] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,312] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,312] INFO Kafka startTimeMs: 1590119132311 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,318] INFO Creating task data-output-stream-9 (org.apache.kafka.connect.runtime.Worker:414)
[2020-05-22 03:45:32,319] INFO ConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig:347)
[2020-05-22 03:45:32,319] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,320] INFO TaskConfig values: 
	task.class = class com.google.pubsub.kafka.sink.CloudPubSubSinkTask
 (org.apache.kafka.connect.runtime.TaskConfig:347)
[2020-05-22 03:45:32,320] INFO Instantiated task data-output-stream-9 with version 2.3.0 of type com.google.pubsub.kafka.sink.CloudPubSubSinkTask (org.apache.kafka.connect.runtime.Worker:428)
[2020-05-22 03:45:32,320] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,320] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-9 using the worker config (org.apache.kafka.connect.runtime.Worker:441)
[2020-05-22 03:45:32,321] INFO StringConverterConfig values: 
	converter.encoding = UTF8
	converter.type = value
 (org.apache.kafka.connect.storage.StringConverterConfig:347)
[2020-05-22 03:45:32,321] INFO Set up the value converter class org.apache.kafka.connect.storage.StringConverter for task data-output-stream-9 using the worker config (org.apache.kafka.connect.runtime.Worker:447)
[2020-05-22 03:45:32,321] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task data-output-stream-9 using the worker config (org.apache.kafka.connect.runtime.Worker:454)
[2020-05-22 03:45:32,327] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker:522)
[2020-05-22 03:45:32,329] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:32,337] INFO SinkConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.SinkConnectorConfig:347)
[2020-05-22 03:45:32,337] INFO EnrichedConnectorConfig values: 
	config.action.reload = restart
	connector.class = com.google.pubsub.kafka.sink.CloudPubSubSinkConnector
	errors.deadletterqueue.context.headers.enable = false
	errors.deadletterqueue.topic.name = 
	errors.deadletterqueue.topic.replication.factor = 3
	errors.log.enable = false
	errors.log.include.messages = false
	errors.retry.delay.max.ms = 60000
	errors.retry.timeout = 0
	errors.tolerance = none
	header.converter = null
	key.converter = null
	name = data-output-stream
	tasks.max = 10
	topics = [data-output-stream]
	topics.regex = 
	transforms = []
	value.converter = null
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
[2020-05-22 03:45:32,338] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [kafka:29092]
	check.crcs = true
	client.dns.lookup = default
	client.id = connector-consumer-data-output-stream-9
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = connect-data-output-stream
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = https
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:347)
[2020-05-22 03:45:32,345] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser:117)
[2020-05-22 03:45:32,345] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser:118)
[2020-05-22 03:45:32,346] INFO Kafka startTimeMs: 1590119132345 (org.apache.kafka.common.utils.AppInfoParser:119)
[2020-05-22 03:45:32,355] INFO Created connector data-output-stream (org.apache.kafka.connect.cli.ConnectStandalone:112)
[2020-05-22 03:45:32,361] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Subscribed to topic(s): data-output-stream (org.apache.kafka.clients.consumer.KafkaConsumer:964)
[2020-05-22 03:45:33,306] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,307] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,307] INFO WorkerSinkTask{id=data-output-stream-2} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,307] INFO WorkerSinkTask{id=data-output-stream-6} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,311] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,312] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,312] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,312] INFO WorkerSinkTask{id=data-output-stream-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,313] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,313] INFO WorkerSinkTask{id=data-output-stream-1} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,314] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,314] INFO WorkerSinkTask{id=data-output-stream-5} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,314] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,312] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,315] INFO WorkerSinkTask{id=data-output-stream-7} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,315] INFO WorkerSinkTask{id=data-output-stream-4} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,314] INFO WorkerSinkTask{id=data-output-stream-3} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,313] INFO WorkerSinkTask{id=data-output-stream-9} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,318] INFO Start CloudPubSubSinkTask (com.google.pubsub.kafka.sink.CloudPubSubSinkTask:145)
[2020-05-22 03:45:33,319] INFO WorkerSinkTask{id=data-output-stream-8} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:301)
[2020-05-22 03:45:33,365] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,368] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,368] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,368] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,365] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,365] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,365] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,372] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,372] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,375] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,377] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,371] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,371] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,371] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Cluster ID: 36MPGS-bQEGQTzqv2AM-rg (org.apache.kafka.clients.Metadata:266)
[2020-05-22 03:45:33,380] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,375] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,375] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,374] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,386] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,386] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,385] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,380] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,388] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,380] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,383] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,383] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,383] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Discovered group coordinator kafka:29092 (id: 2147482646 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:728)
[2020-05-22 03:45:33,381] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,391] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,389] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,388] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,388] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,399] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,401] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,402] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,402] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,408] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,408] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,413] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,423] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Revoking previously assigned partitions [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:476)
[2020-05-22 03:45:33,424] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,425] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,425] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,430] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,430] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,432] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,433] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,435] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,436] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:33,438] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505)
[2020-05-22 03:45:36,429] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,429] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,437] INFO [Consumer clientId=connector-consumer-data-output-stream-1, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,436] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,435] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Successfully joined group with generation 33 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:469)
[2020-05-22 03:45:36,429] INFO [Consumer clientId=connector-consumer-data-output-stream-6, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,445] INFO [Consumer clientId=connector-consumer-data-output-stream-9, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,445] INFO [Consumer clientId=connector-consumer-data-output-stream-5, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,443] INFO [Consumer clientId=connector-consumer-data-output-stream-7, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,442] INFO [Consumer clientId=connector-consumer-data-output-stream-8, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,442] INFO [Consumer clientId=connector-consumer-data-output-stream-3, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,440] INFO [Consumer clientId=connector-consumer-data-output-stream-2, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,439] INFO [Consumer clientId=connector-consumer-data-output-stream-4, groupId=connect-data-output-stream] Setting newly assigned partitions:  (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,455] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Setting newly assigned partitions: data-output-stream-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:283)
[2020-05-22 03:45:36,476] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Setting offset for partition data-output-stream-0 to the committed offset FetchPosition{offset=600399626, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=kafka:29092 (id: 1001 rack: null), epoch=0}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:525)
[2020-05-22 03:45:36,510] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Fetch offset 600399626 is out of range for partition data-output-stream-0, resetting offset (org.apache.kafka.clients.consumer.internals.Fetcher:1214)
[2020-05-22 03:45:36,524] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Resetting offset for partition data-output-stream-0 to offset 607625010. (org.apache.kafka.clients.consumer.internals.SubscriptionState:348)
[2020-05-22 03:46:37,017] ERROR WorkerSinkTask{id=data-output-stream-0} Offset commit failed, rewinding to last committed offsets (org.apache.kafka.connect.runtime.WorkerSinkTask:384)
java.lang.RuntimeException: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:324)
	at org.apache.kafka.connect.sink.SinkTask.preCommit(SinkTask.java:125)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:378)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:208)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:192)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
	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:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
	at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479)
	at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
	at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:62)
	at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:322)
	... 11 more
Caused by: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:51)
	at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
	at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
	at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:68)
	at com.google.common.util.concurrent.Futures$4.run(Futures.java:1123)
	at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:435)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:900)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:811)
	at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:675)
	at io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:526)
	at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:501)
	at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:426)
	at io.grpc.internal.ClientCallImpl.access$500(ClientCallImpl.java:66)
	at io.grpc.internal.ClientCallImpl$1CloseInContext.runInContext(ClientCallImpl.java:416)
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	... 3 more
Caused by: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at io.grpc.Status.asRuntimeException(Status.java:533)
	... 13 more
[2020-05-22 03:46:37,030] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Seeking to offset 600399626 for partition data-output-stream-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1545)
[2020-05-22 03:46:37,032] ERROR WorkerSinkTask{id=data-output-stream-0} Commit of offsets threw an unexpected exception for sequence number 1: null (org.apache.kafka.connect.runtime.WorkerSinkTask:259)
java.lang.RuntimeException: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:324)
	at org.apache.kafka.connect.sink.SinkTask.preCommit(SinkTask.java:125)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:378)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:208)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:192)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
	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:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
	at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479)
	at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
	at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:62)
	at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:322)
	... 11 more
Caused by: com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:51)
	at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
	at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
	at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
	at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:68)
	at com.google.common.util.concurrent.Futures$4.run(Futures.java:1123)
	at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:435)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:900)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:811)
	at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:675)
	at io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:526)
	at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:501)
	at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:426)
	at io.grpc.internal.ClientCallImpl.access$500(ClientCallImpl.java:66)
	at io.grpc.internal.ClientCallImpl$1CloseInContext.runInContext(ClientCallImpl.java:416)
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	... 3 more
Caused by: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999810964s. [remote_addr=pubsub.googleapis.com/216.58.198.74:443]
	at io.grpc.Status.asRuntimeException(Status.java:533)
	... 13 more
[2020-05-22 03:46:37,038] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Fetch offset 600399626 is out of range for partition data-output-stream-0, resetting offset (org.apache.kafka.clients.consumer.internals.Fetcher:1214)
[2020-05-22 03:46:37,040] INFO [Consumer clientId=connector-consumer-data-output-stream-0, groupId=connect-data-output-stream] Resetting offset for partition data-output-stream-0 to offset 607836681. (org.apache.kafka.clients.consumer.internals.SubscriptionState:348)
[2020-05-22 03:46:43,644] INFO WorkerSinkTask{id=data-output-stream-0} Committing offsets asynchronously using sequence number 2: {data-output-stream-0=OffsetAndMetadata{offset=607836887, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:344)
[2020-05-22 03:46:43,677] WARN WorkerSinkTask{id=data-output-stream-0} Commit of offsets timed out (org.apache.kafka.connect.runtime.WorkerSinkTask:217)

@dariocazas
Copy link

We found the DEADLINE_EXCEEDED in our systems in some cases, but at the moment we have not been able to reproduce them in a controlled environment. I subscribe because we are also after this case.

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
3 participants
@kamalaboulhosn @jonathanendy @dariocazas