Что лучший способ состоит в том, чтобы начать с NHibernate? [закрытый]

Добавьте зависимость

    <dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka-test</artifactId>
        <scope>test</scope>
    </dependency>

Создайте нечто похожее в своем тесте

    public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(2, true, 2, "messages");

, и вы готовы его использовать - неважно, функциональный или модульный тест. ]

Вы можете указать количество брокеров, разделов и т. Д.

Вы можете настроить производителя и потребителя так же, как и в противном случае.