{"action":"created","issue":{"url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/80","repository_url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka","labels_url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/80/labels{/name}","comments_url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/80/comments","events_url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/80/events","html_url":"https://github.com/wso2-extensions/siddhi-io-kafka/issues/80","id":350559490,"node_id":"MDU6SXNzdWUzNTA1NTk0OTA=","number":80,"title":"partition.wise thread setting not working as expected.","user":{"login":"amanbhal","id":13241777,"node_id":"MDQ6VXNlcjEzMjQxNzc3","avatar_url":"https://avatars3.githubusercontent.com/u/13241777?v=4","gravatar_id":"","url":"https://api.github.com/users/amanbhal","html_url":"https://github.com/amanbhal","followers_url":"https://api.github.com/users/amanbhal/followers","following_url":"https://api.github.com/users/amanbhal/following{/other_user}","gists_url":"https://api.github.com/users/amanbhal/gists{/gist_id}","starred_url":"https://api.github.com/users/amanbhal/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/amanbhal/subscriptions","organizations_url":"https://api.github.com/users/amanbhal/orgs","repos_url":"https://api.github.com/users/amanbhal/repos","events_url":"https://api.github.com/users/amanbhal/events{/privacy}","received_events_url":"https://api.github.com/users/amanbhal/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-08-14T19:07:40Z","updated_at":"2018-09-06T22:11:18Z","closed_at":null,"author_association":"NONE","body":"**Description:**\r\nThe thread setting : \r\n\r\n> partition.wise\r\n\r\n is not fetching data from all the partitions. It always pulls data from first 5 partitions and does not pull any data from remaining partitions.\r\n\r\n**Affected Product Version:**\r\nwso2sp-4.1.0 with following kafka related jars: kafka_2.11_0.11.0.0_1.0.0.jar, kafka_clients_0.11.0.0_1.0.0.jar, siddhi-io-kafka-4.1.5.jar\r\n\r\n**Steps to reproduce:**\r\nFollowing setting is provided for Kafka source:\r\n```\r\n@source(type='kafka',\r\n        topic.list='topic-name',\r\n        partition.no.list='0,1,2,3,4,5,6,7,8,9,10,11',\r\n        threading.option='partition.wise',\r\n        group.id='group-id',\r\n        bootstrap.servers='server-1:port,server-2:port,server-3:port',\r\n        @map(type='json'))\r\n```"},"comment":{"url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/comments/419257703","html_url":"https://github.com/wso2-extensions/siddhi-io-kafka/issues/80#issuecomment-419257703","issue_url":"https://api.github.com/repos/wso2-extensions/siddhi-io-kafka/issues/80","id":419257703,"node_id":"MDEyOklzc3VlQ29tbWVudDQxOTI1NzcwMw==","user":{"login":"amanbhal","id":13241777,"node_id":"MDQ6VXNlcjEzMjQxNzc3","avatar_url":"https://avatars3.githubusercontent.com/u/13241777?v=4","gravatar_id":"","url":"https://api.github.com/users/amanbhal","html_url":"https://github.com/amanbhal","followers_url":"https://api.github.com/users/amanbhal/followers","following_url":"https://api.github.com/users/amanbhal/following{/other_user}","gists_url":"https://api.github.com/users/amanbhal/gists{/gist_id}","starred_url":"https://api.github.com/users/amanbhal/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/amanbhal/subscriptions","organizations_url":"https://api.github.com/users/amanbhal/orgs","repos_url":"https://api.github.com/users/amanbhal/repos","events_url":"https://api.github.com/users/amanbhal/events{/privacy}","received_events_url":"https://api.github.com/users/amanbhal/received_events","type":"User","site_admin":false},"created_at":"2018-09-06T22:11:18Z","updated_at":"2018-09-06T22:11:18Z","author_association":"NONE","body":"@suhothayan "}}
{"actor":{"display_login":"amanbhal"}}