{"action":"opened","issue":{"url":"https://api.github.com/repos/confluentinc/confluent-kafka-python/issues/149","repository_url":"https://api.github.com/repos/confluentinc/confluent-kafka-python","labels_url":"https://api.github.com/repos/confluentinc/confluent-kafka-python/issues/149/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/confluent-kafka-python/issues/149/comments","events_url":"https://api.github.com/repos/confluentinc/confluent-kafka-python/issues/149/events","html_url":"https://github.com/confluentinc/confluent-kafka-python/issues/149","id":213289759,"number":149,"title":"Problem about 'Broker version compatibility'","user":{"login":"copybash","id":2107957,"avatar_url":"https://avatars2.githubusercontent.com/u/2107957?v=3","gravatar_id":"","url":"https://api.github.com/users/copybash","html_url":"https://github.com/copybash","followers_url":"https://api.github.com/users/copybash/followers","following_url":"https://api.github.com/users/copybash/following{/other_user}","gists_url":"https://api.github.com/users/copybash/gists{/gist_id}","starred_url":"https://api.github.com/users/copybash/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/copybash/subscriptions","organizations_url":"https://api.github.com/users/copybash/orgs","repos_url":"https://api.github.com/users/copybash/repos","events_url":"https://api.github.com/users/copybash/events{/privacy}","received_events_url":"https://api.github.com/users/copybash/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2017-03-10T09:34:54Z","updated_at":"2017-03-10T09:34:54Z","closed_at":null,"body":"Some test code with kafka_2.10-0.8.2.2 \r\n\r\n```\r\n>>> import confluent_kafka\r\n>>> p = confluent_kafka.Producer({'bootstrap.servers': '192.168.0.17:9092,192.168.0.32:9092', 'api.version.request': 'false', 'broker.version.fallback': '0.8.2.2'})\r\n>>> p.produce('mediagw', 'hello world'.encode('utf-8'))\r\n>>> p.flush()\r\n0\r\n>>> c = confluent_kafka.Consumer({'bootstrap.servers': '192.168.0.17:9092,192.168.0.32:9092', 'group.id': 'group.mediagw', 'default.topic.config': {'auto.offset.reset': 'sm\r\nallest'}, 'api.version.request': 'false', 'broker.version.fallback': '0.8.2.2'})\r\n>>> c.subscribe(['mediagw'])\r\n>>> %3|1489136347.773|FAIL|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n%3|1489136347.773|ERROR|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n%3|1489136348.414|FAIL|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n%3|1489136348.414|ERROR|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n%3|1489136348.884|FAIL|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n%3|1489136348.884|ERROR|rdkafka#consumer-2| [thrd:192.168.0.19:9092/192168019]: 192.168.0.19:9092/192168019: Receive failed: Disconnected\r\n```\r\nIt seems work not well with kafka_2.10-0.8.2.2. I had try to do something metion by https://github.com/edenhill/librdkafka/wiki/Broker-version-compatibility. And I can not change the broker version in the production enviroment. What else can I do for it ?"}}
{"actor":{"display_login":"copybash"}}