Can't fetch partition metadata from KafkaServer

I’m using this version of kafka: org.apache.kafka kafka_2.9.2 0.8.1.1 I’m using kafka.server.KafkaServer in memory for some integration tests. I start KafkaServer and use AdminUtils.createTopic(ZkClient, String, Integer, Integer, Properties) to create a Topic. I then use the foll

SimpleConsumer not fetching messages

I’ve got a simple consumer. According to GetOffsetShell my offset is 209418. But the SimpleConsumer doesn’t get any messages past offset 123146. It just won’t pull down any messages after that offset. If I send more messages onto the topic it still won’t pull them down. Though the offset does in