[jira] [Commented] (KAFKA-4099) Change the time based log rolling to only based on the message timestamp.

[ https://issues.apache.org/jira/browse/KAFKA-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15594095#comment-15594095 ] Jun Rao commented on KAFKA-4099: [~becket_qin], Ewen brought up another example that may still lead to

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Thanks Jason. Great job. On Fri, Oct 21, 2016 at 10:29 AM, Becket Qin wrote: > Congratulations! Great job, Jason. > > On Thu, Oct 20, 2016 at 11:57 AM, Vahid S Hashemian < > vahidhashem...@us.ibm.com> wrote: > > > +1 > > > > Thanks Jason for driving the release. Great job!

[jira] [Commented] (KAFKA-4323) Be able to specify chroot to the kafka-client java producer

[ https://issues.apache.org/jira/browse/KAFKA-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15594079#comment-15594079 ] huxi commented on KAFKA-4323: - New clients including producer and consumer do not need to do this > Be able

[jira] [Issue Comment Deleted] (KAFKA-4323) Be able to specify chroot to the kafka-client java producer

[ https://issues.apache.org/jira/browse/KAFKA-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eli Nudler updated KAFKA-4323: -- Comment: was deleted (was: yes, but what about the producer?) > Be able to specify chroot to the

[jira] [Commented] (KAFKA-4323) Be able to specify chroot to the kafka-client java producer

[ https://issues.apache.org/jira/browse/KAFKA-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15594055#comment-15594055 ] Eli Nudler commented on KAFKA-4323: --- yes, but what about the producer? > Be able to specify chroot to

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Congratulations! Great job, Jason. On Thu, Oct 20, 2016 at 11:57 AM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > +1 > > Thanks Jason for driving the release. Great job! > > --Vahid > > > > > From: Sriram Subramanian > To: dev@kafka.apache.org > Date:

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

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4058: -- > Failure in >

[jira] [Closed] (KAFKA-4310) kafka-consumer-groups script for Windows platform does not exist

[ https://issues.apache.org/jira/browse/KAFKA-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxi closed KAFKA-4310. --- > kafka-consumer-groups script for Windows platform does not exist >

[jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593897#comment-15593897 ] huxi commented on KAFKA-4295: - I think you can try the patch in the pull request and verify it. >

[jira] [Commented] (KAFKA-4271) The console consumer fails on Windows with new consumer is used

[ https://issues.apache.org/jira/browse/KAFKA-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593876#comment-15593876 ] huxi commented on KAFKA-4271: - Kafka maps the index file' content into the memory during the log creation.

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

I've been a little reluctant to wade into this discussion since I've spent a lot of my own time on Confluent's kafka-rest project myself. Seems obvious I would hope that time is not wasted and the project succeeds, right? I think it's the same for a lot of others who have submitted patches to it.

[jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593804#comment-15593804 ] Sswater Shi commented on KAFKA-4295: Thank you very much to fix so quickly. The status shows "awaiting

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

See Changes: [jason] MINOR: Fix vagrant rsync exclude argument -- [...truncated 7382 lines...] kafka.log.LogSegmentTest > testReadAfterLast STARTED kafka.log.LogSegmentTest > testReadAfterLast

[jira] [Commented] (KAFKA-4323) Be able to specify chroot to the kafka-client java producer

[ https://issues.apache.org/jira/browse/KAFKA-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593675#comment-15593675 ] huxi commented on KAFKA-4323: - Do you mean the chroot in Zookeeper? The new consumer does not depend on

Build failed in Jenkins: kafka-trunk-jdk7 #1646

See Changes: [jason] MINOR: Fix vagrant rsync exclude argument -- [...truncated 12322 lines...]

[jira] [Resolved] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxi resolved KAFKA-4295. - Resolution: Fixed > kafka-console-consumer.sh does not delete the temporary group in zookeeper >

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

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593586#comment-15593586 ] Vahid Hashemian edited comment on KAFKA-4058 at 10/21/16 1:13 AM: --

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

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593586#comment-15593586 ] Vahid Hashemian commented on KAFKA-4058: [Another occurrence of this

[jira] [Work started] (KAFKA-4302) Simplify KTableSource

[ https://issues.apache.org/jira/browse/KAFKA-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4302 started by Matthias J. Sax. -- > Simplify KTableSource > - > > Key:

[jira] [Assigned] (KAFKA-4302) Simplify KTableSource

[ https://issues.apache.org/jira/browse/KAFKA-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4302: -- Assignee: Matthias J. Sax (was: Guozhang Wang) > Simplify KTableSource >

[GitHub] kafka pull request #2045: Fix for kafka-4295: kafka-console-consumer.sh does...

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

[GitHub] kafka pull request #2049: [WIP] Do not merge

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2049 [WIP] Do not merge Opening PR to trigger travis build. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka improveResetTool Alternatively

[jira] [Created] (KAFKA-4327) Move Reset Tool from core to streams

Matthias J. Sax created KAFKA-4327: -- Summary: Move Reset Tool from core to streams Key: KAFKA-4327 URL: https://issues.apache.org/jira/browse/KAFKA-4327 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-4326) Refactor LogCleaner to remove duplicate log copying logic

Jason Gustafson created KAFKA-4326: -- Summary: Refactor LogCleaner to remove duplicate log copying logic Key: KAFKA-4326 URL: https://issues.apache.org/jira/browse/KAFKA-4326 Project: Kafka

[GitHub] kafka pull request #2047: Fix vagrant rsync exclude argument

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

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

Jay, REST API is something every user is in need of. If the argument is to clone and write your API, this will do a disservice to the users as they now have to choose one vs. others instead of keeping one API that is supported in Kafka community. "Pre-emptively re-creating another REST

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

+1 Thanks Jason for driving the release. Great job! --Vahid From: Sriram Subramanian To: dev@kafka.apache.org Date: 10/20/2016 11:45 AM Subject:Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released Fantastic release and on time! Congratulations everyone for our

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

Jay, REST API is something every user is in need of. If the argument is to clone and write your API, this will do a disservice to the users as they now have to choose one vs. others instead of keeping one API that is supported in Kafka community. "Pre-emptively re-creating another REST

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593018#comment-15593018 ] Greg Fodor commented on KAFKA-4113: --- Oh, so it should be doing exactly what makes sense to me -- I am on

[GitHub] kafka pull request #2048: Pluggable verifiable clients

GitHub user edenhill opened a pull request: https://github.com/apache/kafka/pull/2048 Pluggable verifiable clients This adds support for pluggable VerifiableConsumer and VerifiableProducers test client implementations allowing third-party clients to be used in-place of the Java

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

See Changes: [wangguoz] KAFKA-4001: Improve Kafka Streams Join Semantics (KIP-77) -- [...truncated 4155 lines...] kafka.log.LogTest > testMessageSetSizeCheck STARTED kafka.log.LogTest >

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592931#comment-15592931 ] Guozhang Wang commented on KAFKA-4113: -- [~gfodor] The main reason we do not log the source KTable is

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Thanks Jason for leading a great release process! And thank you all the people who worked on this release! Ben On Oct 20, 2016 7:45 PM, "Jason Gustafson" wrote: > @Ismael, @Guozhang: No way I'm taking your turns! > > On Thu, Oct 20, 2016 at 11:34 AM, Ismael Juma

[GitHub] kafka pull request #2047: Fix vagrant rsync exclude argument

GitHub user edenhill opened a pull request: https://github.com/apache/kafka/pull/2047 Fix vagrant rsync exclude argument Existing VMs will need to be re-provisioned or re-created to pick up this change. Reference docs:

[jira] [Commented] (KAFKA-4001) Improve Kafka Streams Join Semantics (KIP-77)

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

[GitHub] kafka pull request #1777: KAFKA-4001: Improve Kafka Streams Join Semantics (...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1777 --- 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] [Updated] (KAFKA-4001) Improve Kafka Streams Join Semantics (KIP-77)

[ https://issues.apache.org/jira/browse/KAFKA-4001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4001: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4284) Partitioner never closed by producer

[ https://issues.apache.org/jira/browse/KAFKA-4284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theo Hultberg updated KAFKA-4284: - External issue URL: https://github.com/apache/kafka/pull/2000 > Partitioner never closed by

Kafka custom log compaction

Classification: Public Hi I’d like to messages to be removed from log as part of compaction based on message payload internal attribute. I.e. I have some individual expiration date for each message and I’m not interested in keeping it afterwards. Is there any way to inject custom compaction

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

@Ismael, @Guozhang: No way I'm taking your turns! On Thu, Oct 20, 2016 at 11:34 AM, Ismael Juma wrote: > Thanks everyone for your contributions to this release. I think it's > impressive how much has been achieved in just under 5 months. > > And special thanks to Jason who

[GitHub] kafka pull request #2046: MINOR: Improve the help doc of consumer group comm...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/2046 MINOR: Improve the help doc of consumer group command Clarify the documentation around `zookeeper`, `bootstrap-server`, and `new-consumer` options. You can merge this pull request into a

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Fantastic release and on time! Congratulations everyone for our first time based release. On Thu, Oct 20, 2016 at 11:34 AM, Ismael Juma wrote: > Thanks everyone for your contributions to this release. I think it's > impressive how much has been achieved in just under 5

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Thanks all for all the work in this release! Excited to get this deployed :) On Thu, Oct 20, 2016 at 11:34 AM, Ismael Juma wrote: > Thanks everyone for your contributions to this release. I think it's > impressive how much has been achieved in just under 5 months. > > And

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Thanks everyone for your contributions to this release. I think it's impressive how much has been achieved in just under 5 months. And special thanks to Jason who has seemingly just been appointed RM for life? :) Ismael On Thu, Oct 20, 2016 at 7:22 PM, Guozhang Wang wrote:

[jira] [Created] (KAFKA-4325) Improve processing of late records for window operations

Matthias J. Sax created KAFKA-4325: -- Summary: Improve processing of late records for window operations Key: KAFKA-4325 URL: https://issues.apache.org/jira/browse/KAFKA-4325 Project: Kafka

[jira] [Comment Edited] (KAFKA-4324) NullPointerException in StreamTask.forward

[ https://issues.apache.org/jira/browse/KAFKA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592588#comment-15592588 ] Guozhang Wang edited comment on KAFKA-4324 at 10/20/16 6:28 PM: Thanks for

[jira] [Commented] (KAFKA-4324) NullPointerException in StreamTask.forward

[ https://issues.apache.org/jira/browse/KAFKA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592588#comment-15592588 ] Guozhang Wang commented on KAFKA-4324: -- Thanks for the report [~markshelton], could you share your

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Thanks for driving the release Jason! You should just be the release person for all the future releases :P Guozhang On Thu, Oct 20, 2016 at 11:12 AM, Jason Gustafson wrote: > Had the wrong address for dev and users (haven't sent from this account > before). > > On Thu, Oct

Re: [ANNOUNCE] Apache Kafka 0.10.1.0 Released

Had the wrong address for dev and users (haven't sent from this account before). On Thu, Oct 20, 2016 at 11:05 AM, Jason Gustafson wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 0.10.1.0. This is a feature release which includes the

[jira] [Resolved] (KAFKA-4324) NullPointerException in StreamTask.forward

[ https://issues.apache.org/jira/browse/KAFKA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shelton resolved KAFKA-4324. - Resolution: Invalid Marked as invalid. By accident my processor was singleton-like internally and

[GitHub] kafka-site pull request #25: Enable 0.10.1 documentation

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/25 --- 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] [Created] (KAFKA-4324) NullPointerException in StreamTask.forward

Mark Shelton created KAFKA-4324: --- Summary: NullPointerException in StreamTask.forward Key: KAFKA-4324 URL: https://issues.apache.org/jira/browse/KAFKA-4324 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4323) Be able to specify chroot to the kafka-client java producer

Eli Nudler created KAFKA-4323: - Summary: Be able to specify chroot to the kafka-client java producer Key: KAFKA-4323 URL: https://issues.apache.org/jira/browse/KAFKA-4323 Project: Kafka Issue

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592166#comment-15592166 ] Frank Lyaruu commented on KAFKA-4311: - Yeah, that's correct > Exception in NamedCache.flush - Key

[jira] [Comment Edited] (KAFKA-3159) Kafka consumer 0.9.0.0 client poll is very CPU intensive under certain conditions

[ https://issues.apache.org/jira/browse/KAFKA-3159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592137#comment-15592137 ] constantine edited comment on KAFKA-3159 at 10/20/16 3:32 PM: -- Hi everyone.

[jira] [Commented] (KAFKA-3159) Kafka consumer 0.9.0.0 client poll is very CPU intensive under certain conditions

[ https://issues.apache.org/jira/browse/KAFKA-3159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592137#comment-15592137 ] constantine commented on KAFKA-3159: Hi everyone. We use kafka-10.0.0 (in which current bug should be

[jira] [Commented] (KAFKA-4320) Log compaction docs update

[ https://issues.apache.org/jira/browse/KAFKA-4320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592128#comment-15592128 ] Dustin Cote commented on KAFKA-4320: [~Aurijoy] great, welcome! First have a look at the how to

[jira] [Updated] (KAFKA-3637) Add method that checks if streams are initialised

[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3637: Description: Currently when streams are initialised and started with streams.start(), there is no

[jira] [Reopened] (KAFKA-3637) Add method that checks if streams are initialised

[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reopened KAFKA-3637: - Assignee: Eno Thereska (was: Liquan Pei) > Add method that checks if streams are initialised >

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592060#comment-15592060 ] Damian Guy commented on KAFKA-4311: --- when you are running it are you running a single instance of your

[jira] [Commented] (KAFKA-4320) Log compaction docs update

[ https://issues.apache.org/jira/browse/KAFKA-4320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592058#comment-15592058 ] Aurijoy Majumdar commented on KAFKA-4320: - Hi Dustin, I am new to Kafka, I wanted to start

[jira] [Created] (KAFKA-4322) StateRestoreCallback begin and end indication

Mark Shelton created KAFKA-4322: --- Summary: StateRestoreCallback begin and end indication Key: KAFKA-4322 URL: https://issues.apache.org/jira/browse/KAFKA-4322 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591887#comment-15591887 ] Frank Lyaruu commented on KAFKA-4311: - Excellent! I was starting to doubt every part of my system >

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591872#comment-15591872 ] Damian Guy commented on KAFKA-4311: --- Ok - i've been to reproduce the issue with the test data. It has

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

See Changes: [ismael] KAFKA-4313; ISRs may thrash when replication quota is enabled -- [...truncated 7437 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[3] STARTED

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591675#comment-15591675 ] Damian Guy commented on KAFKA-4311: --- Unfortunately that isn't working. We probably need the zookeeper

Jenkins build is back to normal : kafka-0.10.1-jdk7 #80

See

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

See

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591605#comment-15591605 ] Damian Guy commented on KAFKA-4311: --- thanks - i'll take a look > Exception in NamedCache.flush - Key

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591527#comment-15591527 ] Frank Lyaruu commented on KAFKA-4311: - Ok, I tar/gzipped the contents of the kafka partition folders,

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591478#comment-15591478 ] Damian Guy commented on KAFKA-4311: --- Can you commit it to the github repo? > Exception in

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591453#comment-15591453 ] Frank Lyaruu commented on KAFKA-4311: - Ok, I seem to have created an anonymized version of my data,

[jira] [Commented] (KAFKA-4313) ISRs may thrash when replication quota is enabled

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

[jira] [Resolved] (KAFKA-4313) ISRs may thrash when replication quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4313. Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2043

[GitHub] kafka pull request #2043: KAFKA-4313: ISRs may thrash when replication quota...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2043 --- 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-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591373#comment-15591373 ] Frank Lyaruu commented on KAFKA-4311: - No, not at all, I added the random fields to get a bit meatier

[GitHub] kafka pull request #2045: Fix for kafka-4295: kafka-console-consumer.sh does...

GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2045 Fix for kafka-4295: kafka-console-consumer.sh 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

[jira] [Work started] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4295 started by huxi. --- > kafka-console-consumer.sh does not delete the temporary group in zookeeper >

[jira] [Commented] (KAFKA-4311) Exception in NamedCache.flush - Key found in dirty key set, but entry is null

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591271#comment-15591271 ] Damian Guy commented on KAFKA-4311: --- [~flyaruu] Thanks for the sample code. I've tried running this

Re: KStreams / add support for sink processor with dynamic topics

Florian, I'd also have a follow-up question: > Actually, the set of subtypes is not known in advance this is why I need to > compute output topics from messages. So the branch method is of any help > in my context. For a number of reasons we recommend pre-creating input, intermediate, and

[jira] [Comment Edited] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15590599#comment-15590599 ] huxi edited comment on KAFKA-4295 at 10/20/16 7:28 AM: --- The design is not changed.

Build failed in Jenkins: kafka-trunk-jdk7 #1643

See Changes: [wangguoz] HOTFIX: follow up on KAFKA-4275 [wangguoz] KAFKA-4269: Update topic subscription when regex pattern specified out -- [...truncated 14242 lines...]