kafka consumer group is rebalancing

Hi, I am using Kafka .9 and new Java consumer. I am polling inside a loop. I am getting commitfailedexcption because of group rebalance, when code try to execute consumer.commitSycn . Please note, I am adding session.timeout.ms as 3 and heartbeat.interval.ms as 1 to consumer and polling hap

[jira] [Commented] (KAFKA-3768) Replace all pattern match on boolean value by if/elase block.

[ https://issues.apache.org/jira/browse/KAFKA-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307207#comment-15307207 ] ASF GitHub Bot commented on KAFKA-3768: --- Github user satendrakumar06 closed the pull

[GitHub] kafka pull request: Replace all pattern match on boolean value by ...

Github user satendrakumar06 closed the pull request at: https://github.com/apache/kafka/pull/1444 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the featur

Jenkins build is back to normal : kafka-trunk-jdk7 #1327

See

[jira] [Resolved] (KAFKA-3335) Kafka Connect hangs in shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3335. -- Resolution: Fixed Fix Version/s: 0.10.0.0 Fixed independently by commit 5

[jira] [Commented] (KAFKA-3335) Kafka Connect hangs in shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307077#comment-15307077 ] Ewen Cheslack-Postava commented on KAFKA-3335: -- [~shikhar] The shutdown hook

[jira] [Updated] (KAFKA-3335) Kafka Connect hangs in shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3335: - Affects Version/s: 0.9.0.1 > Kafka Connect hangs in shutdown hook > --

Build failed in Jenkins: kafka-trunk-jdk8 #663

See Changes: [me] MINOR: Remove synchronized as the tasks are executed sequentially -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (

[GitHub] kafka pull request: MINOR: Remove synchronized as the tasks are ex...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1441 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3771) Improving Kafka code

[ https://issues.apache.org/jira/browse/KAFKA-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306997#comment-15306997 ] ASF GitHub Bot commented on KAFKA-3771: --- GitHub user rekhajoshm opened a pull reques

[GitHub] kafka pull request: KAFKA-3771; Improving Kafka core code

GitHub user rekhajoshm opened a pull request: https://github.com/apache/kafka/pull/1451 KAFKA-3771; Improving Kafka core code - Used flatMap instead of map and flatten - Use isEmpty, NonEmpty, isDefined as appropriate - Used head, keys and keySet where appropriate - Used

[jira] [Created] (KAFKA-3771) Improving Kafka code

Rekha Joshi created KAFKA-3771: -- Summary: Improving Kafka code Key: KAFKA-3771 URL: https://issues.apache.org/jira/browse/KAFKA-3771 Project: Kafka Issue Type: Improvement Components:

[GitHub] kafka pull request: HOTFIX: updated JavaDoc example for 0.9 tech-p...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/1450 HOTFIX: updated JavaDoc example for 0.9 tech-prev to 0.10 You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka hotfix Alternatively you ca

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306654#comment-15306654 ] Joel Pfaff commented on KAFKA-2729: --- We have hit that as well on 0.9.0.1 today, same log

unsubcribe

[GitHub] kafka pull request: MINOR: Avoid trace logging computation in `che...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1449 MINOR: Avoid trace logging computation in `checkEnoughReplicasReachOffset` `numAcks` is only used in the `trace` logging statement so it should be a `def` and not a `val`. Also took the chance to impr

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306409#comment-15306409 ] Michael Noll commented on KAFKA-3478: - Latest documentation link (covers flow control

[jira] [Commented] (KAFKA-3769) KStream job spending 60% of time writing metrics

[ https://issues.apache.org/jira/browse/KAFKA-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306381#comment-15306381 ] Greg Fodor commented on KAFKA-3769: --- Consider the PR a first pass, please advise on how

[jira] [Commented] (KAFKA-3770) KStream job should be able to specify linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306371#comment-15306371 ] Greg Fodor commented on KAFKA-3770: --- https://github.com/apache/kafka/pull/1448 > KStrea

[GitHub] kafka pull request: Add support for linger.ms override

GitHub user gfodor opened a pull request: https://github.com/apache/kafka/pull/1448 Add support for linger.ms override You can merge this pull request into a Git repository by running: $ git pull https://github.com/AltspaceVR/kafka gfodor/kafka-3770 Alternatively you can revi

[jira] [Created] (KAFKA-3770) KStream job should be able to specify linger.ms

Greg Fodor created KAFKA-3770: - Summary: KStream job should be able to specify linger.ms Key: KAFKA-3770 URL: https://issues.apache.org/jira/browse/KAFKA-3770 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-3769) KStream job spending 60% of time writing metrics

[ https://issues.apache.org/jira/browse/KAFKA-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306321#comment-15306321 ] Greg Fodor commented on KAFKA-3769: --- It seems it might be desirable to have a way to jus

[jira] [Commented] (KAFKA-3769) KStream job spending 60% of time writing metrics

[ https://issues.apache.org/jira/browse/KAFKA-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306318#comment-15306318 ] Greg Fodor commented on KAFKA-3769: --- Actually, additionally it looks like the code path