Venkat1188

Pubsub kafka component

2

I have a few open questions dapr kafka pubsub component, 1)In pub/sub in what situation Dapr retries sending a message again.. I read in the documentation that the delivery is...

Dapr pubsub subscriber issue

11

@Topic(name = "testingtopic", pubsubName = "messagebus") @PostMapping(path = "/testingtopic") public Mono handleMessage(@RequestBody(required = false) CloudEvent cloudEvent) { return Mono.fromRunnable( () -> { try { System.out.println("Subscriber got: " + cloudEvent.getData()); System.out.println("Subscriber...