Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Hi Jay, Thanks for summarising the reasoning for the current approach. On the topic of additional jars, the obvious example that came up recently is sharing JSON serializers between connect and streams. Given the desire not to add a Jackson dependency to clients, it seems like adding a

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

See Changes: [me] MINOR: Fix comment in DistributedHerder [cshapi] KAFKA-3548: Use root locale for case transformation of constant strings -- [...truncated 2499 lines...]

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Thanks! On Wed, Apr 20, 2016 at 8:00 PM, Ashish Singh wrote: > OK, in that case we can move the authorizer interface and related classes > to existing org.apache.kafka.common.security.auth. I have updated KIP to > reflect this. > > > On Wed, Apr 20, 2016 at 4:52 PM, Jay

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

See

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

OK, in that case we can move the authorizer interface and related classes to existing org.apache.kafka.common.security.auth. I have updated KIP to reflect this. ​ On Wed, Apr 20, 2016 at 4:52 PM, Jay Kreps wrote: > Yeah our take when we came up with this approach was pretty

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

See Changes: [wangguoz] KAFKA-3117: handle metadata updates during consumer rebalance -- [...truncated 2425 lines...] kafka.api.test.ProducerCompressionTest > testCompression[3] PASSED

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

See Changes: [wangguoz] KAFKA-3117: handle metadata updates during consumer rebalance -- [...truncated 2602 lines...] kafka.api.PlaintextProducerSendTest > testClose PASSED

[jira] [Updated] (KAFKA-3548) Locale is not handled properly in kafka-consumer

[ https://issues.apache.org/jira/browse/KAFKA-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3548: Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 0.10.1.0

[GitHub] kafka pull request: KAFKA-3548: Use root locale for case transform...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1220 --- 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-3548) Locale is not handled properly in kafka-consumer

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

[jira] [Commented] (KAFKA-3480) Autogenerate metrics documentation

[ https://issues.apache.org/jira/browse/KAFKA-3480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251080#comment-15251080 ] Gwen Shapira commented on KAFKA-3480: - Sorry for the delay James. I'm a bit busy at the moment, it

[jira] [Updated] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

[ https://issues.apache.org/jira/browse/KAFKA-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3459: -- Status: Patch Available (was: In Progress) > Returning zero task configurations from a connector does

[jira] [Work started] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

[ https://issues.apache.org/jira/browse/KAFKA-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3459 started by Liquan Pei. - > Returning zero task configurations from a connector does not properly clean > up

[jira] [Commented] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

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

[GitHub] kafka pull request: KAFKA-3459: Returning zero task configurations...

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1248 KAFKA-3459: Returning zero task configurations from a connector does not properly clean up existing tasks @hachikuji @ewencp Can you take a look when you have time? You can merge this pull

[GitHub] kafka pull request: Minor comment fix

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

electing leader failed and result in 0 latest offset

Hi folks, Recently we run into an odd issue that some partition's latest offset becomes 0. Here's the snapshot of the Kafka Manager. As you can see partition 2 and 3 becomes zero. *Partition* *Latest Offset* *Leader* *Replicas* *In Sync Replicas* *Preferred Leader?* *Under Replicated?* 0

[jira] [Commented] (KAFKA-3579) TopicCommand references outdated consumer property fetch.message.max.bytes

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

[jira] [Commented] (KAFKA-3579) TopicCommand references outdated consumer property fetch.message.max.bytes

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

[GitHub] kafka pull request: KAFKA-3579 - Update reference to the outdated ...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/1239 KAFKA-3579 - Update reference to the outdated consumer property Replace references to the old consumer property 'fetch.message.max.bytes' with the corresponding property in the new

[GitHub] kafka pull request: KAFKA-3579 - Update reference to the outdated ...

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

[jira] [Commented] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250995#comment-15250995 ] Guozhang Wang commented on KAFKA-3117: -- PR merged, leaving this ticket open for another month to see

[jira] [Commented] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

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

[GitHub] kafka pull request: KAFKA-3117: handle metadata updates during con...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1247 --- 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-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250977#comment-15250977 ] Henry Cai commented on KAFKA-3101: -- We really need this batching/buffering feature for us to adopt kafka

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Yeah our take when we came up with this approach was pretty much what Gwen is saying: 1. In practice you either need the server or client to do anything and the server depends on the client so bundling common and client doesn't hurt. 2. Our experience with more granular jars (not in Kafka) was

[jira] [Updated] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3117: --- Status: Patch Available (was: Open) > Fail test at: PlaintextConsumerTest.

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

But its just a compile-time dependency, right? Since the third-party-authorizer-implementation will be installed on a broker where the common classes will exist anyway. On Wed, Apr 20, 2016 at 3:13 PM, Ashish Singh wrote: > Jay, > > Thanks for the info. I think having

[jira] [Created] (KAFKA-3597) Enable query ConsoleConsumer and VerifiableProducer if they shutdown cleanly

Anna Povzner created KAFKA-3597: --- Summary: Enable query ConsoleConsumer and VerifiableProducer if they shutdown cleanly Key: KAFKA-3597 URL: https://issues.apache.org/jira/browse/KAFKA-3597 Project:

[jira] [Commented] (KAFKA-3593) kafka.network.Processor throws ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/KAFKA-3593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250884#comment-15250884 ] S Shan commented on KAFKA-3593: --- After I created this issue, I then found out that this is a known

[GitHub] kafka pull request: KAFKA-3117: handle metadata updates during con...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1247 KAFKA-3117: handle metadata updates during consumer rebalance You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3117

[jira] [Commented] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

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

[jira] [Updated] (KAFKA-1981) Make log compaction point configurable

[ https://issues.apache.org/jira/browse/KAFKA-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Wasserman updated KAFKA-1981: -- Attachment: KIP for Kafka Compaction Patch.md Attached a KIP as I cannot add one in Confluence

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Jay, Thanks for the info. I think having common in clients jar makes sense, as their is no direct usage of it. i.e., without depending on or using clients. Authorizer is a bit different, as third party implementations do not really need anything from clients or server, all they need is Authorizer

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

See

[GitHub] kafka pull request: KAFKA-3589: set inner serializer for ChangedSe...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1246 KAFKA-3589: set inner serializer for ChangedSerde upon initialization You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[jira] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper<K, V, K1> selector, String name) throw NPE

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

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3595: - Fix Version/s: 0.10.1.0 > Add capability to specify replication compact option for stream store >

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3595: - Labels: user-experience (was: ) > Add capability to specify replication compact option for

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3596: - Fix Version/s: 0.10.1.0 > Kafka Streams: Window expiration needs to consider more than event time

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3596: - Labels: architecture (was: ) > Kafka Streams: Window expiration needs to consider more than

[jira] [Resolved] (KAFKA-3568) KafkaProducer fails with timeout on message send()

[ https://issues.apache.org/jira/browse/KAFKA-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Zoller resolved KAFKA-3568. Resolution: Fixed Fix Version/s: 0.10.0.0 0.10.1.0 Wow! What a find!

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3595: - Description: Currently state store replication always go through a compact kafka topic. For some state

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3596: - Description: Currently in Kafka Streams, the way the windows are expired in RocksDB is triggered by new

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3595: - Description: Currently in Kafka Streams, the way the windows are expired in RocksDB is triggered by new

[jira] [Created] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

Henry Cai created KAFKA-3596: Summary: Kafka Streams: Window expiration needs to consider more than event time Key: KAFKA-3596 URL: https://issues.apache.org/jira/browse/KAFKA-3596 Project: Kafka

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

I think it's great that we're moving the interface to java and fixing some of the naming foibles. This isn't explicit in the KIP which just refers to the java package name (I think), but it looks like you are proposing adding a new authorizer jar for this new package and adding it as a dependency

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3595: - Description: Currently state store replication always go through a compact kafka topic. For some state

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3595: - Affects Version/s: (was: 0.9.0.1) 0.10.1.0 > Add capability to specify

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Cai updated KAFKA-3595: - Issue Type: Improvement (was: New Feature) > Add capability to specify replication compact option for

[jira] [Created] (KAFKA-3595) Add capability to specify replication compact option for stream store

Henry Cai created KAFKA-3595: Summary: Add capability to specify replication compact option for stream store Key: KAFKA-3595 URL: https://issues.apache.org/jira/browse/KAFKA-3595 Project: Kafka

[jira] [Commented] (KAFKA-2370) Add pause/unpause connector support

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

[jira] [Updated] (KAFKA-2370) Add pause/unpause connector support

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

[GitHub] kafka pull request: KAFKA-2370: kafka connect pause/resume API

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1087 --- 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-3594) Kafka new producer retries doesn't work in 0.9.0.1

[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas PHUNG updated KAFKA-3594: - Description: Hello, I'm encountering an issue with the new Producer on 0.9.0.1 client with a

[jira] [Created] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

Nicolas PHUNG created KAFKA-3594: Summary: Kafka new producer retries doesn't work in 0.9.0.1 Key: KAFKA-3594 URL: https://issues.apache.org/jira/browse/KAFKA-3594 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-3593) kafka.network.Processor throws ArrayIndexOutOfBoundsException

S Shan created KAFKA-3593: - Summary: kafka.network.Processor throws ArrayIndexOutOfBoundsException Key: KAFKA-3593 URL: https://issues.apache.org/jira/browse/KAFKA-3593 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3592) System tests - don't hardcode paths to scripts

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

[GitHub] kafka pull request: KAFKA-3592: System test - configurable paths [...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/1245 KAFKA-3592: System test - configurable paths [WIP] This patch adds logic for the following: - remove hard-coded paths to various scripts and jars in kafkatest service classes - provide a

[jira] [Created] (KAFKA-3592) System tests - don't hardcode paths to scripts

Geoff Anderson created KAFKA-3592: - Summary: System tests - don't hardcode paths to scripts Key: KAFKA-3592 URL: https://issues.apache.org/jira/browse/KAFKA-3592 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-3035) Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED

[ https://issues.apache.org/jira/browse/KAFKA-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3035: - Assignee: Liquan Pei > Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED >

[jira] [Commented] (KAFKA-1981) Make log compaction point configurable

[ https://issues.apache.org/jira/browse/KAFKA-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250643#comment-15250643 ] Eric Wasserman commented on KAFKA-1981: --- I apparently don't have any privileges to create a KIP in

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Jun/ Jay/ Gwen/ Harsha/ Ismael, As you guys have provided feedback on this earlier, could you review the KIP again? I have updated the PR as well. On Wed, Apr 20, 2016 at 1:01 PM, Ashish Singh wrote: > Hi Grant, > > On Tue, Apr

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Hi Grant, On Tue, Apr 19, 2016 at 8:13 AM, Grant Henke wrote: > Hi Ashish, > > Thanks for the updates. I have a few questions below: > > > Move following interfaces to new package, org.apche.kafka.authorizer. > > > >1. Authorizer > >2. Acl > >3. Operation > >

[jira] [Assigned] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

[ https://issues.apache.org/jira/browse/KAFKA-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3459: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Returning zero task configurations from a

[jira] [Commented] (KAFKA-3577) Partial cluster breakdown

[ https://issues.apache.org/jira/browse/KAFKA-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250531#comment-15250531 ] Kim Christensen commented on KAFKA-3577: Yeah, it seems a lot like the issue you referenced. We

[GitHub] kafka pull request: MINOR: Docs for ACLs over SSL auth and KAFKA_O...

GitHub user QwertyManiac opened a pull request: https://github.com/apache/kafka/pull/1244 MINOR: Docs for ACLs over SSL auth and KAFKA_OPTS

[GitHub] kafka pull request: Minor comment fix

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1243 Minor comment fix @ewencp You can merge this pull request into a Git repository by running: $ git pull https://github.com/Ishiihara/kafka docs Alternatively you can review and apply these

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper<K, V, K1> selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3589: - Labels: architecture (was: ) > KTable.count(final KeyValueMapper selector, String

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper<K, V, K1> selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3589: - Fix Version/s: 0.10.0.0 > KTable.count(final KeyValueMapper selector, String name)

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

See Changes: [cshapi] MINOR: Remove RollingBounceTest since its functionality is covered by -- [...truncated 3415 lines...] kafka.api.SaslPlaintextConsumerTest >

[jira] [Commented] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250473#comment-15250473 ] Jason Gustafson commented on KAFKA-3117: Looks like the first guess was nearer the mark. Although

[jira] [Comment Edited] (KAFKA-3568) KafkaProducer fails with timeout on message send()

[ https://issues.apache.org/jira/browse/KAFKA-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250386#comment-15250386 ] Gwen Shapira edited comment on KAFKA-3568 at 4/20/16 6:06 PM: -- Aha!

[jira] [Commented] (KAFKA-3568) KafkaProducer fails with timeout on message send()

[ https://issues.apache.org/jira/browse/KAFKA-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250386#comment-15250386 ] Gwen Shapira commented on KAFKA-3568: - Aha!

[jira] [Commented] (KAFKA-3568) KafkaProducer fails with timeout on message send()

[ https://issues.apache.org/jira/browse/KAFKA-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250342#comment-15250342 ] Greg Zoller commented on KAFKA-3568: Hi, Gwen... I am puzzled too. I didn't see any code that would

[GitHub] kafka pull request: MINOR: Remove RollingBounceTest since its func...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/1242 MINOR: Remove RollingBounceTest since its functionality is covered by the ReplicationTest system test RollingBounceTest is a system test that cannot be run reliably in unit tests and

[jira] [Updated] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3117: - Labels: newbie test transient-unit-test-failure (was: newbie test) > Fail test

[jira] [Updated] (KAFKA-3182) Failure in kafka.network.SocketServerTest.testSocketsCloseOnShutdown

[ https://issues.apache.org/jira/browse/KAFKA-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3182: - Labels: transient-unit-test-failure (was: ) > Failure in

[jira] [Updated] (KAFKA-3220) Failure in kafka.server.ClientQuotaManagerTest.testQuotaViolation

[ https://issues.apache.org/jira/browse/KAFKA-3220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3220: - Labels: transient-unit-test-failure (was: ) > Failure in

[jira] [Updated] (KAFKA-3155) Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack

[ https://issues.apache.org/jira/browse/KAFKA-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3155: - Labels: transient-unit-test-failure (was: ) > Transient Failure in >

[jira] [Updated] (KAFKA-3168) Failure in kafka.integration.PrimitiveApiTest.testPipelinedProduceRequests

[ https://issues.apache.org/jira/browse/KAFKA-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3168: - Labels: transient-unit-test-failure (was: ) > Failure in

[jira] [Updated] (KAFKA-2398) Transient test failure for SocketServerTest - Socket closed.

[ https://issues.apache.org/jira/browse/KAFKA-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2398: - Labels: transient-unit-test-failure (was: ) > Transient test failure for

[jira] [Updated] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2933: - Labels: transient-unit-test-failure (was: ) > Failure in

[jira] [Updated] (KAFKA-3034) kafka.api.PlaintextConsumerTest > testSeek FAILED

[ https://issues.apache.org/jira/browse/KAFKA-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3034: - Labels: transient-unit-test-failure (was: ) > kafka.api.PlaintextConsumerTest >

[jira] [Updated] (KAFKA-2059) ZookeeperConsumerConnectorTest.testBasic trasient failure

[ https://issues.apache.org/jira/browse/KAFKA-2059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2059: - Labels: newbie transient-unit-test-failure (was: newbie) >

[jira] [Updated] (KAFKA-435) Keep track of the transient test failure for Kafka-343 on Apache Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-435: Labels: transient-unit-test-failure (was: ) > Keep track of the transient test

[jira] [Updated] (KAFKA-1573) Transient test failures on LogTest.testCorruptLog

[ https://issues.apache.org/jira/browse/KAFKA-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1573: - Labels: transient-unit-test-failure (was: ) > Transient test failures on

[jira] [Updated] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer

[ https://issues.apache.org/jira/browse/KAFKA-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2943: - Labels: transient-unit-test-failure (was: ) > Transient Failure in

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

[ https://issues.apache.org/jira/browse/KAFKA-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2363: - Labels: newbie transient-unit-test-failure (was: newbie) >

[jira] [Updated] (KAFKA-2442) QuotasTest should not fail when cpu is busy

[ https://issues.apache.org/jira/browse/KAFKA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2442: - Labels: transient-unit-test-failure (was: ) > QuotasTest should not fail when

[jira] [Updated] (KAFKA-3035) Transient: kafka.api.PlaintextConsumerTest > testAutoOffsetReset FAILED

[ https://issues.apache.org/jira/browse/KAFKA-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3035: - Labels: transient-unit-test-failure (was: ) > Transient:

[jira] [Updated] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3246: - Labels: transient-unit-test-failure (was: ) > Transient Failure in >

[jira] [Updated] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-3420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3420: - Labels: transient-unit-test-failure (was: ) > Transient failure in

[jira] [Updated] (KAFKA-3591) JmxTool should exit out if a provided query matches no values

[ https://issues.apache.org/jira/browse/KAFKA-3591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Harsh J updated KAFKA-3591: --- Status: Patch Available (was: Open) > JmxTool should exit out if a provided query matches no values >

[jira] [Commented] (KAFKA-3591) JmxTool should exit out if a provided query matches no values

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

[GitHub] kafka pull request: KAFKA-3591: JmxTool should exit out if a provi...

GitHub user QwertyManiac opened a pull request: https://github.com/apache/kafka/pull/1241 KAFKA-3591: JmxTool should exit out if a provided query matches no values. Testing: I did manual tests by building locally and running the class against a remote 0.9.0.0 broker JMX URL.

[jira] [Commented] (KAFKA-3591) JmxTool should exit out if a provided query matches no values

[ https://issues.apache.org/jira/browse/KAFKA-3591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15249722#comment-15249722 ] Harsh J commented on KAFKA-3591: (Please assign to me) > JmxTool should exit out if a provided query

[jira] [Created] (KAFKA-3591) JmxTool should exit out if a provided query matches no values

Harsh J created KAFKA-3591: -- Summary: JmxTool should exit out if a provided query matches no values Key: KAFKA-3591 URL: https://issues.apache.org/jira/browse/KAFKA-3591 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-3572) Metrics of topics still exist when they have been deleted

[ https://issues.apache.org/jira/browse/KAFKA-3572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3572. Resolution: Duplicate This issue is fixed in KAFKA-1866 and similar issue is getting fixed

[jira] [Created] (KAFKA-3590) KafkaConsumer fails with "Messages are rejected since there are fewer in-sync replicas than required." when polling

Sergey Alaev created KAFKA-3590: --- Summary: KafkaConsumer fails with "Messages are rejected since there are fewer in-sync replicas than required." when polling Key: KAFKA-3590 URL:

  1   2   >