{"action":"created","issue":{"url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/150","repository_url":"https://api.github.com/repos/confluentinc/confluent-kafka-go","labels_url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/150/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/150/comments","events_url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/150/events","html_url":"https://github.com/confluentinc/confluent-kafka-go/issues/150","id":300507280,"node_id":"MDU6SXNzdWUzMDA1MDcyODA=","number":150,"title":"Consumer fails to start if one of the Topics mentioned is missing","user":{"login":"SowmyaVikram","id":12987218,"node_id":"MDQ6VXNlcjEyOTg3MjE4","avatar_url":"https://avatars0.githubusercontent.com/u/12987218?v=4","gravatar_id":"","url":"https://api.github.com/users/SowmyaVikram","html_url":"https://github.com/SowmyaVikram","followers_url":"https://api.github.com/users/SowmyaVikram/followers","following_url":"https://api.github.com/users/SowmyaVikram/following{/other_user}","gists_url":"https://api.github.com/users/SowmyaVikram/gists{/gist_id}","starred_url":"https://api.github.com/users/SowmyaVikram/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/SowmyaVikram/subscriptions","organizations_url":"https://api.github.com/users/SowmyaVikram/orgs","repos_url":"https://api.github.com/users/SowmyaVikram/repos","events_url":"https://api.github.com/users/SowmyaVikram/events{/privacy}","received_events_url":"https://api.github.com/users/SowmyaVikram/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":4,"created_at":"2018-02-27T06:21:50Z","updated_at":"2018-08-07T10:38:38Z","closed_at":null,"author_association":"NONE","body":"Description\r\n===========\r\nI am using ccloud Kafka. We need to create a list of TOPICs on CCLOUD prior to consuming the same.\r\nI am passing a list of topics to consume on the confluent consumer if one of the topics mentioned is not created, the consumer never starts and does not even throw an error.\r\n\r\nHow to reproduce\r\n================\r\n\r\n1. Use ccloud\r\n2. Create topic TEST on ccloud\r\n3. Try starting a confluent Kafka consumer for Topic TEST and TESTNOTTHERE \r\n4. Consumer appears that it has started but it hasnt. It neither throws an error or complain about missing topic\r\n\r\nChecklist\r\n=========\r\nPlease provide the following information:\r\n\r\n - [ ] confluent-kafka-go and librdkafka version (`LibraryVersion()`):\r\n - [ ] Apache Kafka broker version:\r\n - [ ] Client configuration: `ConfigMap{...}`\r\nc, err := kafka.NewConsumer(&kafka.ConfigMap{\r\n\t\t\"bootstrap.servers\":               config.BrokerList,\r\n\t\t\"group.id\":                        config.Group,\r\n\t\t\"session.timeout.ms\":              20000,\r\n\t\t\"go.events.channel.enable\":        true,\r\n\t\t\"go.application.rebalance.enable\": true,\r\n\t\t\"default.topic.config\":            kafka.ConfigMap{\"auto.offset.reset\": initialOffset},\r\n\t\t\"socket.keepalive.enable\":         true,\r\n\t\t\"log.connection.close\":            false,\r\n\t\t\"api.version.fallback.ms\":         0,\r\n\t\t\"broker.version.fallback\":         \"0.10.0\",\r\n\t\t\"security.protocol\":               sslConfig.SecurityProtocol, \"sasl.mechanisms\": sslConfig.SASLMechanism, \"sasl.username\": sslConfig.UserName, \"sasl.password\": sslConfig.Password, \"ssl.ca.location\": sslConfig.CertLocation, \"api.version.request\": true})\r\n\r\n - [ ] Operating system:\r\n - [ ] Provide client logs (with `\"debug\": \"..\"` as necessary)\r\n - [ ] Provide broker log excerpts\r\n - [ ] Critical issue\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/comments/411013523","html_url":"https://github.com/confluentinc/confluent-kafka-go/issues/150#issuecomment-411013523","issue_url":"https://api.github.com/repos/confluentinc/confluent-kafka-go/issues/150","id":411013523,"node_id":"MDEyOklzc3VlQ29tbWVudDQxMTAxMzUyMw==","user":{"login":"edenhill","id":524990,"node_id":"MDQ6VXNlcjUyNDk5MA==","avatar_url":"https://avatars0.githubusercontent.com/u/524990?v=4","gravatar_id":"","url":"https://api.github.com/users/edenhill","html_url":"https://github.com/edenhill","followers_url":"https://api.github.com/users/edenhill/followers","following_url":"https://api.github.com/users/edenhill/following{/other_user}","gists_url":"https://api.github.com/users/edenhill/gists{/gist_id}","starred_url":"https://api.github.com/users/edenhill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/edenhill/subscriptions","organizations_url":"https://api.github.com/users/edenhill/orgs","repos_url":"https://api.github.com/users/edenhill/repos","events_url":"https://api.github.com/users/edenhill/events{/privacy}","received_events_url":"https://api.github.com/users/edenhill/received_events","type":"User","site_admin":false},"created_at":"2018-08-07T10:38:38Z","updated_at":"2018-08-07T10:38:38Z","author_association":"MEMBER","body":"> The consumer will defer joining the group until metadata is present for every subscribed topic.\r\n\r\nMinor correct: it will defer until at least one topic matches the subscription."}}
{"actor":{"display_login":"edenhill"}}