simplifadmin opened a new issue #1209: URL: https://github.com/apache/camel-kafka-connector/issues/1209
Issue when using [camel-google-pubsub-kafka-connector](https://camel.apache.org/camel-kafka-connector/0.7.x/connectors/camel-google-pubsub-kafka-sink-connector.html) as sink for Strimzi kafka. I've created a KafkaConnect single-node cluster using camel kafka connect for Pubsub. That works fine. Please find the k8s files and the error msg. Any idea of resolving the google-pubsub-kafka-connector for k8s? K8s file for KafkaConnect `apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnect metadata: name: my-connect namespace: kafka annotations: # enable connect operator strimzi.io/use-connector-resources: "true" spec: replicas: 1 #version: 2.6.0 image: camel/my-connect:v1 bootstrapServers: my-cluster-kafka-bootstrap:9092 resources: requests: cpu: 250m memory: 512Mi limits: cpu: 500m memory: 1Gi jvmOptions: gcLoggingEnabled: false config: group.id: my-connect key.converter: org.apache.kafka.connect.storage.StringConverter value.converter: org.apache.kafka.connect.storage.StringConverter offset.storage.topic: my-connect-offsets config.storage.topic: my-connect-configs status.storage.topic: my-connect-status config.storage.replication.factor: 3 #n for production per n brokers offset.storage.replication.factor: 3 #per broker status.storage.replication.factor: 3 #per broker ` Issue with pubsub-kafka `kind: KafkaConnector apiVersion: kafka.strimzi.io/v1beta2 metadata: name: pubsub-kafka namespace: kafka labels: # must match connect cluster name strimzi.io/cluster: my-connect spec: tasksMax: 1 class: org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSinkConnector config: #The Google Cloud PubSub Project Id camel.sink.path.projectId: <Project Id> #The Destination Name. For the consumer this will be the subscription name, while for the producer this will be the topic name. camel.sink.path.destinationName: test-topic ` error msg from KafkaConnect container `2021-06-14 13:18:35,037 ERROR Uncaught exception in REST call to /connectors/pubsub-kafka/config (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper) [qtp977975287-18] org.apache.kafka.common.config.ConfigException: Must configure one of topics or topics.regex at org.apache.kafka.connect.runtime.SinkConnectorConfig.validate(SinkConnectorConfig.java:102) at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:352) at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$1(AbstractHerder.java:326) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834)` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
