-
Notifications
You must be signed in to change notification settings - Fork 93
Description
Hi Basant,
When any exception occur in processPayment() next time onwards it is not consuming from the topic and throwing following exception,so how can we overcome that?
i think on exception it unsubscribe from the channel,any help will be appriciated.
Caused by: org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'application.paymentProcessor-in-0'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=byte[237], headers={kafka_offset=2, scst_nativeHeadersPresent=true, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6fca547c, deliveryAttempt=3, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, contentType=application/json, kafka_receivedTopic=order-event, kafka_receivedTimestamp=1635921694833, kafka_groupId=anonymous.e838a4ed-ab11-4992-ad47-0c4d0111d4d0}]
I just want for next time onwards it should be listen from the topic when a new event is published;