{"comment":{"url":"https://api.github.com/repos/joewitt/incubator-nifi/comments/18751668","html_url":"https://github.com/joewitt/incubator-nifi/commit/9781d49e79b4d09a58ae5b006bfe71bbfc9e03b7#commitcomment-18751668","id":18751668,"user":{"login":"joewitt","id":3057465,"avatar_url":"https://avatars.githubusercontent.com/u/3057465?v=3","gravatar_id":"","url":"https://api.github.com/users/joewitt","html_url":"https://github.com/joewitt","followers_url":"https://api.github.com/users/joewitt/followers","following_url":"https://api.github.com/users/joewitt/following{/other_user}","gists_url":"https://api.github.com/users/joewitt/gists{/gist_id}","starred_url":"https://api.github.com/users/joewitt/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/joewitt/subscriptions","organizations_url":"https://api.github.com/users/joewitt/orgs","repos_url":"https://api.github.com/users/joewitt/repos","events_url":"https://api.github.com/users/joewitt/events{/privacy}","received_events_url":"https://api.github.com/users/joewitt/received_events","type":"User","site_admin":false},"position":281,"line":192,"path":"nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-pubsub-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java","commit_id":"9781d49e79b4d09a58ae5b006bfe71bbfc9e03b7","created_at":"2016-08-23T22:44:31Z","updated_at":"2016-08-23T22:44:31Z","body":"We can never know how many other threads there are for the consumer group we're a part of.  We could know within our own processor instance on a given node but not across the cluster.  What we can do potentially is detect a consumer that has not been assigned any partitions and simply skip it.  We don't want to get rid of it because as partitions and membership changes the kafka client will rebalance.  That said, I don't believe this is an actual issue as-is."}}
{"actor":{"display_login":"joewitt"}}