[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&focusedCommentId=15249601#comment-15249601 ] Ismael Juma edited comment on KAFKA-3565 at 4/20/16 10:19 AM: --

[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&focusedCommentId=15249601#comment-15249601 ] Ismael Juma commented on KAFKA-3565: I ran the tests a couple of times with various se

[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: https://issues.apache.org/jira/brow

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

[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&focusedCommentId=15249722#comment-15249722 ] Harsh J commented on KAFKA-3591: (Please assign to me) > JmxTool should exit out if a pro

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

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

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

[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 > kafka.produ

[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: kafka.api.PlaintextConsu

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

[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) > ProducerSendTest.testC

[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 kafka.producer

[jira] [Updated] (KAFKA-3484) Transient failure in SslConsumerTest.testListTopics

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

[jira] [Updated] (KAFKA-2081) testUncleanLeaderElectionEnabledByTopicOverride transient failure

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

[jira] [Updated] (KAFKA-2054) Fix Kafka transient unit test failures

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

[jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2059: - Summary: ZookeeperConsumerConnectorTest.testBasic transient failure (was: Zookeep

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

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

[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 kafka.api.PlaintextConsu

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

[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 kafka.integration.Primit

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

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

[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 > kafka.integ

[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 kafka.server.ClientQuota

[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 kafka.network.SocketServ

[jira] [Updated] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

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

[jira] [Updated] (KAFKA-3290) WorkerSourceTask testCommit transient failure

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

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

[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: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > QuotasTest should no

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

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

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1242 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-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&focusedCommentId=15250342#comment-15250342 ] Greg Zoller commented on KAFKA-3568: Hi, Gwen... I am puzzled too. I didn't see any c

[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&focusedCommentId=15250386#comment-15250386 ] Gwen Shapira commented on KAFKA-3568: - Aha! https://github.com/spotify/docker-kafka/

[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&focusedCommentId=15250386#comment-15250386 ] Gwen Shapira edited comment on KAFKA-3568 at 4/20/16 6:06 PM: --

[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&focusedCommentId=15250473#comment-15250473 ] Jason Gustafson commented on KAFKA-3117: Looks like the first guess was nearer the

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

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper 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) throw NPE > ---

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper 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 name) throw NPE

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

[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 [Motivation](http://mail-archives.apache.org/mod_mbox/kafka-users/201604.mbox/%3CCAFXAVc4%2B6Z863K1%2B-2h1aFaAjnMb3jjCu_A9RvWdVnHZg1s1SQ%40mail

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

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

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

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 > >4. PermissionType > >

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 19, 2016 at 8:13 AM, Gra

[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&focusedCommentId=15250643#comment-15250643 ] Eric Wasserman commented on KAFKA-1981: --- I apparently don't have any privileges to c

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

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

[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&focusedCommentId=15250663#comment-15250663 ] ASF GitHub Bot commented on KAFKA-3592: --- GitHub user granders opened a pull request:

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

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

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

[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&focusedCommentId=15250720#comment-15250720 ] ASF GitHub Bot commented on KAFKA-2370: --- Github user asfgit closed the pull request

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

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

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

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

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

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

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

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

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

[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] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

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

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

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

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

[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

[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&focusedCommentId=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 Alte

[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&focusedCommentId=15250884#comment-15250884 ] S Shan commented on KAFKA-3593: --- After I created this issue, I then found out that this is a

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

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 common in clients jar makes

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

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 that

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

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

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

[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&focusedCommentId=15250994#comment-15250994 ] ASF GitHub Bot commented on KAFKA-3117: --- Github user asfgit closed the pull request

[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&focusedCommentId=15250995#comment-15250995 ] Guozhang Wang commented on KAFKA-3117: -- PR merged, leaving this ticket open for anoth

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

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

[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&focusedCommentId=15251000#comment-15251000 ] ASF GitHub Bot commented on KAFKA-3579: --- Github user vahidhashemian closed the pull

[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&focusedCommentId=15251001#comment-15251001 ] ASF GitHub Bot commented on KAFKA-3579: --- GitHub user vahidhashemian reopened a pull

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 2

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

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

[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&focusedCommentId=15251033#comment-15251033 ] ASF GitHub Bot commented on KAFKA-3459: --- GitHub user Ishiihara opened a pull request

  1   2   >