spring-boot-test - 如何修复无法找到 meta.properties 的嵌入式 kafka 错误

Question

我正在尝试对使用 kafka、kafka-streams 和 cassandra 的应用程序进行集成测试。但是当我尝试设置测试类时，我有两个错误:
错误 [main] BrokerMetadataCheckpoint:无法读取目录下的 meta.properties 文件
ERROR [main] KafkaServer: 无法读取日志目录下的 meta.properties

我正在使用 spring-boot-starter 2.1.2、spring-boot-starter-test 2.1.2、spring-kafka 2.2.0、spring-kafka-test 2.2.0、apache.kafka-streams 2.1.0

试图更改 logs.dir 和 logs.dirs 参数。
使用 @EnableKafka @EnableKafkaStreams

@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka(partitions = 3, controlledShutdown = false, count = 1, topics = {"zc.deviceposition"}, brokerProperties = {"listeners=PLAINTEXT://localhost:9092", "port=9092", "log.dir=/home/name/logs"})
@EmbeddedCassandra(timeout = 60000)
@CassandraDataSet(value = {"bootstrap_test.cql"}, keyspace = "statistics")
@ActiveProfiles("test")
@DirtiesContext
public class CassandraTripsAggregatorProcessorSupplierIntegrationTest {
  @Test
  public void someTest() {System.out.println("hello world");}
}

我希望使用嵌入式 kafka 运行上下文，但现在我收到一个错误，即 meta.properties 不存在

Answer 1

我检查了 kafka 源代码，看看到底发生了什么:

抛出错误信息 in this class .
在 kafka 服务器启动期间 meta.properties如果文件不存在，则读取并创建文件 ( see here )。

所以我认为没有什么可以做的，因为它实际上不是一个错误，但可能是 kafka 代码中的日志级别不正确。