Incorrect order of produced messages in transaction

[PoteRii]

Hello,
Consider a scenario (slightly modified code from sample Sample.Kafka.PostgreSql project):

Sometimes we are seeing that produced messages are in incorrect order, meaning that message with less DateTime.Now value has higher offset

this happens not always, but quite frequently.
In our scenario even adding await Task.Delay(500); between two messages does not help.

Could it be because there is no await in Flush method? In that case possible solution might be new FlushAsync function

[yang-xiaodong]

Does using PublishAsync have the same issue?

[PoteRii]

Yes. In our real scenario we use PublishAsync.

[PoteRii]

I have tested by adding FlushAsync function and doing await FlushAsync in CommitAsync and it seems to work

[PoteRii]

should I make a PR with new FlushAsync? At least it won`t break anything

[yang-xiaodong]

should I make a PR with new FlushAsync? At least it won`t break anything

Sure, Thanks

[PoteRii]

#1629