Konstantin Scheumann

@digitalsmithy Thanks for the comment on this use case. I'll look into that.

Hi @ilyashtrikul, thanks for the PR! I also see you fixed the test :) The headers field is definitely useful. But you can achieve the same result if you supply...

@ilyashtrikul I'm not sure what you mean with own bundle with configuration. You just specify the service ID of your Serializer in the Messenger config ```yaml consumer: dsn: '%env(KAFKA_URL)%' serializer:...

@ilyashtrikul Are you using Avro? Avro includes the qualified name, that you can use in your serializer to determine the output class

@gayansanjeewa May I ask, how the payload is serialized? it it plain json?

@gayansanjeewa Overriding these properties doesn't really seem like an ideal solution. If you do it this way, you'll need to configure different transports for each topic you consume. I'd rather...

Hi @rdotter! Great to see your PR :) I know we talked about this feature a while ago, and your case definitely makes sense. Still, I'm a bit unsure about...

It really depends on your implementation. In your project you're free to write a Middleware, that catches the Exception and logs it. Just keep in mind that some systems may...

@rdotter That's right. Maybe we should ack failed messages. I'm not sure how many people will want to use a kafka topic as an eventstore though. (single partition) What do...

👍 LGT