CODEWITHSUNDEEP
spring-kafka
Angel
Angel

Reputation: 21

Change zookeeper log directory in Embedded Kafka

I am setting up Embedded-Kafka for JUnit test in my application which is using spring Kafka. What is the location/property to set for zookeeper log directory. When using Embedded-Kafka, I don't have file named server.properties or zookeeper.properties By Default, it creates log files in temp folder on Windows, but my temp windows is restrictive so I get an exception

I was able to specify the Kafka log directory by using following 

@EmbeddedKafka(brokerProperties = { "log.dirs=../kafka-logs/" })

For broker/zookeeper properties I tried -

 static {
  props.setProperty("java.io.tmpdir", "../kafka-logs/");
}

Upvotes: 2

Views: 3375

Answers (1)

Gary Russell
Gary Russell

Reputation: 174664

Changing java.io.tmpdir works fine for me.

../kafka/kafka-1090602028141584277

(../kafka must exist already).

Perhaps your static block is invoked after the EmbeddedZookeeper is created?

Upvotes: 2

Related Questions