[jira] [Assigned] (KAFKA-4709) Error message from Struct.validate() should include the name of the offending field.

[ https://issues.apache.org/jira/browse/KAFKA-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4709: Assignee: Aegeaner (was: Jeremy Custenborder) > Error message from Struct.validate()

Re: [外部邮件] Re: Add me to the contributor list, please

Jian, I have added you to the contributor list and have also updated KAFKA-4709. Guozhang On Wed, Mar 29, 2017 at 8:14 PM, 郭健 wrote: > Hi all, > Could you please add me to contributor list too? My JIRA username is: > Aegeaner. I have submitted a PR to fix KAFKA-4709

Re: [外部邮件] Re: Add me to the contributor list, please

Hi all, Could you please add me to contributor list too? My JIRA username is: Aegeaner. I have submitted a PR to fix KAFKA-4709 before. Thanks. 在 17/3/30 07:12，“Jun Rao” 写入: Hi, Vitaly, Thanks for your interest. Just added you to the contributor list.

[jira] [Commented] (KAFKA-4882) Remove internal converter configuration from example property files

[ https://issues.apache.org/jira/browse/KAFKA-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948183#comment-15948183 ] Mitch Seymour commented on KAFKA-4882: -- [~ewencp] Thanks for clarifying :) I'll keep it the fix

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

See

Re: Add me to the contributor list, please

Hi, Vitaly, Thanks for your interest. Just added you to the contributor list. Jun On Wed, Mar 29, 2017 at 3:56 PM, Vitaly Pushkar wrote: > Hello, > my name is Vitaly. > > The 'How to contribute' page states that before I begin working on a JIRA > ticket, I must

Add me to the contributor list, please

Hello, my name is Vitaly. The 'How to contribute' page states that before I begin working on a JIRA ticket, I must contact you to be added to the contributor list. I have already signed up in JIRA and commented on the ticket I am interested in: https://issues.apache.org/jira/browse/KAFKA-4810.

[jira] [Commented] (KAFKA-4810) SchemaBuilder should be more lax about checking that fields are unset if they are being set to the same value

[ https://issues.apache.org/jira/browse/KAFKA-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948026#comment-15948026 ] Vitaly Pushkar commented on KAFKA-4810: --- I would like to fix this one. > SchemaBuilder should be

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

Made another pass over the KIP wiki, overall LGTM. One quick question on the described logic: "they will be added to the group and the delay will be extended by min(remainingRebalanceTimeout, group.initial.rebalance.delay.ms)" though: >From your previous email I thought you are "resetting the

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

Thanks Damian! On Wed, Mar 29, 2017 at 1:27 AM, Damian Guy wrote: > Thanks everyone for the discussion, very helpful. I've updated the KIP to > make the delay such that it is extended as new members join the group and > that it never exceeds the groups rebalance timeout. >

[jira] [Resolved] (KAFKA-4843) Stream round-robin scheduler is inneficient

[ https://issues.apache.org/jira/browse/KAFKA-4843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4843. -- Resolution: Fixed Issue resolved by pull request 2643

[jira] [Commented] (KAFKA-4843) Stream round-robin scheduler is inneficient

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

[GitHub] kafka pull request #2643: KAFKA-4843: More efficient round-robin scheduler

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2643 --- 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-4977) kafka-connect: fix findbugs issues in connect/runtime

[ https://issues.apache.org/jira/browse/KAFKA-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947913#comment-15947913 ] Colin P. McCabe commented on KAFKA-4977: https://github.com/apache/kafka/pull/2763 >

[GitHub] kafka pull request #2763: Kafka 4977

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/2763 Kafka 4977 You can merge this pull request into a Git repository by running: $ git pull https://github.com/cmccabe/kafka KAFKA-4977 Alternatively you can review and apply these changes as

[jira] [Commented] (KAFKA-4977) kafka-connect: fix findbugs issues in connect/runtime

[ https://issues.apache.org/jira/browse/KAFKA-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947912#comment-15947912 ] Colin P. McCabe commented on KAFKA-4977: It's not clear me why {{OffsetStorageWriter#doFlush}}

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

See Changes: [ismael] KAFKA-4903; Remove dead code in Shell -- [...truncated 747.30 KB...] org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest

[jira] [Created] (KAFKA-4977) kafka-connect: fix findbugs issues in connect/runtime

Colin P. McCabe created KAFKA-4977: -- Summary: kafka-connect: fix findbugs issues in connect/runtime Key: KAFKA-4977 URL: https://issues.apache.org/jira/browse/KAFKA-4977 Project: Kafka

[jira] [Created] (KAFKA-4976) DumpLogSegments should print the contents of the pid snapshot files

Apurva Mehta created KAFKA-4976: --- Summary: DumpLogSegments should print the contents of the pid snapshot files Key: KAFKA-4976 URL: https://issues.apache.org/jira/browse/KAFKA-4976 Project: Kafka

[GitHub] kafka pull request #2762: MINOR: Ensure streaming iterator is closed by Fetc...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2762 MINOR: Ensure streaming iterator is closed by Fetcher You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Commented] (KAFKA-3877) Gradle compiler daemon exits with non-zero exit code while running LogOffsetTest

[ https://issues.apache.org/jira/browse/KAFKA-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947790#comment-15947790 ] Armin Braun commented on KAFKA-3877: [~ijuma] I think this is not actually a Kafka build instability.

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1594#comment-1594 ] Armin Braun commented on KAFKA-4692: [~guozhang] maybe take a look at my PR. I think I fixed this

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947773#comment-15947773 ] ASF GitHub Bot commented on KAFKA-4692: --- GitHub user original-brownbear opened a pull request:

[GitHub] kafka pull request #2761: KAFKA-4692: Make testNo thread safe

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2761 KAFKA-4692: Make testNo thread safe https://issues.apache.org/jira/browse/KAFKA-4692 should be resolved by this. The problem here (or at least one problem, causing trouble)

[jira] [Work started] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4692 started by Armin Braun. -- > Transient test failure in >

[jira] [Updated] (KAFKA-4882) Remove internal converter configuration from example property files

[ https://issues.apache.org/jira/browse/KAFKA-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4882: - Fix Version/s: (was: 0.10.2.1) Removing fix version since this isn't actually

[jira] [Resolved] (KAFKA-1449) Extend wire protocol to allow CRC32C

[ https://issues.apache.org/jira/browse/KAFKA-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1449. Resolution: Fixed Assignee: Ismael Juma (was: Neha Narkhede) Fix Version/s:

[jira] [Commented] (KAFKA-1449) Extend wire protocol to allow CRC32C

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

[GitHub] kafka pull request #2739: KAFKA-1449: Use CRC32C for checksum of V2 message ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2739 --- 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-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947575#comment-15947575 ] Damian Guy commented on KAFKA-4969: --- This also needs to take into account task stickyness, i.e., see

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 (non-binding) On Wed, Mar 29, 2017 at 6:38 PM, Sriram Subramanian wrote: > +1 > > On Wed, Mar 29, 2017 at 9:36 AM, Bill Bejeck wrote: > > > +1 (non-binding) > > > > Thanks Matthias, > > Bill > > > > On Wed, Mar 29, 2017 at 12:18 PM, Apurva Mehta

Re: [VOTE] KIP-81: Bound Fetch memory usage in the consumer

Hi Mickael, as discussed we could change the priority parameter to be an int rather than a boolean. That's a bit more extensible -- Edoardo Comar IBM MessageHub eco...@uk.ibm.com IBM UK Ltd, Hursley Park, SO21 2JN IBM United Kingdom Limited

[jira] [Commented] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

[ https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947525#comment-15947525 ] ASF GitHub Bot commented on KAFKA-4973: --- GitHub user lindong28 opened a pull request:

[GitHub] kafka pull request #2760: KAFKA-4973; Fix transient failure of AdminClientTe...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/2760 KAFKA-4973; Fix transient failure of AdminClientTest.testDeleteRecordsWithException You can merge this pull request into a Git repository by running: $ git pull

[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=15947500#comment-15947500 ] Sam Nguyen commented on KAFKA-2729: --- We ran into this today on kafka_2.11-0.10.0.1. There is unexpected

[jira] [Commented] (KAFKA-4963) Global Store: startup recovery process skipping processor

[ https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947496#comment-15947496 ] Matthias J. Sax commented on KAFKA-4963: I guess this would be possible to add into the API. If

[jira] [Commented] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

[ https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947479#comment-15947479 ] Dong Lin commented on KAFKA-4973: - [~ijuma] Certainly. Thanks for filing the ticket. I will look into

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 On Wed, Mar 29, 2017 at 9:36 AM, Bill Bejeck wrote: > +1 (non-binding) > > Thanks Matthias, > Bill > > On Wed, Mar 29, 2017 at 12:18 PM, Apurva Mehta > wrote: > > > +1 (non-binding) > > > > On Wed, Mar 29, 2017 at 9:17 AM, Jay Kreps

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 (non-binding) Thanks Matthias, Bill On Wed, Mar 29, 2017 at 12:18 PM, Apurva Mehta wrote: > +1 (non-binding) > > On Wed, Mar 29, 2017 at 9:17 AM, Jay Kreps wrote: > > > +1 > > > > -Jay > > > > On Mon, Mar 20, 2017 at 11:27 AM, Matthias J. Sax

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 (non-binding) On Wed, Mar 29, 2017 at 9:17 AM, Jay Kreps wrote: > +1 > > -Jay > > On Mon, Mar 20, 2017 at 11:27 AM, Matthias J. Sax > wrote: > > > Hi, > > > > I would like to start the vote for KIP-129. Of course, feel free to > > provide some more

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 -Jay On Mon, Mar 20, 2017 at 11:27 AM, Matthias J. Sax wrote: > Hi, > > I would like to start the vote for KIP-129. Of course, feel free to > provide some more feedback on the DISCUSS thread. > > Thanks a lot! > > > -Matthias > >

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

Hi Ismael, I agree. I will change the compatibility para and start voting. Thanks, Mayuresh On Tue, Mar 28, 2017 at 6:40 PM, Ismael Juma wrote: > Hi, > > I think error messages and error codes serve different purposes. Error > messages provide additional information about

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 Thanks for the KIP! On Wed, Mar 29, 2017 at 1:30 AM, Damian Guy wrote: > Thanks Matthias > > +1 > > On Wed, 29 Mar 2017 at 07:34 Eno Thereska wrote: > > > +1 (non-binding) > > > > Thanks Matthias, > > Eno > > > On 20 Mar 2017, at 18:27, Matthias

[jira] [Resolved] (KAFKA-4944) Fix an "unread field" findbugs warning in streams examples

[ https://issues.apache.org/jira/browse/KAFKA-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4944. Resolution: Fixed > Fix an "unread field" findbugs warning in streams examples >

[jira] [Updated] (KAFKA-4944) Fix an "unread field" findbugs warning in streams examples

[ https://issues.apache.org/jira/browse/KAFKA-4944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4944: --- Fix Version/s: 0.11.0.0 > Fix an "unread field" findbugs warning in streams examples >

[jira] [Commented] (KAFKA-4944) Fix an "unread field" findbugs warning in streams examples

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

[GitHub] kafka pull request #2727: KAFKA-4944. Fix an "unread field" findbugs warning...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2727 --- 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] [Resolved] (KAFKA-4945) Suppress findbugs warnings about machine-generated code in jmh-benchmarks

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

[jira] [Commented] (KAFKA-4945) Suppress findbugs warnings about machine-generated code in jmh-benchmarks

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

[GitHub] kafka pull request #2729: KAFKA-4945: Suppress findbugs warnings about machi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2729 --- 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-4975) Kafka process is running, but not listening to 9092 port

[ https://issues.apache.org/jira/browse/KAFKA-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Telles updated KAFKA-4975: - Description: I have two clusters of Kafka brokers, one of them (with 15 brokers + 3 Zookeeper

[GitHub] kafka pull request #2759: Move `Os` class to utils package

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2759 Move `Os` class to utils package The `common` package is public and this class is internal. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-4903) Remove unused code for reading Shell command stdout and add unit test

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

[GitHub] kafka pull request #2692: KAFKA-4903: Shell#runCommand does not clear the in...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2692 --- 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] [Resolved] (KAFKA-4903) Remove unused code for reading Shell command stdout and add unit test

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

[jira] [Commented] (KAFKA-4863) Querying window store may return unwanted keys

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

[GitHub] kafka pull request #2688: KAFKA-4863: Querying window store may return unwan...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/2688 --- 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-4963) Global Store: startup recovery process skipping processor

[ https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947221#comment-15947221 ] Yennick Trevels commented on KAFKA-4963: Thanks for the clear explanation. Wouldn't it be better

[jira] [Updated] (KAFKA-4975) Kafka process is running, but not listening to 9092 port

[ https://issues.apache.org/jira/browse/KAFKA-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Telles updated KAFKA-4975: - Description: I have two clusters of Kafka brokers, one of them (with 15 brokers + 3 Zookeeper

[jira] [Updated] (KAFKA-4975) Kafka process is running, but not listening to 9092 port

[ https://issues.apache.org/jira/browse/KAFKA-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Telles updated KAFKA-4975: - Description: I have two clusters of Kafka brokers, one of them (with 15 brokers + 3 Zookeeper

[jira] [Created] (KAFKA-4975) Kafka process is running, but not listening to 9092 port

Rafael Telles created KAFKA-4975: Summary: Kafka process is running, but not listening to 9092 port Key: KAFKA-4975 URL: https://issues.apache.org/jira/browse/KAFKA-4975 Project: Kafka Issue

[jira] [Commented] (KAFKA-4925) Add a configurable delay to the initial consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947081#comment-15947081 ] ASF GitHub Bot commented on KAFKA-4925: --- GitHub user dguy opened a pull request:

[GitHub] kafka pull request #2758: KAFKA-4925: delay initial rebalance of consumer gr...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2758 KAFKA-4925: delay initial rebalance of consumer group [WiP] Add new broker config, `group.initial.rebalance.delay.ms`, with a default of 3 seconds. When a consumer creates a new group, set the

[jira] [Updated] (KAFKA-4974) System test failure in 0.8.2.2 upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-4974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magnus Edenhill updated KAFKA-4974: --- Description: The 0.10.2 system test failed in one of the upgrade tests from 0.8.2.2:

[jira] [Created] (KAFKA-4974) System test failure in 0.8.2.2 upgrade tests

Magnus Edenhill created KAFKA-4974: -- Summary: System test failure in 0.8.2.2 upgrade tests Key: KAFKA-4974 URL: https://issues.apache.org/jira/browse/KAFKA-4974 Project: Kafka Issue Type:

[jira] [Work started] (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 ] Work on KAFKA-4814 started by Balint Molnar. > ZookeeperLeaderElector not respecting zookeeper.set.acl >

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

See

[jira] [Resolved] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2103. Resolution: Fixed OK, let's close it again then. I haven't seen this failure in Jenkins. >

[jira] [Resolved] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3875. Resolution: Fixed I think the underlying issue was fixed by [~original-brownbear] in a different

[jira] [Updated] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3875: --- Fix Version/s: 0.11.0.0 > Transient test failure: >

[jira] [Commented] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946775#comment-15946775 ] Eno Thereska commented on KAFKA-2103: - I haven't seen it. > kafka.producer.AsyncProducerTest failure.

[jira] [Resolved] (KAFKA-2363) ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread Transient Failure

[ https://issues.apache.org/jira/browse/KAFKA-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2363. Resolution: Fixed Assignee: Armin Braun Fix Version/s: 0.11.0.0

[jira] [Commented] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946771#comment-15946771 ] Ismael Juma commented on KAFKA-2103: [~enothereska], do you still see this failure? >

[jira] [Updated] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

[ https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4973: --- Fix Version/s: 0.11.0.0 > Transient failure of AdminClientTest.testDeleteRecordsWithException >

[jira] [Updated] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

[ https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4973: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > Transient failure of

[jira] [Created] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

Ismael Juma created KAFKA-4973: -- Summary: Transient failure of AdminClientTest.testDeleteRecordsWithException Key: KAFKA-4973 URL: https://issues.apache.org/jira/browse/KAFKA-4973 Project: Kafka

[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=15946736#comment-15946736 ] Balint Molnar commented on KAFKA-4814: -- [~ijuma] Not yet, but I am going to start to work on this

[jira] [Resolved] (KAFKA-4963) Global Store: startup recovery process skipping processor

[ https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4963. --- Resolution: Not A Problem as [~mjsax] stated in his comment this is by design. If you want to do any

[jira] [Commented] (KAFKA-4963) Global Store: startup recovery process skipping processor

[ https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946730#comment-15946730 ] Damian Guy commented on KAFKA-4963: --- [~mjsax] what you have said is correct. This ticket can be closed

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

Thanks Matthias +1 On Wed, 29 Mar 2017 at 07:34 Eno Thereska wrote: > +1 (non-binding) > > Thanks Matthias, > Eno > > On 20 Mar 2017, at 18:27, Matthias J. Sax wrote: > > > > Hi, > > > > I would like to start the vote for KIP-129. Of course, feel

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

Thanks everyone for the discussion, very helpful. I've updated the KIP to make the delay such that it is extended as new members join the group and that it never exceeds the groups rebalance timeout. If everyone is ok with this I'll kick off the voting thread. Thanks again, Damian On Tue, 28

[jira] [Created] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

fangjinuo created KAFKA-4972: Summary: Kafka 0.10.0 Found a corrupted index file during Kafka broker startup Key: KAFKA-4972 URL: https://issues.apache.org/jira/browse/KAFKA-4972 Project: Kafka

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

See Changes: [ismael] KAFKA-4959; Remove controller concurrent access to non-threadsafe [jason] MINOR: Support streaming decompression of fetched records for new format

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 (non-binding) Thanks Matthias, Eno > On 20 Mar 2017, at 18:27, Matthias J. Sax wrote: > > Hi, > > I would like to start the vote for KIP-129. Of course, feel free to > provide some more feedback on the DISCUSS thread. > > Thanks a lot! > > > -Matthias >

[GitHub] kafka pull request #2757: MINOR: stabelize flaky ResetIntegrationTest

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2757 MINOR: stabelize flaky ResetIntegrationTest We got test error `org.apache.kafka.common.errors.TopicExistsException: Topic 'inputTopic' already exists.` in some builds. Can reproduce reliably at

[jira] [Created] (KAFKA-4971) Why is there no difference between kafka benchmark tests on SSD and HDD?

Dasol Kim created KAFKA-4971: Summary: Why is there no difference between kafka benchmark tests on SSD and HDD? Key: KAFKA-4971 URL: https://issues.apache.org/jira/browse/KAFKA-4971 Project: Kafka

KIP-98 Message Format Update

Hi All, As you may have noticed, the message format patch for KIP-98 was merged last Friday. This patch also included the message format changes for KIP-101 and KIP-82. I wanted to mention the notable differences from our initial proposal: 1. We decided not to implement an unsigned varint type.