如何使用SpringBoot测试EmbeddedKafka

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

@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka(topics = "testTopic", partitions = 1)
public class KafkaTest {
    // 测试代码
}

@Autowired
private EmbeddedKafkaBroker embeddedKafkaBroker;

@Test
public void testKafka() {
    Map<String, Object> producerProps = KafkaTestUtils.producerProps(embeddedKafkaBroker);
    ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(producerProps);
    KafkaTemplate<String, String> kafkaTemplate = new KafkaTemplate<>(producerFactory);
    
    // 使用kafkaTemplate发送和接收消息进行测试
}

Map<String, Object> consumerProps = KafkaTestUtils.consumerProps("testGroup", "false", embeddedKafkaBroker);
ConsumerFactory<String, String> consumerFactory = new DefaultKafkaConsumerFactory<>(consumerProps);
Consumer<String, String> consumer = consumerFactory.createConsumer();
embeddedKafkaBroker.consumeFromAllEmbeddedTopics(consumer);

ConsumerRecords<String, String> consumerRecords = KafkaTestUtils.getRecords(consumer);
// 处理消费到的消息进行验证和断言