{"action":"created","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/41","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/41/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/41/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/41/events","html_url":"https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/41","id":177006454,"number":41,"title":"Auto partition assignment issue when there are more consumers than there are partitions","user":{"login":"sabbyanandan","id":1562654,"avatar_url":"https://avatars.githubusercontent.com/u/1562654?v=3","gravatar_id":"","url":"https://api.github.com/users/sabbyanandan","html_url":"https://github.com/sabbyanandan","followers_url":"https://api.github.com/users/sabbyanandan/followers","following_url":"https://api.github.com/users/sabbyanandan/following{/other_user}","gists_url":"https://api.github.com/users/sabbyanandan/gists{/gist_id}","starred_url":"https://api.github.com/users/sabbyanandan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sabbyanandan/subscriptions","organizations_url":"https://api.github.com/users/sabbyanandan/orgs","repos_url":"https://api.github.com/users/sabbyanandan/repos","events_url":"https://api.github.com/users/sabbyanandan/events{/privacy}","received_events_url":"https://api.github.com/users/sabbyanandan/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/labels/bug","name":"bug","color":"ee0701"},{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/labels/in%20progress","name":"in progress","color":"1d76db"}],"state":"open","locked":false,"assignee":{"login":"sobychacko","id":827682,"avatar_url":"https://avatars.githubusercontent.com/u/827682?v=3","gravatar_id":"","url":"https://api.github.com/users/sobychacko","html_url":"https://github.com/sobychacko","followers_url":"https://api.github.com/users/sobychacko/followers","following_url":"https://api.github.com/users/sobychacko/following{/other_user}","gists_url":"https://api.github.com/users/sobychacko/gists{/gist_id}","starred_url":"https://api.github.com/users/sobychacko/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sobychacko/subscriptions","organizations_url":"https://api.github.com/users/sobychacko/orgs","repos_url":"https://api.github.com/users/sobychacko/repos","events_url":"https://api.github.com/users/sobychacko/events{/privacy}","received_events_url":"https://api.github.com/users/sobychacko/received_events","type":"User","site_admin":false},"assignees":[{"login":"sobychacko","id":827682,"avatar_url":"https://avatars.githubusercontent.com/u/827682?v=3","gravatar_id":"","url":"https://api.github.com/users/sobychacko","html_url":"https://github.com/sobychacko","followers_url":"https://api.github.com/users/sobychacko/followers","following_url":"https://api.github.com/users/sobychacko/following{/other_user}","gists_url":"https://api.github.com/users/sobychacko/gists{/gist_id}","starred_url":"https://api.github.com/users/sobychacko/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sobychacko/subscriptions","organizations_url":"https://api.github.com/users/sobychacko/orgs","repos_url":"https://api.github.com/users/sobychacko/repos","events_url":"https://api.github.com/users/sobychacko/events{/privacy}","received_events_url":"https://api.github.com/users/sobychacko/received_events","type":"User","site_admin":false}],"milestone":null,"comments":2,"created_at":"2016-09-14T20:04:48Z","updated_at":"2016-09-14T22:46:34Z","closed_at":null,"body":"_From @mnadelson on September 14, 2016 15:25_\n\nI have a consumer that subscribes to a topic with 3 partitions.  I launch the same instance of that consumer multiple times (they will of course all have the same consumer group).  When I launch one instance the consumer gets all three partitions (as expected).  When I launch 3 instances each consumer gets one partition (as expected).  When I launch 4 instances two of the consumers got the same partition and received the same messages.  This was not expected.  I would either expect the 4th consumer to get none of the messages or the 4th consumer to round-robin the messages with the other consumer on the same partition.\n\n_Copied from original issue: spring-cloud/spring-cloud-stream#649_"},"comment":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/comments/247180187","html_url":"https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/41#issuecomment-247180187","issue_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream-binder-kafka/issues/41","id":247180187,"user":{"login":"sobychacko","id":827682,"avatar_url":"https://avatars.githubusercontent.com/u/827682?v=3","gravatar_id":"","url":"https://api.github.com/users/sobychacko","html_url":"https://github.com/sobychacko","followers_url":"https://api.github.com/users/sobychacko/followers","following_url":"https://api.github.com/users/sobychacko/following{/other_user}","gists_url":"https://api.github.com/users/sobychacko/gists{/gist_id}","starred_url":"https://api.github.com/users/sobychacko/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sobychacko/subscriptions","organizations_url":"https://api.github.com/users/sobychacko/orgs","repos_url":"https://api.github.com/users/sobychacko/repos","events_url":"https://api.github.com/users/sobychacko/events{/privacy}","received_events_url":"https://api.github.com/users/sobychacko/received_events","type":"User","site_admin":false},"created_at":"2016-09-14T22:46:34Z","updated_at":"2016-09-14T22:46:34Z","body":" @mnadelson Could you give a bit more context around the issue? If you could share your configuration with us, we can try reproducing it on our end. I tried to reproduce and found that it worked as expected.\r\n\r\nI created a simple ticktock (time | log) stream with time source writing into 3 partitions and created 4 different log-sink consumers. I found out that only 3 of them received data. When I restarted a consumer, Kafka did the auto rebalancing among partitions, i.e. only 3 of them got any partitions but reshuffled. I tried this with Kafka 0.9. \r\n\r\nWhat version of Kafka are you using?\r\n\r\n"}}
{"actor":{"display_login":"sobychacko"}}