{"action":"closed","issue":{"url":"https://api.github.com/repos/spring-projects/spring-kafka/issues/135","repository_url":"https://api.github.com/repos/spring-projects/spring-kafka","labels_url":"https://api.github.com/repos/spring-projects/spring-kafka/issues/135/labels{/name}","comments_url":"https://api.github.com/repos/spring-projects/spring-kafka/issues/135/comments","events_url":"https://api.github.com/repos/spring-projects/spring-kafka/issues/135/events","html_url":"https://github.com/spring-projects/spring-kafka/issues/135","id":163778265,"number":135,"title":"Kafka offsets not commited","user":{"login":"adamdec","id":8249432,"avatar_url":"https://avatars.githubusercontent.com/u/8249432?v=3","gravatar_id":"","url":"https://api.github.com/users/adamdec","html_url":"https://github.com/adamdec","followers_url":"https://api.github.com/users/adamdec/followers","following_url":"https://api.github.com/users/adamdec/following{/other_user}","gists_url":"https://api.github.com/users/adamdec/gists{/gist_id}","starred_url":"https://api.github.com/users/adamdec/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/adamdec/subscriptions","organizations_url":"https://api.github.com/users/adamdec/orgs","repos_url":"https://api.github.com/users/adamdec/repos","events_url":"https://api.github.com/users/adamdec/events{/privacy}","received_events_url":"https://api.github.com/users/adamdec/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/spring-projects/spring-kafka/labels/bug","name":"bug","color":"fc2929"},{"url":"https://api.github.com/repos/spring-projects/spring-kafka/labels/in%20progress","name":"in progress","color":"f7c6c7"}],"state":"closed","locked":false,"assignee":{"login":"garyrussell","id":483832,"avatar_url":"https://avatars.githubusercontent.com/u/483832?v=3","gravatar_id":"","url":"https://api.github.com/users/garyrussell","html_url":"https://github.com/garyrussell","followers_url":"https://api.github.com/users/garyrussell/followers","following_url":"https://api.github.com/users/garyrussell/following{/other_user}","gists_url":"https://api.github.com/users/garyrussell/gists{/gist_id}","starred_url":"https://api.github.com/users/garyrussell/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/garyrussell/subscriptions","organizations_url":"https://api.github.com/users/garyrussell/orgs","repos_url":"https://api.github.com/users/garyrussell/repos","events_url":"https://api.github.com/users/garyrussell/events{/privacy}","received_events_url":"https://api.github.com/users/garyrussell/received_events","type":"User","site_admin":false},"assignees":[{"login":"garyrussell","id":483832,"avatar_url":"https://avatars.githubusercontent.com/u/483832?v=3","gravatar_id":"","url":"https://api.github.com/users/garyrussell","html_url":"https://github.com/garyrussell","followers_url":"https://api.github.com/users/garyrussell/followers","following_url":"https://api.github.com/users/garyrussell/following{/other_user}","gists_url":"https://api.github.com/users/garyrussell/gists{/gist_id}","starred_url":"https://api.github.com/users/garyrussell/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/garyrussell/subscriptions","organizations_url":"https://api.github.com/users/garyrussell/orgs","repos_url":"https://api.github.com/users/garyrussell/repos","events_url":"https://api.github.com/users/garyrussell/events{/privacy}","received_events_url":"https://api.github.com/users/garyrussell/received_events","type":"User","site_admin":false}],"milestone":null,"comments":4,"created_at":"2016-07-05T06:13:01Z","updated_at":"2016-07-05T16:00:34Z","closed_at":"2016-07-05T16:00:34Z","body":"Hi, we were trying to use new spring-kafka 1.0.0.RELEASE 'RECORD' strategy for committing offsets with ConcurrentKafkaListenerContainerFactory configuration:\r\n- concurrency=1\r\n- pollTimeout=10 000\r\n\r\nIn our scenario we encountered strange situation when offsets were not commited by ListenerConsumer.\r\n\r\nIt happened that ListenerInvoker thread processed the Kafka messages so quickly that all he was doing was to wake up ListenerConsumer thread (which was blocked on poll() method) every 1sec. Please note that there was no other messages on Kafka topic to consume so ListenerConsumer  will be blocked on poll() invocation for the entire 10seconds.\r\n\r\nWe think that the problem is because pollTimeout (ListenerConsumer ) is greater then 1 sec (ListenerInvoker) and due to that we were able to produce a live-lock on ListenerConsumer.\r\n\r\nPlease comment.\r\n\r\n\r\n\r\n"}}
{"actor":{"display_login":"artembilan"}}