Is your feature request related to a problem? Please describe.
As far as i understand the documentation - currently if i throw an exception in request handler it will create DLQ entry for rabbitmq, but for kafka it will just ack message. This basically mean that there are completely different behavior between providers and it's hard to change between providers while keeping handler logic the same.
Describe the solution you'd like
Kafka does not have DLQ as a concept, but Brighter could just simulate that. So if anything in handler fails - the message and error details can be passed to another topic with specified name.
Is that something you see useful?
Is your feature request related to a problem? Please describe.
As far as i understand the documentation - currently if i throw an exception in request handler it will create DLQ entry for rabbitmq, but for kafka it will just ack message. This basically mean that there are completely different behavior between providers and it's hard to change between providers while keeping handler logic the same.
Describe the solution you'd like
Kafka does not have DLQ as a concept, but Brighter could just simulate that. So if anything in handler fails - the message and error details can be passed to another topic with specified name.
Is that something you see useful?