Hi,
I hope you can help me on to undertand the cause of an issue I am having
with Kafka Connector,
https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector
that use gRPC.
Basically I have a Kafka Connect server in a network that is not connected
to the public network and it talk to pubsub.googleapis.com:443 trough a
Microsoft ForeFront 2010 proxy.
When I try to send messages to Kafka topic I get after a few
seconds/minutes this error in the Kafka Connect log:
[2018-02-10 10:07:28,077] ERROR WorkerSinkTask{id=CPSConnector-0} Offset
commit failed, rewinding to last committed offsets
(org.apache.kafka.connect.runtime.WorkerSinkTask:351)
java.lang.RuntimeException: java.util.concurrent.ExecutionException:
io.grpc.StatusRuntimeException: INTERNAL: Connection closed with unknown
cause
at
com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:293)
at org.apache.kafka.connect.sink.SinkTask.preCommit(SinkTask.java:117)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:345)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:182)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:166)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
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:
io.grpc.StatusRuntimeException: INTERNAL: Connection closed with unknown
cause
at
com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
at
com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:459)
at
com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:290)
... 11 more
Caused by: io.grpc.StatusRuntimeException: INTERNAL: Connection closed with
unknown cause
at io.grpc.Status.asRuntimeException(Status.java:526)
at
io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:433)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:422)
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:61)
at
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:504)
at
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$600(ClientCallImpl.java:425)
at
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:536)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:102)
... 3 more
I really can't understand the cause of this issue.
Could be that the proxy must support http2 because the connector is using
gRPC?
Please let me know if you can help me on this
thanks
--
You received this message because you are subscribed to the Google Groups
"grpc.io" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/grpc-io.
To view this discussion on the web visit
https://groups.google.com/d/msgid/grpc-io/CAJkvmchYQ8zrwrDz-HbLg-Zfb%2B%2Bnc9rQKYQE3BVrrsizgwCp4A%40mail.gmail.com.
For more options, visit https://groups.google.com/d/optout.
