Hi You can also look at how some of the kamelts for kafka (for different kind of security SSL, Scram, ...) https://github.com/apache/camel-kamelets/tree/main/kamelets
And take a read at their security docs https://kafka.apache.org/documentation/#security On Fri, Jul 28, 2023 at 5:55 PM Mark Nuttall <mknutt...@gmail.com> wrote: > Yeah, typically most camel config is in properties. It looks like all the > config is on the URI and i dont see any security settings. > It is very highly likely what Claus said. > Or, your service does not have the correct access. > > I have used Kafka with AWS MSK and Confluent and have seen this error > before. Typically it is security related. > Kafka is really bad about not giving you the correct info to figure out the > issue. > > > On Fri, Jul 28, 2023 at 9:35 AM Claus Ibsen <claus.ib...@gmail.com> wrote: > > > Hi > > > > There is no so much error details. Kafka is complex messaging system. And > > specially product systems are setup to be secured out of the box, and > then > > you likely need to configure Camel Kafka for secured connection. > > Also try to google that error message bits you have and see what you can > > find on the internet. > > > > > > > > On Fri, Jul 28, 2023 at 3:03 PM Aditya Kavathekar < > > kavathekar.adi...@gmail.com> wrote: > > > > > Hi everyone I am trying to consume from a kafka topic and simply print > > the > > > body in logs. the code works when I try to connect to a local kafka > topic > > > on localhost but I get error when I try to connect to dev1 kafka topic. > > > > > > In the logs I see after my code subscribes to the topic then I get > these > > > errors Node -1 disconnected Canceled in-flight API_VERSIONS request > with > > > correlation id 21 due to node -1 being disconnected (elapsed time since > > > creation: 131ms ...) Bootstrap broker (id: -1 rack: null) disconnected > > > > > > this is my code: > > > > > > > > > from("kafka:mytopic?brokers=xxxx:9094&groupId=xxxx&autoOffsetReset=latest&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&specificAvroReader=true&valueDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer&schemaRegistryURL=xxxx:8081") > > > .log("Message is : ${body}"); > > > > > > the xxxx is a valid url which is confidential. the camel version is > > 3.2.0. > > > > > > I am getting the same error when I try to connect to kafka through core > > > java as well. Kindly help me > > > > > > > > > -- > > Claus Ibsen > > ----------------- > > @davsclaus > > Camel in Action 2: https://www.manning.com/ibsen2 > > > -- Claus Ibsen ----------------- @davsclaus Camel in Action 2: https://www.manning.com/ibsen2
