[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

[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

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] [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] [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] [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-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:

[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] [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] [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] [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] [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:

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] [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

[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

[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

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

[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

[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-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

[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

[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] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15249346#comment-15249346 ] Ismael Juma commented on KAFKA-3565: [~becket_qin], the results were reproducible when I ran them last

[jira] [Resolved] (KAFKA-3326) Error: A JNI error has occurred, please check your installation and try again

[ https://issues.apache.org/jira/browse/KAFKA-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3326. Resolution: Not A Problem > Error: A JNI error has occurred, please check your installation

[jira] [Comment Edited] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15249601#comment-15249601 ] Ismael Juma edited comment on KAFKA-3565 at 4/20/16 10:19 AM: -- I ran the

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15249601#comment-15249601 ] Ismael Juma commented on KAFKA-3565: I ran the tests a couple of times with various settings to check

[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

[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=15249727#comment-15249727 ] ASF GitHub Bot commented on KAFKA-3591: --- GitHub user QwertyManiac opened a pull request:

[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:

[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] [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] [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-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-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-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-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] [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-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-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-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-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-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-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-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-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-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-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

[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] [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

[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] [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] [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

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

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

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

[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

[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] [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

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

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

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

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=15250849#comment-15250849 ] ASF GitHub Bot commented on KAFKA-3117: --- GitHub user hachikuji opened a pull request:

[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-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

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

[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

[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:

[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

[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

[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:

[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

[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

[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

[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

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

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] [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

[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] [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:

[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!

[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

[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

[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] [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

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

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

[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

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] [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)

[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-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] [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

  1   2   >