XD-2502 Add embedded Kafka server support

- changed KafkaTestSupport to create and shutdown a standalone Kafka server (and associated ZK instance)
- updated the test to use the embedded broker
XD-2490 - Update to use Reactor 2.0 snapshots
XD-2475 MessageBus Producer Batching

JIRA: https://jira.spring.io/browse/XD-2475

Rabbit: Use a `BatchingRabbitTemplate` if batching is enabled.
Kafka: Set properties

Tested with:

    xd:>stream create foo --definition "time | log"
    xd:>stream deploy --name foo --properties "module.time.producer.batchingEnabled=true,module.time.producer.batchSize=6"

Observe messages appear in log in batches of 6.

    xd:>stream undeploy foo

Observe partial batch is flushed.

(Also added RabbitMessageBus test).
XD-2475 Polishing

Bump SI to 4.1.1.RELEASE
Fix kafka bus property names in bus.xml