[GitHub] kafka-site pull request #51: Add missing semicolon in JAAS config

Github user stromnet closed the pull request at: https://github.com/apache/kafka-site/pull/51 --- 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-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960362#comment-15960362 ] Vitaly Pushkar commented on KAFKA-4831: --- I see! Thank you [~mjsax] > Extract Window

[jira] [Commented] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960352#comment-15960352 ] Bharad Tirumala commented on KAFKA-5038: btw, this happens with as few as 5 thread

[jira] [Commented] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

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

[GitHub] kafka pull request #2820: KAFKA-5039: Logging in BlockingChannel and SyncPro...

GitHub user arunmahadevan opened a pull request: https://github.com/apache/kafka/pull/2820 KAFKA-5039: Logging in BlockingChannel and SyncProducer connect When an exception is thrown in BlockingChannel::connect, the connection is disconnected but the actual exception is not logged.

[jira] [Created] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

Arun Mahadevan created KAFKA-5039: - Summary: Logging in BlockingChannel and SyncProducer connect Key: KAFKA-5039 URL: https://issues.apache.org/jira/browse/KAFKA-5039 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5038: - Fix Version/s: (was: 0.10.2.0) Removing invalid fix version since the tagged v

Re: [DISCUSS] KIP-132: Augment KStream.print to allow extra parameters in the printed string

Hi Marc, any update on this KIP? -Matthias On 3/20/17 3:02 PM, Eno Thereska wrote: > Hi Marc, > > Could you add more information in the motivation of the KIP as to what > problems this would solve? I can see how it can be done, but I don't yet grok > why it's useful. The KIP should contain

Re: [VOTE] KIP-123: Allow per stream/table timestamp extractor

+1 (binding) Left a few more comments in the DISCUSS thread, but nothing that would affect voting. Might also want to note somewhere in the KIP wiki that this interacts with KIP-120. Not critical, but it might help someone reading the KIPs for 0.11 figure out that they should actually be using the

Re: [DISCUSS] KIP-123: Allow per stream/table timestamp extractor

I agree there's a potential issue that Eno raises, but probably it's not worth worrying about trying to enforce it. It seems like we have the right default for long term and for most cases a custom timestamp extractor should only be needed for legacy data that isn't putting a timestamp in the recor

Re: [DISCUSS] KIP-138: Change punctuate semantics

Sure, Thanks Matthias. My id is [arunmathew88]. Of course. I was thinking of a subpage where people can collaborate. Will do as per Michael’s suggestion. Regards, Arun Mathew On 4/7/17, 12:30, "Matthias J. Sax" wrote: Please share your Wiki-ID and a committer can give you write access.

Re: [DISCUSS] KIP-138: Change punctuate semantics

Please share your Wiki-ID and a committer can give you write access. Btw: as you did not initiate the KIP, you should not change the KIP without the permission of the original author -- in this case Michael. So you might also just share your thought over the mailing list and Michael can update th

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

See Changes: [junrao] HOTFIX: Remove duplicate entry from ApiVersion [ismael] KAFKA-4995; Fix remaining findbugs warnings in Kafka Streams -- [...truncated 937.88 KB...]

Subscribe request

Re: [DISCUSS] KIP-138: Change punctuate semantics

Hi Jay, Thanks for the advise, I would like to list down the use cases as per your suggestion. But it seems I don't have write permission to the Apache Kafka Confluent Space. Whom shall I request for it? Regarding your last question. We are using a patch in our production system which do

[jira] [Commented] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960123#comment-15960123 ] Bharad Tirumala commented on KAFKA-5038: Tried it with 0.10.2.1 build with PR #279

[GitHub] kafka pull request #2819: MINOR: Increase number of retries from the default...

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2819 MINOR: Increase number of retries from the default of 0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-increase-ret

[jira] [Resolved] (KAFKA-4574) Transient failure in ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade with security_protocol = SASL_PLAINTEXT, SSL

[ https://issues.apache.org/jira/browse/KAFKA-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4574. Resolution: Fixed Fix Version/s: 0.11.0.0 I ran this test with --repeat=8 (which works out to

[jira] [Created] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

Bharad Tirumala created KAFKA-5038: -- Summary: running multiple kafka streams instances causes one or more instance to get into file contention Key: KAFKA-5038 URL: https://issues.apache.org/jira/browse/KAFKA-5038

[jira] [Created] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

Matthias J. Sax created KAFKA-5037: -- Summary: Infinite loop if all input topics are unknown at startup Key: KAFKA-5037 URL: https://issues.apache.org/jira/browse/KAFKA-5037 Project: Kafka Is

[GitHub] kafka pull request #2780: KAFKA-4995. Fix remaining findbugs warnings in Kaf...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2780 --- 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] [Resolved] (KAFKA-4995) Fix remaining findbugs warnings in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4995. Resolution: Fixed Fix Version/s: 0.11.0.0 > Fix remaining findbugs warnings in Kafka Streams

[jira] [Commented] (KAFKA-4995) Fix remaining findbugs warnings in Kafka Streams

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

Build failed in Jenkins: kafka-0.10.2-jdk7 #127

See Changes: [ismael] KAFKA-5003; StreamThread should catch InvalidTopicException [me] KAFKA-4916: test streams with brokers failing -- [...truncated 161.51 KB...]

[GitHub] kafka pull request #2818: HOTFIX: Remove duplicate entry from ApiVersion

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

[GitHub] kafka-site pull request #52: SMT example, correct classnames in the generate...

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

[jira] [Commented] (KAFKA-5035) throttling_test fails due to parsing exception in console consumer

[ https://issues.apache.org/jira/browse/KAFKA-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959915#comment-15959915 ] Jun Rao commented on KAFKA-5035: It seems that one way to fix the issue is to use acks=all

[GitHub] kafka-site issue #52: SMT example, correct classnames in the generated trans...

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/52 Ismael said I should get those mechanical thingies reviewed just in case I'm missing files or stuff.. Thanks! --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Created] (KAFKA-5036) Followups from KIP-101

Jun Rao created KAFKA-5036: -- Summary: Followups from KIP-101 Key: KAFKA-5036 URL: https://issues.apache.org/jira/browse/KAFKA-5036 Project: Kafka Issue Type: Improvement Affects Versions: 0.11.0

[jira] [Created] (KAFKA-5035) throttling_test fails due to parsing exception in console consumer

Jun Rao created KAFKA-5035: -- Summary: throttling_test fails due to parsing exception in console consumer Key: KAFKA-5035 URL: https://issues.apache.org/jira/browse/KAFKA-5035 Project: Kafka Issue T

[GitHub] kafka pull request #2818: HOTFIX: Remove duplicate entry from ApiVersion

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2818 HOTFIX: Remove duplicate entry from ApiVersion You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka fix-api-version Alternatively you can

Build failed in Jenkins: kafka-0.10.2-jdk7 #126

See Changes: [ismael] KAFKA-4901; Make ProduceRequest thread-safe -- [...truncated 163.83 KB...] kafka.server.KafkaConfigTest > testUncleanLeaderElectionDefault STARTED

[jira] [Commented] (KAFKA-4916) Add streams tests with brokers failing

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

[GitHub] kafka-site issue #52: SMT example, correct classnames in the generated trans...

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/52 @ewencp ? --- 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 t

[GitHub] kafka pull request #2793: KAFKA-4916: test streams with brokers failing (for...

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2793 --- 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-5003) StreamThread should catch InvalidTopicException

[ https://issues.apache.org/jira/browse/KAFKA-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5003: Resolution: Fixed Status: Resolved (was: Patch Available) > StreamThread should catch Inval

[jira] [Commented] (KAFKA-5003) StreamThread should catch InvalidTopicException

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

[GitHub] kafka pull request #2774: KAFKA-5003: StreamThread should catch InvalidTopic...

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

[jira] [Updated] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset (KIP-101)

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1211: --- Resolution: Fixed Status: Resolved (was: Patch Available) The PR has been merged. Thanks, [~benstopfo

[jira] [Commented] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959829#comment-15959829 ] Ewen Cheslack-Postava commented on KAFKA-4929: -- [~gwenshap] Fine with me. >

[jira] [Updated] (KAFKA-4916) Add streams tests with brokers failing

[ https://issues.apache.org/jira/browse/KAFKA-4916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4916: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[GitHub] kafka pull request #2808: KIP-101: Alter Replication Protocol to use Leader ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2808 --- 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] [Updated] (KAFKA-5034) Connect workers don't discover new Connector Plugins without Restart

[ https://issues.apache.org/jira/browse/KAFKA-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-5034: Component/s: KafkaConnect > Connect workers don't discover new Connector Plugins without Restart > -

[jira] [Created] (KAFKA-5034) Connect workers don't discover new Connector Plugins without Restart

Gwen Shapira created KAFKA-5034: --- Summary: Connect workers don't discover new Connector Plugins without Restart Key: KAFKA-5034 URL: https://issues.apache.org/jira/browse/KAFKA-5034 Project: Kafka

Build failed in Jenkins: kafka-0.10.2-jdk7 #125

See Changes: [cshapi] KAFKA-4929: Transformation Key/Value type references should be to class -- [...truncated 813.73 KB...] org.apache.kafka.streams.integration.KStreamA

[jira] [Commented] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959761#comment-15959761 ] Matthias J. Sax commented on KAFKA-4831: The classes `WindowSerializer` and `Windo

[jira] [Assigned] (KAFKA-5033) Reconsider default retries for idempotent producer

[ https://issues.apache.org/jira/browse/KAFKA-5033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5033: --- Assignee: Apurva Mehta > Reconsider default retries for idempotent producer > ---

[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=15959741#comment-15959741 ] Dong Lin commented on KAFKA-3042: - [~pengwei] Sorry, I didn't notice your message in Jan u

[jira] [Commented] (KAFKA-4901) Make ProduceRequest thread-safe

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

[GitHub] kafka pull request #2810: KAFKA-4901: Make ProduceRequest thread-safe

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

[jira] [Commented] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959568#comment-15959568 ] Vitaly Pushkar commented on KAFKA-4831: --- Hello [~guozhang], could you elaborate on

[GitHub] kafka-site pull request #52: SMT example, correct classnames in the generate...

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka-site/pull/52 SMT example, correct classnames in the generated transformations list… … and more Connect in TOC You can merge this pull request into a Git repository by running: $ git pull https://git

[jira] [Commented] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959490#comment-15959490 ] Gwen Shapira commented on KAFKA-4929: - I'm cherrypicking this to 0.10.2 branch to be i

[jira] [Comment Edited] (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=15959479#comment-15959479 ] Jeff Widman edited comment on KAFKA-3042 at 4/6/17 6:16 PM: We

[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=15959479#comment-15959479 ] Jeff Widman commented on KAFKA-3042: We hit this on 0.10.0.1. Root cause was a reall

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959426#comment-15959426 ] Joseph Aliase commented on KAFKA-5007: -- [~junrao] [~ijuma] I repeated the test in 0.8

[GitHub] kafka-site issue #50: Typo in kafka 0.10.2 topics operation doc

Github user jlisam13 commented on the issue: https://github.com/apache/kafka-site/pull/50 I see. No worries. I will make the changes in the right place --- 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

Build failed in Jenkins: kafka-0.10.2-jdk7 #124

See Changes: [ismael] MINOR: Improve topic management instructions for Kafka Streams examples [ismael] MINOR: Clarify ReadOnlyWindowStore's time range behaviour -- [...tr

[GitHub] kafka-site issue #48: Filled in og meta tags

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/48 @derrickdoo I just saw it... is this PR still relevant? Or was this already fixed at some point? --- If your project is set up for it, you can reply to this email and have your reply appear on G

[GitHub] kafka-site issue #49: Fix bad kafka stream link on use cases page

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/49 Sorry, documentation changes actually don't go here... they go in the source repo and are pushed here. See the instructions here: https://cwiki.apache.org/confluence/display/KAFKA/Contributin

[GitHub] kafka-site issue #50: Typo in kafka 0.10.2 topics operation doc

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/50 Sorry, documentation changes actually don't go here... they go in the source repo and are pushed here. See the instructions here: https://cwiki.apache.org/confluence/display/KAFKA/Contributin

[GitHub] kafka-site issue #51: Add missing semicolon in JAAS config

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/51 Sorry, documentation changes actually don't go here... they go in the source repo and are pushed here. See the instructions here: https://cwiki.apache.org/confluence/display/KAFKA/Contributin

[jira] [Assigned] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4730: --- Assignee: Nikki Thean (was: Eno Thereska) > Streams does not have an in-memory windowed stor

[jira] [Comment Edited] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959347#comment-15959347 ] Eno Thereska edited comment on KAFKA-4730 at 4/6/17 5:18 PM: -

[jira] [Assigned] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4730: --- Assignee: Eno Thereska > Streams does not have an in-memory windowed store >

[jira] [Commented] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959347#comment-15959347 ] Eno Thereska commented on KAFKA-4730: - [~nthean] we'd love your help with this. It mig

Re: [VOTE] KIP-120: Cleanup Kafka Streams builder API

+1 I am closing this vote now. The KIP got accepted with +3 binding (Guozhang, Ewen, Ram) +2 non-bining (Damian, Matthias) Thanks for voting. -Matthias On 4/5/17 9:02 AM, Sriram Subramanian wrote: > +1 > > On Tue, Apr 4, 2017 at 9:01 PM, Ewen Cheslack-Postava > wrote: > >> +1 (binding) >>

Re: [VOTE] KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user

Hi Ismael, Are you suggesting to use the InvalidRecordException when the key is null? Thanks, Mayuresh On Thu, Apr 6, 2017 at 8:49 AM, Ismael Juma wrote: > Hi Mayuresh, > > I took a closer look at the code and we seem to throw > `InvalidRecordException` in a number of cases where retrying doe

Re: [VOTE] KIP-134: Delay initial consumer group rebalance

Hi Damian. Can you copy the point Becket made earlier that you say isn't addressed? On Thu, Apr 6, 2017 at 2:51 AM, Damian Guy wrote: > Thanks all, the Vote is now closed and the KIP has been accepted with 9 +1s > > 3 binding:: > Guozhang, > Jason, > Ismael > > 6 non-binding: > Bill, > Eno, > M

Re: [VOTE] KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user

Hi Mayuresh, I took a closer look at the code and we seem to throw `InvalidRecordException` in a number of cases where retrying doesn't seem to make sense. For example: throw new InvalidRecordException(s"Log record magic does not match outer magic ${batch.magic}") throw new InvalidRecordException

Re: [VOTE] KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user

+1 (non-binding) On Wed, Apr 5, 2017 at 10:45 AM, Mayuresh Gharat wrote: > Bumping up this thread. > > On Mon, Apr 3, 2017 at 4:22 PM, Mayuresh Gharat < > gharatmayures...@gmail.com> > wrote: > > > Hi All, > > > > It seems that there is no further concern with the KIP-135. At this point > > we

Build failed in Jenkins: kafka-0.10.2-jdk7 #123

See Changes: [ismael] MINOR: Improve log4j on stream thread and stream process -- [...truncated 762.25 KB...] org.apache.kafka.streams.integration.JoinIntegrationTest > t

Jenkins build is back to normal : kafka-trunk-jdk8 #1407

See

[GitHub] kafka pull request #2811: MINOR: update javadoc on ReadOnlyWindowStore

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2811 --- 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] [Updated] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Aliase updated KAFKA-5007: - Priority: Critical (was: Major) > Kafka Replica Fetcher Thread- Resource Leak > -

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958945#comment-15958945 ] Joseph Aliase commented on KAFKA-5007: -- [~junrao]I conducted one more test to confirm

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958944#comment-15958944 ] Joseph Aliase commented on KAFKA-5007: -- [~junrao] Thanks for responding back. I do se

[jira] [Updated] (KAFKA-5014) SSL Channel not ready but tcp is established and the server is hung will not sending metadata

[ https://issues.apache.org/jira/browse/KAFKA-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5014: --- Labels: reliability (was: ) > SSL Channel not ready but tcp is established and the server is hung wil

[jira] [Updated] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5007: --- Labels: reliability (was: ) > Kafka Replica Fetcher Thread- Resource Leak > -

[jira] [Updated] (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:all-tabpanel ] Ismael Juma updated KAFKA-3042: --- Component/s: controller > updateIsr should stop after failed several times due to zkVersion issue > --

[jira] [Updated] (KAFKA-3964) Metadata update requests are sometimes received after LeaderAndIsrRequests

[ https://issues.apache.org/jira/browse/KAFKA-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3964: --- Labels: reliability (was: ) > Metadata update requests are sometimes received after LeaderAndIsrReque

[jira] [Updated] (KAFKA-3964) Metadata update requests are sometimes received after LeaderAndIsrRequests

[ https://issues.apache.org/jira/browse/KAFKA-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3964: --- Component/s: controller > Metadata update requests are sometimes received after LeaderAndIsrRequests >

[GitHub] kafka pull request #2812: MINOR: Improve topic management instructions for K...

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

[GitHub] kafka pull request #2817: MINOR: Improve log4j on stream thread and stream p...

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2817 --- 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] [Assigned] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

[ https://issues.apache.org/jira/browse/KAFKA-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar reassigned KAFKA-4814: Assignee: Rajini Sivaram (was: Balint Molnar) > ZookeeperLeaderElector not respecting zook

[jira] [Commented] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

[ https://issues.apache.org/jira/browse/KAFKA-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958759#comment-15958759 ] Balint Molnar commented on KAFKA-4814: -- [~rsivaram] Please help me with this. Sadly,

[jira] [Commented] (KAFKA-5003) StreamThread should catch InvalidTopicException

[ https://issues.apache.org/jira/browse/KAFKA-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958751#comment-15958751 ] Ismael Juma commented on KAFKA-5003: The trunk PR has been merged, 0.10.2 still to be

[GitHub] kafka pull request #2747: KAFKA-5003: StreamThread should catch InvalidTopic...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2747 --- 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-5003) StreamThread should catch InvalidTopicException

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

[GitHub] kafka pull request #2817: MINOR: Improve log4j on stream thread and stream p...

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2817 MINOR: Improve log4j on stream thread and stream process Cherry pick from https://github.com/apache/kafka/pull/2685 You can merge this pull request into a Git repository by running: $ git p

[jira] [Created] (KAFKA-5033) Reconsider default retries for idempotent producer

Ismael Juma created KAFKA-5033: -- Summary: Reconsider default retries for idempotent producer Key: KAFKA-5033 URL: https://issues.apache.org/jira/browse/KAFKA-5033 Project: Kafka Issue Type: Sub-

[jira] [Commented] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958681#comment-15958681 ] Ismael Juma commented on KAFKA-5018: Also, there are a few magic values in tests like

[VOTE] KIP-86: Configurable SASL callback handlers

Hi all, I would like to start the voting process for KIP-86: https://cwiki.apache.org/confluence/display/KAFKA/KIP-86%3A+Configurable+SASL+callback+handlers The KIP makes callback handlers for SASL configurable to make it simpler to integrate with custom authentication database or custom authent

Re: [VOTE] KIP-134: Delay initial consumer group rebalance

Thanks all, the Vote is now closed and the KIP has been accepted with 9 +1s 3 binding:: Guozhang, Jason, Ismael 6 non-binding: Bill, Eno, Mathieu, Matthias, Dong, Mickael Thanks, Damian On Thu, 6 Apr 2017 at 09:26 Ismael Juma wrote: > Thanks for the KIP, +1 (binding). > > Ismael > > On Thu, M

[jira] [Created] (KAFKA-5032) Think through implications of max.message.size affecting record batches in message format V2

Ismael Juma created KAFKA-5032: -- Summary: Think through implications of max.message.size affecting record batches in message format V2 Key: KAFKA-5032 URL: https://issues.apache.org/jira/browse/KAFKA-5032

[jira] [Commented] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

[ https://issues.apache.org/jira/browse/KAFKA-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958663#comment-15958663 ] Rajini Sivaram commented on KAFKA-4814: --- [~baluchicken] Let me know you would like m

[jira] [Created] (KAFKA-5031) Additional validation in validateMessagesAndAssignOffsets

Ismael Juma created KAFKA-5031: -- Summary: Additional validation in validateMessagesAndAssignOffsets Key: KAFKA-5031 URL: https://issues.apache.org/jira/browse/KAFKA-5031 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-5030) Suggested clean-ups from message format V2 review

Ismael Juma created KAFKA-5030: -- Summary: Suggested clean-ups from message format V2 review Key: KAFKA-5030 URL: https://issues.apache.org/jira/browse/KAFKA-5030 Project: Kafka Issue Type: Sub-t

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958590#comment-15958590 ] Domenico Di Giulio commented on KAFKA-5016: --- More information on Kafka versions

[jira] [Updated] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Di Giulio updated KAFKA-5016: -- Attachment: Kafka 0.10.2.0 Issue (TRACE) - Server + Client.txt > Consumer hang in poll m

  1   2   >