3 Replies Latest reply on Aug 31, 2021 4:40 AM by Kishor Baindoor

    Not able to produce/consume messages from Confluent Cloud

    Kishor Baindoor New Member

      I am trying explore application integration capabilities in producing/consuming messages Confluent Cloud. I also need to use schema registry and Avro serialization.

       

      I created appConnection for Confluent Cloud with below configuration. When I test, I see the result as Passed. (I don't understand what does this mean. It looks like, it only checks if it is able to ping Kafka server. Even with wrong port and JassConfig it shows test result as Passed.)

       

      Run On: Local secure agent installed on Windows Laptop. From this laptop, I am able to produce/consume messages from Confluent using ccloud cli.

      Kafka Host:: pkc-ldvmy.centralus.azure.confluent.cloud

      Kafka Port:9092

      Use SSL: No

      Use SASL: Yes

      SASL Mechanism:: PLAIN

      Jaas Config: org.apache.kafka.common.security.plain.PlainLoginModule required username="APIKey" password="APISecret"

       

      Event Target:

      Topic: KafkaDemo

      GroupId : 1

      Content Format: Text

       

      I have created a process to produce message to Kafka Topic. When I run the job, I get below error. I have attached the process code.

       

      Error:

      Process Input:KafkaInput

      • Error Message:HTTP method: POST
      • Reason:{"error":{"code":500,"detail":{"reason":"Error executing cloud process [hostRuntimeCall] with id [1057]: No consumers available on endpoint: direct:\/\/AppConnection-Kafka_KafkaProducer. Exchange[]"},"message":"Error executing cloud process [hostRuntimeCall] with id [1057]: No consumers available on endpoint: direct:\/\/AppConnection-Kafka_KafkaProducer. Exchange[]"}}