v3.1.0

• Add new ways to configure headers and kafka key
• New callbacks for Kafka log events
• Improve consumer status tracking introducing ConsumerStatus.Ready
• Try to automatically recover from Kafka maximum poll interval exceed errors
• Improve Kafka static partition assignment with resolver function and fetching the available partitions
• Upgrade to Confluent.Kafka 1.7.0
• Upgrade to MQTTnet 3.0.15
• Prevent possible race condition causing messages to be skipped when a RetryPolicy kicks in for messages from multiple Kafka partitions simultaneously
• Prevent ObjectDisposedException to be thrown when Kafka events (e.g. statistics) are fired during the application shutdown
• Prevent ObjectDisposedException to be thrown when Consumer.Dispose is called multiple times
• Properly clear the trace context (Activity) when reconnecting the consumer to prevent the newly started consume loop to be tracked under the current message traceId
• Fix wrong prefix in MQTT log event names

See docs for details.