lburgazzoli opened a new issue, #5295:
URL: https://github.com/apache/camel-k/issues/5295
### What happened?
I have a pipe to move data from a kafka topic to a vector database:
```yaml
apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
annotations:
trait.camel.apache.org/container.image:
quay.io/megacamelus/assistant-ingestion-sink:latest
trait.camel.apache.org/dependencies.enabled: "false"
trait.camel.apache.org/jvm.enabled: "false"
trait.camel.apache.org/kamelets.enabled: "false"
name: camel-ai-ingestion-siknk
namespace: camel-ai
spec:
sink:
properties:
collection: cai
qdrantHost: camel-ai
qdrantPort: "6334"
ref:
apiVersion: camel.apache.org/v1
kind: Kamelet
name: qdrant-upsert-sink
source:
ref:
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
name: camel-ai-ingestion
steps:
- properties:
embeddingId: camel-ai-ingestion-siknk
ref:
apiVersion: camel.apache.org/v1
kind: Kamelet
name: langchain-embeddings-action
```
And the a `Kafka` resource as follow:
```yaml
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: camel-ai-kafka
spec:
entityOperator:
topicOperator: {}
userOperator: {}
kafka:
config:
default.replication.factor: 3
inter.broker.protocol.version: "3.6"
min.insync.replicas: 2
offsets.topic.replication.factor: 3
transaction.state.log.min.isr: 2
transaction.state.log.replication.factor: 3
listeners:
- name: plain
port: 9092
tls: false
type: internal
- name: tls
port: 9093
tls: true
type: internal
replicas: 3
storage:
deleteClaim: true
size: 10Gi
type: persistent-claim
version: 3.6.0
zookeeper:
replicas: 3
storage:
deleteClaim: true
size: 5Gi
type: persistent-claim
status:
clusterId: cRS2lQFkRwGaDeXtT90rWw
conditions:
- lastTransitionTime: "2024-03-27T08:37:54.609806285Z"
status: "True"
type: Ready
kafkaVersion: 3.6.0
listeners:
- addresses:
- host: camel-ai-kafka-kafka-bootstrap.camel-ai.svc
port: 9092
bootstrapServers: camel-ai-kafka-kafka-bootstrap.camel-ai.svc:9092
name: plain
- addresses:
- host: camel-ai-kafka-kafka-bootstrap.camel-ai.svc
port: 9093
bootstrapServers: camel-ai-kafka-kafka-bootstrap.camel-ai.svc:9093
```
Then the pipe reports the following error:
```
Status:
Conditions:
Last Transition Time: 2024-03-27T12:31:56Z
Last Update Time: 2024-03-27T12:31:56Z
Message: could not determine source URI: cluster
"camel-ai-kafka" has no listeners of type "plain"
Reason: Couldn't create an Integration custom resource
Status: False
Type: IntegrationError
```
### Steps to reproduce
_No response_
### Relevant log output
_No response_
### Camel K version
2.2.0
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
