Re: [DISCUSS] KIP-82 - Add Record Headers

Let me talk about the container format that we are using here at TiVo to add headers to our Kafka messages. Just some quick terminology, so that I don't confuse everyone. I'm going to use "message body" to refer to the thing returned by ConsumerRecord.value() And I'm going to use "payload" to re

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

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15617788#comment-15617788 ] Frank Lyaruu commented on KAFKA-4311: - I couldn't reproduce the problems from the (pre

[GitHub] kafka pull request #2032: KAFKA-3559: Recycle old tasks when possible

GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2032 KAFKA-3559: Recycle old tasks when possible You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3559-onPartitionAssig

[jira] [Commented] (KAFKA-3559) Task creation time taking too long in rebalance callback

[ https://issues.apache.org/jira/browse/KAFKA-3559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15617935#comment-15617935 ] ASF GitHub Bot commented on KAFKA-3559: --- GitHub user enothereska reopened a pull req

[jira] [Commented] (KAFKA-3559) Task creation time taking too long in rebalance callback

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

[GitHub] kafka pull request #2032: KAFKA-3559: Recycle old tasks when possible

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2032 --- 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

[jira] [Commented] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

[ https://issues.apache.org/jira/browse/KAFKA-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15618009#comment-15618009 ] Michal Borowiecki commented on KAFKA-4355: -- Trying to work around this issue by c

[jira] [Comment Edited] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

[ https://issues.apache.org/jira/browse/KAFKA-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15618009#comment-15618009 ] Michal Borowiecki edited comment on KAFKA-4355 at 10/29/16 12:18 PM: ---

Re: [VOTE] Add REST Server to Apache Kafka

-1 Kafka's development model is a good fit for critical path and well-established APIs. It doesn't work as well for add-ons that need to rapidly evolve. Merging communities with different development pace and models rarely ends well - I think the REST Proxy will benefit from being a separate proje

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15618210#comment-15618210 ] Martin Nowak commented on KAFKA-3042: - Yes, still happens with 0.10.0.1. Also just ran

[GitHub] kafka-site pull request #27: fix includes to missing files in 0101 docs and ...

GitHub user derrickdoo opened a pull request: https://github.com/apache/kafka-site/pull/27 fix includes to missing files in 0101 docs and update mobile nav to a… - Update includes on the 0101 docs "Protocol" and "Migration" pages to point at correct files - Adjust styles for m

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15618260#comment-15618260 ] Martin Nowak commented on KAFKA-3042: - Out of curiosity, why does the controller data

Re: [VOTE] Add REST Server to Apache Kafka

Oops. Sorry, didn't notice the 72h voting period has passed. You can disregard. Gwen On Sat, Oct 29, 2016 at 4:29 PM, Gwen Shapira wrote: > -1 > > Kafka's development model is a good fit for critical path and > well-established APIs. It doesn't work as well for add-ons that need to > rapidly ev

Re: [VOTE] Add REST Server to Apache Kafka

This Vote now closed. There is the majority who are not in favor of including the REST server. Thanks everyone for participating. Vote tally: +1 Votes: Harsha Chintalapani Parth Brahbhatt Ken Jackson Suresh Srinivas Jungtaek Lim Ali Akthar Haohui Mai Shekhar Tippu

[GitHub] kafka pull request #2012: KAFKA-4117: Stream partitionassignro cleanup

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2012 --- 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-4117) Cleanup StreamPartitionAssignor behavior

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

[jira] [Updated] (KAFKA-4117) Cleanup StreamPartitionAssignor behavior

[ https://issues.apache.org/jira/browse/KAFKA-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4117: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch Available

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

See Changes: [wangguoz] KAFKA-4117: Stream partitionassignro cleanup -- [...truncated 3871 lines...] kafka.admin.DeleteTopicTest > testResumeDeleteTopicWithRecoveredFollower STARTED kafka.admi

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

See

[jira] [Created] (KAFKA-4359) Streams integration tests should not use commit interval of 1

Eno Thereska created KAFKA-4359: --- Summary: Streams integration tests should not use commit interval of 1 Key: KAFKA-4359 URL: https://issues.apache.org/jira/browse/KAFKA-4359 Project: Kafka Is