kotlin-kafka icon indicating copy to clipboard operation
kotlin-kafka copied to clipboard

Can't use `sendAwait` with Kafka's MockProducer

Open felixkrull-neuland opened this issue 1 year ago • 1 comments
trafficstars

sendAwait is defined directly on KafkaProducer. This makes it impossible to use with Kafka's own MockProducer. The method should be defined on the Producer interface instead.

felixkrull-neuland avatar Jan 15 '24 16:01 felixkrull-neuland

Hey @felixkrull-neuland,

Thank you for opening this ticket, an alternative implementation has been written for producing elements that will be released soon. It is defined on top of Producer so it should fix this issue, but I will keep this open until I've released that in a next version.

You can check out the API, and implementation here. Any feedback would be greatly appreciated, https://github.com/nomisRev/kotlin-kafka/pull/156

nomisRev avatar Jan 18 '24 13:01 nomisRev