[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788677#comment-15788677 ] Ewen Cheslack-Postava commented on KAFKA-3135: -- [~jeffwidman] I've updated the affected

[jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3135: - Affects Version/s: 0.10.1.0 0.9.0.1

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788664#comment-15788664 ] Ewen Cheslack-Postava commented on KAFKA-3539: --

[jira] [Commented] (KAFKA-4550) current trunk unstable

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788627#comment-15788627 ] Ewen Cheslack-Postava commented on KAFKA-4550: -- One of the failures reported in this issue is

[jira] [Commented] (KAFKA-4550) current trunk unstable

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788626#comment-15788626 ] Ewen Cheslack-Postava commented on KAFKA-4550: -- Seems like the second issue is still

[jira] [Commented] (KAFKA-4556) unordered messages when multiple topics are combined in single topic through stream

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788347#comment-15788347 ] Ewen Cheslack-Postava commented on KAFKA-4556: -- Can you be more specific about what your

[jira] [Commented] (KAFKA-4572) Kafka connect for windows is missing

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788234#comment-15788234 ] Ewen Cheslack-Postava commented on KAFKA-4572: -- [~vahid] The version he included looks

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2016-12-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15788229#comment-15788229 ] Ewen Cheslack-Postava commented on KAFKA-3297: -- Yeah, part of the improvement of KIP-49 seems

[jira] [Updated] (KAFKA-2196) remove roundrobin identical topic constraint in consumer coordinator

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2196: - Fix Version/s: 0.9.0.0 > remove roundrobin identical topic constraint in consumer

[jira] [Commented] (KAFKA-2196) remove roundrobin identical topic constraint in consumer coordinator

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786960#comment-15786960 ] Ewen Cheslack-Postava commented on KAFKA-2196: -- Based on git history, looks like 0.9.0.0,

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786948#comment-15786948 ] Ewen Cheslack-Postava commented on KAFKA-3297: -- [~jeffwidman] I don't think KIP-54 supercedes

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3297: - Component/s: consumer > More optimally balanced partition assignment strategy

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

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786941#comment-15786941 ] Ewen Cheslack-Postava commented on KAFKA-3502: -- I've seen this in a number of Jenkins builds

[jira] [Commented] (KAFKA-2019) Old consumer RoundRobinAssignor clusters by consumer

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786931#comment-15786931 ] Ewen Cheslack-Postava commented on KAFKA-2019: -- [~jeffwidman] I updated the title to clarify.

[jira] [Updated] (KAFKA-2019) Old consumer RoundRobinAssignor clusters by consumer

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2019: - Summary: Old consumer RoundRobinAssignor clusters by consumer (was:

[jira] [Commented] (KAFKA-2331) Kafka does not spread partitions in a topic among all consumers evenly

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786920#comment-15786920 ] Ewen Cheslack-Postava commented on KAFKA-2331: -- This seems like a separate issue -- it sounds

[jira] [Updated] (KAFKA-2331) Kafka does not spread partitions in a topic among all consumers evenly

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2331: - Component/s: (was: core) consumer clients >

[jira] [Comment Edited] (KAFKA-4567) Connect Producer and Consumer ignore ssl parameters configured for worker

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786745#comment-15786745 ] Ewen Cheslack-Postava edited comment on KAFKA-4567 at 12/30/16 3:13 AM:

[jira] [Commented] (KAFKA-4567) Connect Producer and Consumer ignore ssl parameters configured for worker

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786745#comment-15786745 ] Ewen Cheslack-Postava commented on KAFKA-4567: -- Given some future security features we may

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786719#comment-15786719 ] Ewen Cheslack-Postava commented on KAFKA-2260: -- [~wwarshaw] That sounds right -- the epoch

[jira] [Commented] (KAFKA-4570) How to transfer extended fields in producing or consuming requests.

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786713#comment-15786713 ] Ewen Cheslack-Postava commented on KAFKA-4570: -- [~zander] You're correct that Kafka does not

[jira] [Commented] (KAFKA-4571) Consumer fails to retrieve messages if started before producer

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786707#comment-15786707 ] Ewen Cheslack-Postava commented on KAFKA-4571: -- Since another consumer group ID consumes the

[jira] [Updated] (KAFKA-4115) Grow default heap settings for distributed Connect from 256M to 1G

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4115: - Fix Version/s: 0.10.2.0 > Grow default heap settings for distributed Connect from

[jira] [Commented] (KAFKA-3947) kafka-reassign-partitions.sh should support dumping current assignment

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786244#comment-15786244 ] Ewen Cheslack-Postava commented on KAFKA-3947: -- [~kawamuray] Any progress on this? It got

[jira] [Updated] (KAFKA-4404) Add knowledge of sign to numeric schema types

2016-12-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4404: - Fix Version/s: 0.10.2.0 Status: Patch Available (was: Open) > Add

[jira] [Resolved] (KAFKA-4092) retention.bytes should not be allowed to be less than segment.bytes

2016-12-27 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4092. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix Version/s:

[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

2016-12-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Labels: system-test-failure (was: ) > StreamsSmokeTest.test_streams intermittent

[jira] [Commented] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

2016-12-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15779574#comment-15779574 ] Ewen Cheslack-Postava commented on KAFKA-4551: -- Another case of this today:

[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

2016-12-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Assignee: Damian Guy > StreamsSmokeTest.test_streams intermittent failure >

[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

2016-12-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Fix Version/s: 0.10.1.2 > StreamsSmokeTest.test_streams intermittent failure >

[jira] [Commented] (KAFKA-4558) throttling_test fails if the producer starts too fast.

2016-12-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15776893#comment-15776893 ] Ewen Cheslack-Postava commented on KAFKA-4558: -- And this is also happening, albeit less

[jira] [Resolved] (KAFKA-4527) Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages

2016-12-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4527. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava > Transient failure of

[jira] [Commented] (KAFKA-4558) throttling_test fails if the producer starts too fast.

2016-12-23 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15773299#comment-15773299 ] Ewen Cheslack-Postava commented on KAFKA-4558: -- There's another case that looks basically the

[jira] [Updated] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

2016-12-17 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4553: - Status: Patch Available (was: Open) > Connect's round robin assignment produces

[jira] [Created] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

2016-12-17 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4553: Summary: Connect's round robin assignment produces undesirable distribution of connectors/tasks Key: KAFKA-4553 URL:

[jira] [Created] (KAFKA-4527) Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages

2016-12-12 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4527: Summary: Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages Key: KAFKA-4527 URL:

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

2016-12-12 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743246#comment-15743246 ] Ewen Cheslack-Postava commented on KAFKA-4526: -- re: related test failures, we're also seeing

[jira] [Created] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

2016-12-12 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4526: Summary: Transient failure in ThrottlingTest.test_throttled_reassignment Key: KAFKA-4526 URL: https://issues.apache.org/jira/browse/KAFKA-4526

[jira] [Resolved] (KAFKA-4140) Update system tests to allow running tests in parallel

2016-12-11 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4140. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-4154) Kafka Connect fails to shutdown if it has not completed startup

2016-12-06 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4154. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix Version/s:

[jira] [Resolved] (KAFKA-4306) Connect workers won't shut down if brokers are not available

2016-12-06 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4306. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-4161) Decouple flush and offset commits

2016-12-01 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4161. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-3008) Connect should parallelize task start/stop

2016-12-01 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3008. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-4397) Refactor Connect backing stores for thread-safety

2016-11-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4397. -- Resolution: Fixed Issue resolved by pull request 2123

[jira] [Updated] (KAFKA-4345) Run ducktape test for each pull request

2016-11-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4345: - Summary: Run ducktape test for each pull request (was: Run decktape test for

[jira] [Reopened] (KAFKA-4345) Run decktape test for each pull request

2016-11-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-4345: -- > Run decktape test for each pull request > ---

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

2016-11-29 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: - Fix Version/s: (was: 0.10.1.1) > Add missing 0.10.1.x upgrade tests and

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

2016-11-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15705874#comment-15705874 ] Ewen Cheslack-Postava commented on KAFKA-4450: -- Yeah, that makes sense [~ijuma], I think when

[jira] [Commented] (KAFKA-4007) Improve fetch pipelining for low values of max.poll.records

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15699134#comment-15699134 ] Ewen Cheslack-Postava commented on KAFKA-4007: -- [~enothereska] prefetching is based on the

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

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4450: Summary: Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks Key: KAFKA-4450 URL: https://issues.apache.org/jira/browse/KAFKA-4450

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

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15698985#comment-15698985 ] Ewen Cheslack-Postava commented on KAFKA-3959: -- [~toddpalino] That's fair, I think the

[jira] [Updated] (KAFKA-3963) Missing messages from the controller to brokers

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3963: - Fix Version/s: (was: 0.10.1.0) > Missing messages from the controller to

[jira] [Commented] (KAFKA-4449) Add Serializer/Deserializer for POJO

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15698784#comment-15698784 ] Ewen Cheslack-Postava commented on KAFKA-4449: -- [~habren] We actually try to keep

[jira] [Updated] (KAFKA-3400) Topic stop working / can't describe topic

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3400: - Fix Version/s: (was: 0.10.1.0) > Topic stop working / can't describe topic >

[jira] [Updated] (KAFKA-4063) Add support for infinite endpoints for range queries in Kafka Streams KV stores

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4063: - Fix Version/s: (was: 0.10.1.0) > Add support for infinite endpoints for range

[jira] [Updated] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3775: - Fix Version/s: (was: 0.10.1.0) > Throttle maximum number of tasks assigned to

[jira] [Updated] (KAFKA-4449) Add Serializer/Deserializer for POJO

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4449: - Fix Version/s: (was: 0.10.1.0) > Add Serializer/Deserializer for POJO >

[jira] [Updated] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4316: - Fix Version/s: (was: 0.10.1.0) > Kafka Streams 0.10.0.1 does not run on

[jira] [Updated] (KAFKA-4156) Not able to download tests jar of kafka and kafka-streams from maven repo.

2016-11-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4156: - Fix Version/s: (was: 0.10.0.1) (was: 0.10.0.0) > Not

[jira] [Updated] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

2016-11-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4403: - Assignee: Balint Molnar (was: Ewen Cheslack-Postava) > Update KafkaBasedLog to

[jira] [Commented] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

2016-11-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696374#comment-15696374 ] Ewen Cheslack-Postava commented on KAFKA-4403: -- Absolutely, I've assigned the ticket to you.

[jira] [Resolved] (KAFKA-4417) Update build dependencies for 0.10.2 cycle

2016-11-17 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4417. -- Resolution: Fixed Issue resolved by pull request 2144

[jira] [Commented] (KAFKA-4404) Add knowledge of sign to numeric schema types

2016-11-14 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664439#comment-15664439 ] Ewen Cheslack-Postava commented on KAFKA-4404: -- What is the motivation for this? Support for

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

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662738#comment-15662738 ] Ewen Cheslack-Postava commented on KAFKA-3959: -- [~granthenke] [~onurkaraman] [~toddpalino]

[jira] [Resolved] (KAFKA-3967) Excessive Network IO between Kafka brokers

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3967. -- Resolution: Invalid [~Krishna82] Closing this for now since we haven't heard

[jira] [Commented] (KAFKA-4021) system tests need to enable trace level logging for controller and state-change log

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662381#comment-15662381 ] Ewen Cheslack-Postava commented on KAFKA-4021: -- [~junrao] Is this actually reasonable to do

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662197#comment-15662197 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Sorry, missed that update with the

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662198#comment-15662198 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Sorry, missed that update with the

[jira] [Created] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4403: Summary: Update KafkaBasedLog to use new endOffsets consumer API Key: KAFKA-4403 URL: https://issues.apache.org/jira/browse/KAFKA-4403 Project: Kafka

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662153#comment-15662153 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Which code are you looking at for

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

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662147#comment-15662147 ] Ewen Cheslack-Postava commented on KAFKA-4401: -- [~becket_qin] We've already done much of this

[jira] [Resolved] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names

2016-11-12 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3829. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.1)

[jira] [Created] (KAFKA-4400) Prefix for sink task consumer groups should be configurable

2016-11-11 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4400: Summary: Prefix for sink task consumer groups should be configurable Key: KAFKA-4400 URL: https://issues.apache.org/jira/browse/KAFKA-4400 Project:

[jira] [Resolved] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging

2016-11-09 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4364. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

2016-11-08 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649280#comment-15649280 ] Ewen Cheslack-Postava commented on KAFKA-4381: -- Yeah, I don't want things to get bogged down

[jira] [Updated] (KAFKA-4284) Partitioner never closed by producer

2016-11-08 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4284: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved

[jira] [Commented] (KAFKA-4353) Add semantic types to Kafka Connect

2016-11-07 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645840#comment-15645840 ] Ewen Cheslack-Postava commented on KAFKA-4353: -- [~rhauch] Some of these make sense to me,

[jira] [Created] (KAFKA-4388) Connect key and value converters are listed without default values

2016-11-07 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4388: Summary: Connect key and value converters are listed without default values Key: KAFKA-4388 URL: https://issues.apache.org/jira/browse/KAFKA-4388

[jira] [Updated] (KAFKA-4383) Update API design subsection to reflect the current implementation of Producer/Consumer

2016-11-07 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4383: - Fix Version/s: (was: 0.10.0.1) (was: 0.10.0.0) >

[jira] [Updated] (KAFKA-4382) Fix broken fragments in site docs

2016-11-07 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4382: - Fix Version/s: (was: 0.10.0.1) > Fix broken fragments in site docs >

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

2016-11-06 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642780#comment-15642780 ] Ewen Cheslack-Postava commented on KAFKA-4381: -- I suppose since metrics can be considered

[jira] [Resolved] (KAFKA-4372) Kafka Connect REST API does not handle DELETE of connector with slashes in their names

2016-11-04 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4372. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix Version/s:

[jira] [Commented] (KAFKA-4371) Sporadic ConnectException shuts down the whole connect process

2016-11-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15634793#comment-15634793 ] Ewen Cheslack-Postava commented on KAFKA-4371: -- [~sagarrao] I'm a bit confused by the report.

[jira] [Updated] (KAFKA-4343) Connect REST API should expose whether each connector is a source or sink

2016-10-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4343: - Labels: needs-kip (was: ) > Connect REST API should expose whether each

[jira] [Created] (KAFKA-4343) Connect REST API should expose whether each connector is a source or sink

2016-10-25 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4343: Summary: Connect REST API should expose whether each connector is a source or sink Key: KAFKA-4343 URL: https://issues.apache.org/jira/browse/KAFKA-4343

[jira] [Updated] (KAFKA-4161) Decouple flush and offset commits

2016-10-25 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4161: - Assignee: Shikhar Bhushan (was: Ewen Cheslack-Postava) > Decouple flush and

[jira] [Commented] (KAFKA-4335) FileStreamSource Connector not working for large files (~ 1GB)

2016-10-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602851#comment-15602851 ] Ewen Cheslack-Postava commented on KAFKA-4335: -- Can you be more specific about what isn't

[jira] [Resolved] (KAFKA-4334) HashCode in SinkRecord not handling null timestamp, checks on value

2016-10-23 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4334. -- Resolution: Fixed > HashCode in SinkRecord not handling null timestamp, checks

[jira] [Updated] (KAFKA-4334) HashCode in SinkRecord not handling null timestamp, checks on value

2016-10-23 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4334: - Fix Version/s: 0.10.2.0 > HashCode in SinkRecord not handling null timestamp,

[jira] [Updated] (KAFKA-4290) High CPU caused by timeout overflow in WorkerCoordinator

2016-10-11 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4290: - Fix Version/s: 0.10.2.0 > High CPU caused by timeout overflow in

[jira] [Resolved] (KAFKA-4290) High CPU caused by timeout overflow in WorkerCoordinator

2016-10-11 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4290. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava > High CPU caused by

[jira] [Resolved] (KAFKA-4010) ConfigDef.toRst() should create sections for each group

2016-10-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4010. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-4280) Add REST resource for showing available connector plugin configs

2016-10-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562889#comment-15562889 ] Ewen Cheslack-Postava commented on KAFKA-4280: -- [~gwenshap] You can get the list of configs

[jira] [Commented] (KAFKA-3808) Transient failure in ReplicaVerificationToolTest

2016-10-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562803#comment-15562803 ] Ewen Cheslack-Postava commented on KAFKA-3808: -- Seen again running against trunk commit

[jira] [Resolved] (KAFKA-4285) ReplicaVerificationToolTest.test_replica_lags: Timed out waiting to reach non-zero number of replica lags.

2016-10-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4285. -- Resolution: Duplicate > ReplicaVerificationToolTest.test_replica_lags: Timed

[jira] [Created] (KAFKA-4285) ReplicaVerificationToolTest.test_replica_lags: Timed out waiting to reach non-zero number of replica lags.

2016-10-10 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4285: Summary: ReplicaVerificationToolTest.test_replica_lags: Timed out waiting to reach non-zero number of replica lags. Key: KAFKA-4285 URL:

[jira] [Resolved] (KAFKA-4251) Test driver not launching in Vagrant 1.8.6

2016-10-04 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4251. -- Resolution: Fixed Fix Version/s: 0.10.2.0 0.10.1.0

[jira] [Commented] (KAFKA-4202) Facing error while trying to create the Producer.

2016-09-22 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514380#comment-15514380 ] Ewen Cheslack-Postava commented on KAFKA-4202: -- It looks like you may have mismatched

[jira] [Updated] (KAFKA-4202) Facing error while trying to create the Producer.

2016-09-22 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4202: - Assignee: (was: Ewen Cheslack-Postava) > Facing error while trying to create

[jira] [Updated] (KAFKA-4202) Facing error while trying to create the Producer.

2016-09-22 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4202: - Component/s: (was: KafkaConnect) > Facing error while trying to create the

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