Kafka pubsub data subscription not working.

[amuthapriya4]

Ask your question here

Used below code to Subscribing kafka message. But message not received. Dapr-SDK 1.7 is used. @Topic(name = "dapr_pubsub_input", pubsubName = "kafka-pubsub") public void receiveKafkaData(ConsumerRecord<String, byte[]> record) {
log.info("Received message from topic1 : "+record.toString()); } Also Rest controller way it's working. But this endpoint is exposed to other sources also. @PostMapping("/kafka-pubsub") public void kafkaSubscribeMessage(@RequestBody HashMap<Object,Object> message) { log.info("Message Subscribed from kafka: "+message.toString()); }