v3.3.0

• Optimize in-memory mocked Kafka (avoid spawning too many threads)
• Support multiple brokers (with overlapping topic names) in mocked Kafka and MQTT
• Add message validation for both producer and consumer
• Add new AddInbound overloads specifying message type for a more compact configuration when using the typed deserializer
• Invoke the Kafka partition EOF callback for all connected consumers
• Ignore null or empty Kafka key in producer

See docs for details.