Re: Why do I get an IllegalStateException when accessing record metadata?

2019-01-06 Thread Peter Levart
Hi, I suggest the following: If you attach a new Processor/Transformer/ValueTransformer to your topology using a corresponding supplier, you need to make sure that the supplier returns a new instance each time get() is called. If you return the same object, a single Processor/Transformer/Valu

message ordering within a transaction

2019-01-06 Thread Mark Horton
I was curious if re-ordering is possible within a transaction? Let's say a KafkaProducer sends 1000 messages to a single partition within a single transaction, and the total size causes more than 1 batch to be sent to the broker. If, for some reason, one of the batches is lost and resent, is it pos