Ozan Gunalp

In the long run, it is no longer recommended to continue using custom message types such as `KafkaRecordBatch`, `KafkaRecord` etc. to consume messages. I am preparing a documentation change to...

This has been addressed in https://smallrye.io/smallrye-reactive-messaging/latest/concepts/model/#messages-vs-payloads

Thanks! The issue here is the change to the `PricincipalExtractor` effectively pulls `json-path` and transitively `json-smart`, whereas before only json related library required by the `kafka-oauth-client` was `jackson-databind`. I just...

Is it possible that processing of some records takes more than 60s? Therefore setting 500s to unprocessed max age takes you to the safe side of that check?

Closed by #1836

@cescoffier I am willing to take this in for 3.23. Could you take a look ?

Thanks for this. There is now a connector contribution guide if it may help you: https://smallrye.io/smallrye-reactive-messaging/4.11.0/concepts/contributing-connectors/

Closed by #2002

Closing this as this is easily achievable now with the Mutiny API: https://smallrye.io/smallrye-mutiny/2.5.1/guides/reactive-to-imperative/#iterating-over-multis-items One can inject a channel as Multi and subscribe to it with a blocking iterator: ```java @Inject...

Yes, probably your messages are not acknowledged properly, so not cleared from tracked messages.