{"action":"closed","issue":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/442","labels_url":"https://api.github.com/repos/dpkp/kafka-python/issues/442/labels{/name}","comments_url":"https://api.github.com/repos/dpkp/kafka-python/issues/442/comments","events_url":"https://api.github.com/repos/dpkp/kafka-python/issues/442/events","html_url":"https://github.com/dpkp/kafka-python/issues/442","id":98411380,"number":442,"title":"If one topic does not exist, it will be created after produce() function called several times","user":{"login":"peichengcheng001","id":13469530,"avatar_url":"https://avatars.githubusercontent.com/u/13469530?v=3","gravatar_id":"","url":"https://api.github.com/users/peichengcheng001","html_url":"https://github.com/peichengcheng001","followers_url":"https://api.github.com/users/peichengcheng001/followers","following_url":"https://api.github.com/users/peichengcheng001/following{/other_user}","gists_url":"https://api.github.com/users/peichengcheng001/gists{/gist_id}","starred_url":"https://api.github.com/users/peichengcheng001/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/peichengcheng001/subscriptions","organizations_url":"https://api.github.com/users/peichengcheng001/orgs","repos_url":"https://api.github.com/users/peichengcheng001/repos","events_url":"https://api.github.com/users/peichengcheng001/events{/privacy}","received_events_url":"https://api.github.com/users/peichengcheng001/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2015-07-31T15:14:34Z","updated_at":"2015-12-05T01:23:21Z","closed_at":"2015-12-05T01:23:21Z","body":"I am trying to produce one message \"0---testing---\" to topic \"test9\", which did not exist at beginning. It threw out Exception. So I made my program to produce again and again. It threw out Exception again and again. Finally, it was created. Following are some printout (See the Exception and the client info after \"---Info of Kafka Client and Kafka Producer---\"). Also, notice the highlight part in the attached picture.\r\n\r\n![kafka-topic-issue](https://cloud.githubusercontent.com/assets/13469530/9010516/52385c76-3775-11e5-8f41-0b1581b046a1.png)\r\n\r\n\r\n----------- 0 --------------\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\nException while trying to produce msg: TopicMetadata(topic='test9', error=5, partitions=[])\r\nMessage: 0---testing---\r\n---Info of Kafka Client and Kafka Producer---\r\n*Kafka Client*\r\nclient_id: kafka-python\r\ncorrelation_id: 14\r\nhosts: [('localhost', 9092)]\r\nbrokers: {0: BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092)}\r\ntimeout: 120\r\nconns: {('localhost', 9092): <KafkaConnection host=localhost port=9092>, (u'cyclops-9803', 9092): <KafkaConnection host=cyclops-9803 port=9092>}\r\ntopics_to_brokers: {TopicAndPartition(topic='test1', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test6', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test2', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test9', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test7', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test3', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test4', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092), TopicAndPartition(topic='test5', partition=0): BrokerMetadata(nodeId=0, host='cyclops-9803', port=9092)}\r\n"}}