[jira] [Commented] (KAFKA-4311) Multi layer cache eviction causes forwarding to incorrect ProcessorNode

2016-10-22 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15597385#comment-15597385 ] Damian Guy commented on KAFKA-4311: --- Frank, thanks for testing this for me. I just pushe

[GitHub] kafka-site pull request #26: add trademark symbol on all pages plus longer f...

2016-10-22 Thread derrickdoo
GitHub user derrickdoo opened a pull request: https://github.com/apache/kafka-site/pull/26 add trademark symbol on all pages plus longer footer message - Added trademark symbol to first instance of "Kafka" or "Apache Kafka" across the site. - Updated footer copy You can merge t

[GitHub] kafka pull request #2054: kafka-4295: ConsoleConsumer does not delete the te...

2016-10-22 Thread amethystic
GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2054 kafka-4295: ConsoleConsumer does not delete the temporary group in zookeeper Since consumer stop logic and zk node removal code are in separate threads, so when two threads execute in an interlea

[jira] [Created] (KAFKA-4334) HashCode in SinkRecord not handling null timestamp, checks on value

2016-10-22 Thread Andrew Stevenson (JIRA)
Andrew Stevenson created KAFKA-4334: --- Summary: HashCode in SinkRecord not handling null timestamp, checks on value Key: KAFKA-4334 URL: https://issues.apache.org/jira/browse/KAFKA-4334 Project: Kafk

[GitHub] kafka pull request #2055: check for null timestamp rather than value in hash...

2016-10-22 Thread andrewstevenson
GitHub user andrewstevenson opened a pull request: https://github.com/apache/kafka/pull/2055 check for null timestamp rather than value in hashcode You can merge this pull request into a Git repository by running: $ git pull https://github.com/datamountaineer/kafka kafka-4334

[jira] [Updated] (KAFKA-4334) HashCode in SinkRecord not handling null timestamp, checks on value

2016-10-22 Thread Andrew Stevenson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Stevenson updated KAFKA-4334: Flags: Patch PR raised https://github.com/apache/kafka/pull/2055 > HashCode in SinkRecord

[jira] [Commented] (KAFKA-4306) Connect workers won't shut down if brokers are not available

2016-10-22 Thread Saravanan Tirugnanum (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15598388#comment-15598388 ] Saravanan Tirugnanum commented on KAFKA-4306: - We are noticing this same probl

[GitHub] kafka pull request #1622: KAFKA-3859: Fix describe group command to report v...

2016-10-22 Thread vahidhashemian
Github user vahidhashemian closed the pull request at: https://github.com/apache/kafka/pull/1622 --- 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

[jira] [Commented] (KAFKA-3859) Consumer group is stuck in rebalancing status

2016-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15598439#comment-15598439 ] ASF GitHub Bot commented on KAFKA-3859: --- Github user vahidhashemian closed the pull

[jira] [Updated] (KAFKA-3859) Consumer group is stuck in rebalancing status

2016-10-22 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3859: --- Status: Open (was: Patch Available) Fixed as part of [KAFKA-3144|https://issues.apache.org/ji

[jira] [Resolved] (KAFKA-3859) Consumer group is stuck in rebalancing status

2016-10-22 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-3859. Resolution: Duplicate > Consumer group is stuck in rebalancing status >

[jira] [Work started] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used

2016-10-22 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4333 started by Vahid Hashemian. -- > Report consumer group coordinator id when '--list' option is used > ---

Re: [DISCUSS] KIP-68 Add a consumed log retention before log retention

2016-10-22 Thread Becket Qin
Hi David, > 1. What scenario is used to this configuration? One scenario is stream processing pipeline. In a stream processing DAG, there will be a bunch of intermediate result, we only care about the consumer group that is in the downstream of the DAG, but not other groups. Ideally we want to de

[GitHub] kafka pull request #2056: KAFAK-4058: Failure in org.apache.kafka.streams.in...

2016-10-22 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2056 KAFAK-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset - fixed consumer group dead condition - disabled state store cache You can

[jira] [Updated] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic

2016-10-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4331: --- Status: Patch Available (was: In Progress) https://github.com/apache/kafka/pull/2049 > Kafka

[jira] [Work started] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic

2016-10-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4331 started by Matthias J. Sax. -- > Kafka Streams resetter is slow because it joins the same group for each top

[jira] [Updated] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

2016-10-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4058: --- Status: Patch Available (was: Reopened) https://github.com/apache/kafka/pull/2056 > Failure

Re: [DISCUSS] KIP-80: Kafka REST Server

2016-10-22 Thread Nacho Solis
To be perfectly clear, I'm actually not in favor of adding a REST module to Kafka, but that's because I think other things should be separated as well. Again, I'm new and don't know the history, and I admit it's purely personal preference, but I'm on the Tea Party side of things... the microkernel