Kyle McClellan
Kyle McClellan
I'm also hitting this issue. When my application was configured incorrectly to have a bad topic, I expected to see an exception thrown. Instead, it just sat waiting on the...
This is what we use for `kafka-di`: https://github.com/kmcclellan/kafka-di/blob/main/Confluent.Kafka.DependencyInjection/ConsumerThreadingExtensions.cs The file is independent of the rest of the library so feel free to copy/paste it if you don't need the whole...
@mgravell That's interesting, I wonder what accounts for the difference. I assumed that the way the multiplexer works the commands in a transaction typically get batched and sent in a...