Venkat1188

Results 4 comments of Venkat1188

Getting an nullpointer exception on reading cloudEvent.getData(), Error on dapr sidecar {"app_id":"dpar-subscribe","instance":"dpar-subscribe-67c7f44cc4-ndpm5","level":"error","msg":"non-retriable error returned from app while processing pub/sub event fd9d23c3-1f68-4222-8e9e-7960554017c3: \u003c!doctype html\u003e\u003chtml lang="en"\u003e\u003chead\u003e\u003ctitle\u003eHTTP Status 404 – Not Found\u003c/title\u003e\u003cstyle type="text/css"\u003ebody...

public String publishMessage(String reqMessage) throws Exception { String message = "This is message : " + reqMessage; Map metadata = new HashMap(); // metadata.put(Constants.KAFKA_PARTITION_KEY, eventAuditDTO.getRequestId()); metadata.put(Constants.KAFKA_PARTITION_KEY, UUID.randomUUID().toString()); metadata.put(Metadata.TTL_IN_SECONDS, MESSAGE_TTL_IN_SECONDS); //...

Configured application to subscribe to a specific topic. This is the code, I am using for subscriptipn @Topic(name = "testingtopic", pubsubName = "messagebus") @PostMapping(path = "/testingtopic", consumes = MediaType.ALL_VALUE) public...

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