@Test
void sendTest() {

    // send a message to the kafka bus
    this.producer.send("TST-01; 220.1; 220.2; 220.3; 5.1; 5.2; 5.3; 7.1; 7.2; 7.3;");
    // consume the message with embeddedKafka
    final Map<String, Object> consumerProps = KafkaTestUtils.consumerProps("testGroup", "true", this.embeddedKafka);
    consumerProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
    final ConsumerFactory<String, GridMeasurementPublishedEvent> consumerFactory = new DefaultKafkaConsumerFactory<>(
            consumerProps, new StringDeserializer(), new GridMeasurementPublishedEventDeserializer());
    final Consumer<String, GridMeasurementPublishedEvent> consumer = consumerFactory.createConsumer();
    this.embeddedKafka.consumeFromAnEmbeddedTopic(consumer, this.topic);
    final ConsumerRecord<String, GridMeasurementPublishedEvent> received = KafkaTestUtils.getSingleRecord(consumer,
            this.topic);
    // check the consumed message
    assertThat(received).has(value(this.message));
}