assertion failed: Partition [topic1, 0] metadata not propagated after timeout

java.util.concurrent.TimeoutException: assertion failed: Partition [topic1, 0] metadata not propagated after timeout
	at org.apache.spark.streaming.kafka010.JavaDirectKafkaStreamSuite.createTopicAndSendData(JavaDirectKafkaStreamSuite.java:176)
	at org.apache.spark.streaming.kafka010.JavaDirectKafkaStreamSuite.testKafkaStream(JavaDirectKafkaStreamSuite.java:74)