Repository navigation
[KafkaPubSubConnector] : Getting UNAVAILABLE: HTTP/2 error code: NO_ERROR and goes into retry loop forever #3071
Description
I am using https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector for publishing messages to pubsub from kafka.
Running into the below issue and the publishing enters an infinite loop of retrying same batch of messages and not recovering.
java.lang.RuntimeException: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: HTTP/2 error code: NO_ERROR
Received Goaway
session_timed_out
at com.google.pubsub.kafka.sink.CloudPubSubSinkTask.flush(CloudPubSubSinkTask.java:293) at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:192) at org.apache.kafka.connect.runtime.WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:75) at org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58) at org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
Activity
sduskis commentedon Dec 5, 2018
This is likely an obsolete issue and would not reoccur if you upgraded the client. I'm closing this assuming that the issue is fixed. If this is indeed still an issue, please reopen it.
deps: update actions/upload-artifact action to v4.1.0 (#3071)
chore(main): release 2.37.0 (#3076)
deps: update google api dependencies (#3071)
chore(main): release 2.44.0 (#3074)
test(deps): update cross product test dependencies (#3071)