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

poll() question

2019-02-04 Thread Mark Horton
This is a theoretical question. I have not seen this behavior but wanted to know if it was possible. If consumer.poll() returns EMPTY, does that always mean no records are currently available? In other words, let's say there are some records in a partition. Could poll() return EMPTY if there was a