org.apache.kafka.connect.errors.ConnectException

The subscription REDACTED does not exist for the projectREDACTED


Solutions on the web50

Solution icon of github
via GitHub by jare19
, 2 months ago
The subscription REDACTED does not exist for the projectREDACTED

Solution icon of github
java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist

Solution icon of github
Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. Error code: 0; SQLSTATE: 08S01.

Solution icon of googlegroups
Could not look up partition metadata for offset backing store topic in allotted period. This could indicate a connectivity issue, unavailable topic partitions, or if this is your first use of the topic it may have taken too long to create.

Solution icon of github
via GitHub by chaitras
, 2 months ago
Cannot ALTER to add missing field SinkRecordField{schema=Schema{INT64}, name='ID', isPrimaryKey=true}, as it is not optional and does not have a default value

Solution icon of github
via GitHub by charliwardbd
, 6 months ago
Cannot ALTER to add missing field SinkRecordField{schema=Schema{FLOAT32}, name='price', isPrimaryKey=false}, as it is not optional and does not have a default value

Solution icon of github
com.amazonaws.SdkClientException: Unable to load AWS credentials from any provider in the chain

Solution icon of stackoverflow
via Stack Overflow by clay
, 1 week ago
null (ARRAY) type doesn't have a mapping to the SQL database column type

Solution icon of github
Invalid type for incrementing column: BYTES

Solution icon of googlegroups
via Google Groups by Cherupally Bhargav, 1 month ago
Invalid type for incrementing column: BYTES

Stack trace

  • org.apache.kafka.connect.errors.ConnectException: The subscription REDACTED does not exist for the projectREDACTED at com.google.pubsub.kafka.source.CloudPubSubSourceConnector.verifySubscription(CloudPubSubSourceConnector.java:201) at com.google.pubsub.kafka.source.CloudPubSubSourceConnector.start(CloudPubSubSourceConnector.java:116) at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:100) at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:125) at org.apache.kafka.connect.runtime.WorkerConnector.transitionTo(WorkerConnector.java:182) at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:183) at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.startConnector(StandaloneHerder.java:251) at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:177) at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:93)

Write tip

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.