[jira] [Updated] (KAFKA-3302) Pass kerberos keytab and principal as part of client config

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3302: - Fix Version/s: (was: 0.10.2.0) > Pass kerberos keytab and principal as part

[jira] [Updated] (KAFKA-4495) ThreadCache.maybeEvict can become an infinite loop

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4495: - Fix Version/s: (was: 0.10.2.0) > ThreadCache.maybeEvict can become an

[jira] [Updated] (KAFKA-3478) Finer Stream Flow Control

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3478: - Fix Version/s: (was: 0.10.2.0) > Finer Stream Flow Control >

[jira] [Updated] (KAFKA-1332) Add functionality to the offsetsBeforeTime() API

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1332: - Fix Version/s: (was: 0.10.2.0) > Add functionality to the offsetsBeforeTime()

[jira] [Updated] (KAFKA-3262) Make KafkaStreams debugging friendly

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3262: - Fix Version/s: (was: 0.10.2.0) > Make KafkaStreams debugging friendly >

[jira] [Updated] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4717: - Resolution: Fixed Fix Version/s: 0.10.1.2 0.10.3.0

[jira] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3959: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 >

[jira] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-4717: Assignee: Ewen Cheslack-Postava > connect jars are missing LICENSE/NOTICE

[jira] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4717: - Status: Patch Available (was: Open) > connect jars are missing LICENSE/NOTICE

[jira] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4689: - Priority: Major (was: Blocker) > OffsetValidationTest fails validation with

[jira] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4689: - Fix Version/s: (was: 0.10.2.0) > OffsetValidationTest fails validation with

[jira] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4717: - Fix Version/s: 0.10.2.0 > connect jars are missing LICENSE/NOTICE files >

[jira] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files

2017-01-31 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4717: - Priority: Blocker (was: Major) > connect jars are missing LICENSE/NOTICE files >

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

2017-01-28 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15844221#comment-15844221 ] Ewen Cheslack-Postava commented on KAFKA-4689: -- Actually, the error message in the latest

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

2017-01-28 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15844219#comment-15844219 ] Ewen Cheslack-Postava commented on KAFKA-4689: -- [~hachikuji] Any further thoughts on this

[jira] [Updated] (KAFKA-4679) Remove unstable markers from Connect APIs

2017-01-27 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4679: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved

[jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment

2017-01-27 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3733: - Assignee: Adrian Muraru > Avoid long command lines by setting CLASSPATH in

[jira] [Updated] (KAFKA-4679) Remove unstable markers from Connect APIs

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4679: - Status: Patch Available (was: Open) > Remove unstable markers from Connect APIs

[jira] [Updated] (KAFKA-4679) Remove unstable markers from Connect APIs

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4679: - Priority: Blocker (was: Major) > Remove unstable markers from Connect APIs >

[jira] [Updated] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4450: - Status: Patch Available (was: Open) > Add missing 0.10.1.x upgrade tests and

[jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: - Status: Patch Available (was: Reopened) > Support single message transforms in

[jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: - Priority: Blocker (was: Major) > Support single message transforms in Kafka

[jira] [Reopened] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-3209: -- Assignee: Ewen Cheslack-Postava (was: Shikhar Bhushan) > Support single

[jira] [Commented] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840259#comment-15840259 ] Ewen Cheslack-Postava commented on KAFKA-4517: -- oh, I missed the PR, but yeah either retitle

[jira] [Updated] (KAFKA-4667) Connect should create internal topics

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4667: - Summary: Connect should create internal topics (was: Connect (and Stream?)

[jira] [Updated] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

2017-01-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4450: - Priority: Blocker (was: Critical) > Add missing 0.10.1.x upgrade tests and

[jira] [Commented] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839234#comment-15839234 ] Ewen Cheslack-Postava commented on KAFKA-4680: -- I think it's totally reasonable to try to

[jira] [Updated] (KAFKA-4578) Upgrade notes for 0.10.2.0

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4578: - Reviewer: Ewen Cheslack-Postava > Upgrade notes for 0.10.2.0 >

[jira] [Commented] (KAFKA-4578) Upgrade notes for 0.10.2.0

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839224#comment-15839224 ] Ewen Cheslack-Postava commented on KAFKA-4578: -- [~ijuma] Looking at 0.10.2.0 blockers and

[jira] [Commented] (KAFKA-3567) Add --security-protocol option to console consumer and producer

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839184#comment-15839184 ] Ewen Cheslack-Postava commented on KAFKA-3567: -- [~bharatviswa] But you still need to modify

[jira] [Resolved] (KAFKA-4026) consumer block

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4026. -- Resolution: Not A Problem Assignee: Ewen Cheslack-Postava Fix

[jira] [Updated] (KAFKA-2329) Consumers balance fails when multiple consumers are started simultaneously.

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2329: - Fix Version/s: (was: 0.8.1.2) Removing the 0.8.1.2 fix version since it is

[jira] [Commented] (KAFKA-3103) Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839118#comment-15839118 ] Ewen Cheslack-Postava commented on KAFKA-3103: -- [~guozhang] I don't think we've seen this

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

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3103: - Fix Version/s: (was: 0.9.0.1) Removing invalid fix version > Transient

[jira] [Commented] (KAFKA-3567) Add --security-protocol option to console consumer and producer

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839117#comment-15839117 ] Ewen Cheslack-Postava commented on KAFKA-3567: -- I think I'm in favor of closing this as Won't

[jira] [Updated] (KAFKA-3567) Add --security-protocol option to console consumer and producer

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3567: - Labels: needs-kip (was: ) Fix Version/s: (was: 0.9.0.0) Removing

[jira] [Updated] (KAFKA-2615) Poll() method is broken wrt time

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2615: - Resolution: Implemented Fix Version/s: (was: 0.8.2.1)

[jira] [Commented] (KAFKA-2615) Poll() method is broken wrt time

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839112#comment-15839112 ] Ewen Cheslack-Postava commented on KAFKA-2615: -- Semi unintentionally, KAFKA-2677 ran into the

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1843: - Fix Version/s: (was: 0.8.2.1) > Metadata fetch/refresh in new producer should

[jira] [Updated] (KAFKA-2602) Incorrect descriptions about serializers for ProducerConfig in 0.8.2 and 0.8.3 documentation

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2602: - Resolution: Won't Fix Assignee: Ewen Cheslack-Postava Fix

[jira] [Updated] (KAFKA-1729) add doc for Kafka-based offset management in 0.8.2

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1729: - Resolution: Fixed Status: Resolved (was: Patch Available) A bit unclear

[jira] [Updated] (KAFKA-3071) Kafka Server 0.8.2 ERROR OOME with siz

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3071: - Fix Version/s: (was: 0.8.2.0) Removing invalid fix version > Kafka Server

[jira] [Resolved] (KAFKA-2501) getting one test failed when building apache kafka

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2501. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava Fix

[jira] [Commented] (KAFKA-2501) getting one test failed when building apache kafka

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839095#comment-15839095 ] Ewen Cheslack-Postava commented on KAFKA-2501: -- Exact duplicate by same reporter > getting

[jira] [Resolved] (KAFKA-1568) Blackspider

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1568. -- Resolution: Won't Fix Assignee: Ewen Cheslack-Postava Fix

[jira] [Updated] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

2017-01-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4083: - Fix Version/s: (was: 0.10.0.0) (was: 0.9.0.0)

[jira] [Commented] (KAFKA-4666) Failure test for Kafka configured for consistency vs availability

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837218#comment-15837218 ] Ewen Cheslack-Postava commented on KAFKA-4666: -- [~ecesena] Absolutely -- if you're very

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836969#comment-15836969 ] Ewen Cheslack-Postava commented on KAFKA-4477: -- [~ctrochalakis] You should see updated

[jira] [Deleted] (KAFKA-4624) Streams smoke tests fails when there is only 1 broker

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava deleted KAFKA-4624: - > Streams smoke tests fails when there is only 1 broker >

[jira] [Created] (KAFKA-4694) Streams smoke tests fails when there is only 1 broker

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4694: Summary: Streams smoke tests fails when there is only 1 broker Key: KAFKA-4694 URL: https://issues.apache.org/jira/browse/KAFKA-4694 Project: Kafka

[jira] [Deleted] (KAFKA-4625) Streams smoke tests fails when there is only 1 broker

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava deleted KAFKA-4625: - > Streams smoke tests fails when there is only 1 broker >

[jira] [Commented] (KAFKA-4625) Streams smoke tests fails when there is only 1 broker

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836830#comment-15836830 ] Ewen Cheslack-Postava commented on KAFKA-4625: -- [~mjsax] [~enothereska] Something seems funky

[jira] [Resolved] (KAFKA-2307) Drop ConsumerOffsetChecker completely

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2307. -- Resolution: Duplicate Fix Version/s: (was: 0.11.0.0) > Drop

[jira] [Commented] (KAFKA-2307) Drop ConsumerOffsetChecker completely

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836813#comment-15836813 ] Ewen Cheslack-Postava commented on KAFKA-2307: -- This one is actually older, but other one is

[jira] [Resolved] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4517. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava Fix

[jira] [Commented] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836809#comment-15836809 ] Ewen Cheslack-Postava commented on KAFKA-4517: -- Duplicate of KAFKA-3356 (and KAFKA-2307 for

[jira] [Updated] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3356: - Priority: Blocker (was: Major) > Remove ConsumerOffsetChecker, deprecated in

[jira] [Commented] (KAFKA-4667) Connect (and Stream?) should create internal topics with availability or consistency properly set

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836801#comment-15836801 ] Ewen Cheslack-Postava commented on KAFKA-4667: -- [~ecesena] Not sure I understand exactly --

[jira] [Updated] (KAFKA-4667) Connect (and Stream?) should create internal topics with availability or consistency properly set

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4667: - Component/s: KafkaConnect > Connect (and Stream?) should create internal topics

[jira] [Commented] (KAFKA-4666) Failure test for Kafka configured for consistency vs availability

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836790#comment-15836790 ] Ewen Cheslack-Postava commented on KAFKA-4666: -- [~ecesena] ducktape test to validate this is

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836738#comment-15836738 ] Ewen Cheslack-Postava commented on KAFKA-4557: -- [~salaev] Can you give an idea of the

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836729#comment-15836729 ] Ewen Cheslack-Postava commented on KAFKA-4401: -- [~becket_qin] I would actually like to

[jira] [Resolved] (KAFKA-4673) Python VerifiableConsumer service has thread-safety bug for event_handlers

2017-01-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4673. -- Resolution: Fixed Fix Version/s: 0.10.2.0 0.10.1.2

[jira] [Resolved] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-20 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3209. -- Resolution: Fixed Fixed in https://github.com/apache/kafka/pull/2374 > Support

[jira] [Created] (KAFKA-4679) Remove unstable markers from Connect APIs

2017-01-20 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4679: Summary: Remove unstable markers from Connect APIs Key: KAFKA-4679 URL: https://issues.apache.org/jira/browse/KAFKA-4679 Project: Kafka

[jira] [Created] (KAFKA-4673) Python VerifiableConsumer service has thread-safety bug for event_handlers

2017-01-18 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4673: Summary: Python VerifiableConsumer service has thread-safety bug for event_handlers Key: KAFKA-4673 URL: https://issues.apache.org/jira/browse/KAFKA-4673

[jira] [Commented] (KAFKA-3513) Transient failure of OffsetValidationTest

2017-01-17 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826869#comment-15826869 ] Ewen Cheslack-Postava commented on KAFKA-3513: -- This continues to pop up occasionally:

[jira] [Assigned] (KAFKA-4625) Streams smoke tests fails when there is only 1 broker

2017-01-17 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-4625: Assignee: Ewen Cheslack-Postava (was: Hojjat Jafarpour) > Streams smoke

[jira] [Updated] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

2017-01-16 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4632: - Component/s: KafkaConnect > Kafka Connect WorkerSinkTask.closePartitions doesn't

[jira] [Updated] (KAFKA-4514) Add Codec for ZStandard Compression

2017-01-16 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4514: - Assignee: Lee Dongjin > Add Codec for ZStandard Compression >

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

2017-01-16 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824483#comment-15824483 ] Ewen Cheslack-Postava commented on KAFKA-3992: -- [~darmag] That is a bug in the Kafka logstash

[jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3959: - Affects Version/s: 0.10.1.2 0.10.0.2

[jira] [Updated] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4221: - Fix Version/s: (was: 0.10.2.0) This is a nice improvement, but not strictly

[jira] [Commented] (KAFKA-4005) Add per topic compression ratio in broker and consumer.

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823556#comment-15823556 ] Ewen Cheslack-Postava commented on KAFKA-4005: -- I agree this would be useful, but moving out

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823557#comment-15823557 ] Ewen Cheslack-Postava commented on KAFKA-4084: -- [~tcrayford-heroku] Answer to the above

[jira] [Commented] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823551#comment-15823551 ] Ewen Cheslack-Postava commented on KAFKA-4178: -- [~benstopford] This will now be pushed to

[jira] [Updated] (KAFKA-4182) Move the change logger our of RocksDB stores

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4182: - Fix Version/s: (was: 0.10.2.0) The fixVersion has been set but there is no

[jira] [Commented] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823548#comment-15823548 ] Ewen Cheslack-Postava commented on KAFKA-4184: -- Are there more recent cases of this? I don't

[jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4292: - Fix Version/s: (was: 0.10.2.0) Moving out of a target fixVersion -- KIP-86

[jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4292: - Summary: KIP-86: Configurable SASL callback handlers (was: Configurable SASL

[jira] [Updated] (KAFKA-4363) Add document for dynamic JAAS configuration property sasl.jaas.config

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4363: - Priority: Blocker (was: Major) > Add document for dynamic JAAS configuration

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823518#comment-15823518 ] Ewen Cheslack-Postava commented on KAFKA-4401: -- Could we make incremental progress on this by

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823513#comment-15823513 ] Ewen Cheslack-Postava commented on KAFKA-4421: -- [~ijuma] A) should this be set up for the

[jira] [Updated] (KAFKA-4501) Support Java 9

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4501: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 Moving to 0.10.3.0

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Priority: Blocker (was: Major) Bumping to blocker -- this is pretty basic

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Affects Version/s: 0.10.1.1 > Consumer.position returns incorrect results for

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Affects Version/s: 0.10.0.2 > Consumer.position returns incorrect results for

[jira] [Commented] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823473#comment-15823473 ] Ewen Cheslack-Postava commented on KAFKA-4563: -- [~enothereska]

[jira] [Updated] (KAFKA-4580) Change one SASL system test to use new JAAS config property

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4580: - Priority: Blocker (was: Major) [~rsivaram] Moving to blocker since it'd be ideal

[jira] [Updated] (KAFKA-4589) Add documentation for SASL/SCRAM

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4589: - Priority: Blocker (was: Major) > Add documentation for SASL/SCRAM >

[jira] [Commented] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823463#comment-15823463 ] Ewen Cheslack-Postava commented on KAFKA-4596: -- [~ijuma] [~tcrayford-heroku] This doesn't

[jira] [Updated] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4602: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 [~radai] I'm going

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823442#comment-15823442 ] Ewen Cheslack-Postava commented on KAFKA-4614: -- [~ijuma] Seems like you started tracking work

[jira] [Commented] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823431#comment-15823431 ] Ewen Cheslack-Postava commented on KAFKA-4630: -- [~cmccabe] Should this be a blocker since the

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4631: - Priority: Minor (was: Major) > Refresh consumer metadata more frequently for

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823429#comment-15823429 ] Ewen Cheslack-Postava commented on KAFKA-4631: -- Would this be a constant timeout or yet

[jira] [Updated] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1313: - Assignee: (was: Geoff Anderson) Priority: Major (was: Critical)

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1694: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > KIP-4: Command

[jira] [Commented] (KAFKA-2500) Expose fetch response high watermark in ConsumerRecords

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823420#comment-15823420 ] Ewen Cheslack-Postava commented on KAFKA-2500: -- [~hachikuji] [~rmetzger] [~willf] In light of

[jira] [Commented] (KAFKA-3190) KafkaProducer should not invoke callback in send()

2017-01-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823415#comment-15823415 ] Ewen Cheslack-Postava commented on KAFKA-3190: -- [~becket_qin] Do you want to revisit this?

<    1   2   3   4   5   6   7   8   9   10   >