{"action":"created","issue":{"url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/99","repository_url":"https://api.github.com/repos/fluent/fluent-plugin-kafka","labels_url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/99/labels{/name}","comments_url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/99/comments","events_url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/99/events","html_url":"https://github.com/fluent/fluent-plugin-kafka/issues/99","id":189563904,"number":99,"title":"kafka consumer group can't work ","user":{"login":"jaywayjayway","id":5195170,"avatar_url":"https://avatars.githubusercontent.com/u/5195170?v=3","gravatar_id":"","url":"https://api.github.com/users/jaywayjayway","html_url":"https://github.com/jaywayjayway","followers_url":"https://api.github.com/users/jaywayjayway/followers","following_url":"https://api.github.com/users/jaywayjayway/following{/other_user}","gists_url":"https://api.github.com/users/jaywayjayway/gists{/gist_id}","starred_url":"https://api.github.com/users/jaywayjayway/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jaywayjayway/subscriptions","organizations_url":"https://api.github.com/users/jaywayjayway/orgs","repos_url":"https://api.github.com/users/jaywayjayway/repos","events_url":"https://api.github.com/users/jaywayjayway/events{/privacy}","received_events_url":"https://api.github.com/users/jaywayjayway/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2016-11-16T02:15:46Z","updated_at":"2016-11-16T06:07:14Z","closed_at":null,"body":"HI,I use  input kafka plugin with consumer group. But it doesn't work .\r\n\r\nkafka  input plugin  conf:\r\n```\r\n<source>\r\n  @type kafka_group\r\n  brokers es1.quakecloud:9092,es2.quakecloud.cc:9092\r\n  topics   test\r\n  consumer_group access-group\r\n  format  json\r\n  add_prefix access\r\n</source>\r\n```\r\nI check  out in Kafka  ， But can't  find  the  consumer group \r\n```\r\n[root@es2 td-agent]# kafka-consumer-groups.sh  --list  --zookeeper  localhost:2181\r\nconsole-consumer-78528\r\nconsole-consumer-78813\r\n```\r\nWhat can I do  for it ?"},"comment":{"url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/comments/260862486","html_url":"https://github.com/fluent/fluent-plugin-kafka/issues/99#issuecomment-260862486","issue_url":"https://api.github.com/repos/fluent/fluent-plugin-kafka/issues/99","id":260862486,"user":{"login":"repeatedly","id":16928,"avatar_url":"https://avatars.githubusercontent.com/u/16928?v=3","gravatar_id":"","url":"https://api.github.com/users/repeatedly","html_url":"https://github.com/repeatedly","followers_url":"https://api.github.com/users/repeatedly/followers","following_url":"https://api.github.com/users/repeatedly/following{/other_user}","gists_url":"https://api.github.com/users/repeatedly/gists{/gist_id}","starred_url":"https://api.github.com/users/repeatedly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/repeatedly/subscriptions","organizations_url":"https://api.github.com/users/repeatedly/orgs","repos_url":"https://api.github.com/users/repeatedly/repos","events_url":"https://api.github.com/users/repeatedly/events{/privacy}","received_events_url":"https://api.github.com/users/repeatedly/received_events","type":"User","site_admin":false},"created_at":"2016-11-16T06:07:14Z","updated_at":"2016-11-16T06:07:14Z","body":"Hmm... I tested in_kafka_group with local `kafka_2.11-0.9.0.1` and it worked.\r\n\r\n```\r\n% RUBYLIB=~/dev/fluentd/fluentd/lib:~/dev/fluentd/fluent-plugin-kafka/lib ~/dev/fluentd/fluentd/bin/fluentd -c kafka_group.conf \r\n2016-11-16 15:04:21 +0900 [info]: reading config file path=\"kafka_group.conf\"\r\n2016-11-16 15:04:21 +0900 [info]: starting fluentd-0.14.9\r\n2016-11-16 15:04:21 +0900 [info]: spawn command to main: /Users/repeatedly/.rbenv/versions/2.3.1/bin/ruby -Eascii-8bit:ascii-8bit /Users/repeatedly/dev/fluentd/fluentd/bin/fluentd -c kafka_group.conf --under-supervisor\r\n2016-11-16 15:04:21 +0900 [info]: reading config file path=\"kafka_group.conf\"\r\n2016-11-16 15:04:21 +0900 [info]: starting fluentd-0.14.9 without supervision\r\n[snip]\r\n2016-11-16 15:04:21 +0900 [info]: adding source type=\"kafka_group\"\r\n2016-11-16 15:04:21 +0900 [info]: Will watch for topics test at brokers localhost:9092 and 'access-group' group\r\n2016-11-16 15:04:21 +0900 [info]: using configuration file: <ROOT>\r\n  <source>\r\n    @type kafka_group\r\n    topics \"test\"\r\n    consumer_group \"access-group\"\r\n    format \"json\"\r\n    add_prefix \"access\"\r\n  </source>\r\n</ROOT>\r\n```\r\n\r\n```\r\n% bin/kafka-consumer-groups.sh --list --new-consumer --bootstrap-server localhost:9092\r\naccess-group\r\n```"}}
{"actor":{"display_login":"repeatedly"}}