Hey all, I'm trying to run some basic error-handling validation with some client code, and I'm attempting to handle an UnknownTopicOrPartitionException. To set this scenario up, I wanted to attempt fetch messages from a topic I know doesn't exist. To that end, I've got a 3-broker cluster with: * auto.create.topics.enable=false * each broker restarted after setting the above
The logs for each broker show the following after the restart: [2015-02-23 10:13:30,315] INFO Property auto.create.topics.enable is overridden to false (kafka.utils.VerifiableProperties) However, every time I try to fetch messages from the broker, I get no exception, and kafka-list-topics shows the previously non-existent topic is now created! I'm using poseidon/poseidon-cluster ruby libraries for the comms, but don't believe they should be over-riding the broker configuration in terms of topic creation. Nothing in source code suggests anything, and I don't believe the protocol allows for it anyway. We're using Kafka 0.8.0 final for all brokers. Anyone come across this issue before? /Dave
