[jira] [Created] (KAFKA-7538) Improve locking model used to update ISRs and HW

2018-10-24 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-7538: - Summary: Improve locking model used to update ISRs and HW Key: KAFKA-7538 URL: https://issues.apache.org/jira/browse/KAFKA-7538 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2018-10-24 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660868#comment-16660868 ] Sönke Liebau edited comment on KAFKA-7509 at 10/24/18 12:24 PM: Hi

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable

2018-10-24 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-7536: Description: I have a GlobalKTable that's defined as {code} GlobalKTable userIdsByEmail

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable

2018-10-24 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-7536: Summary: TopologyTestDriver cannot pre-populate KTable (was: TopologyTestDriver cannot

[jira] [Commented] (KAFKA-3932) Consumer fails to consume in a round robin fashion

2018-10-24 Thread CHIENHSING WU (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662386#comment-16662386 ] CHIENHSING WU commented on KAFKA-3932: -- I am going ahead to implement the change I propose. I don't

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable

2018-10-24 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662413#comment-16662413 ] Dmitry Minkovsky commented on KAFKA-7536: - Thank you. Yes, disabling cache makes the issue go

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662460#comment-16662460 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] we might just want to update the

[jira] [Commented] (KAFKA-7538) Improve locking model used to update ISRs and HW

2018-10-24 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662538#comment-16662538 ] Jun Rao commented on KAFKA-7538: [~rsivaram], thanks for the analysis. I agree that approach 2) is

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662555#comment-16662555 ] Dong Lin commented on KAFKA-7481: - Thanks [~ewencp] for the suggestion. I agree. Will do this in the

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable

2018-10-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7536: --- Summary: TopologyTestDriver cannot pre-populate KTable or GlobalKTable (was:

[jira] [Updated] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7535: --- Fix Version/s: 2.0.2 2.1.1 > KafkaConsumer doesn't report records-lag if

[jira] [Updated] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7535: --- Labels: regression (was: ) > KafkaConsumer doesn't report records-lag if isolation.level is

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable

2018-10-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662566#comment-16662566 ] Matthias J. Sax commented on KAFKA-7536: Thanks for the information! Really helpful. >

[jira] [Updated] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7481: Priority: Blocker (was: Critical) > Consider options for safer upgrade of offset commit value schema >

[jira] [Commented] (KAFKA-3932) Consumer fails to consume in a round robin fashion

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662625#comment-16662625 ] ASF GitHub Bot commented on KAFKA-3932: --- chienhsingwu opened a new pull request #5838: KAFKA-3932 -

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662812#comment-16662812 ] Ismael Juma commented on KAFKA-7535: cc [~lindong] [~omkreddy] in case you think this is important

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663144#comment-16663144 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] I think anything here ends up

[jira] [Updated] (KAFKA-7313) StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7313: Fix Version/s: 2.1.1 > StopReplicaRequest should attempt to remove future replica for the partition >

[jira] [Created] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7539: --- Summary: ConsumerBounceTest.testClose transient failure Key: KAFKA-7539 URL: https://issues.apache.org/jira/browse/KAFKA-7539 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7535: Fix Version/s: 2.1.0 > KafkaConsumer doesn't report records-lag if isolation.level is read_committed >

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Description: {code:java} java.lang.ArrayIndexOutOfBoundsException: -1 at

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Labels: system-test-failure (was: ) > ConsumerBounceTest.testClose transient failure >

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Labels: (was: newbie) > ConsumerBounceTest.testClose transient failure >

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Fix Version/s: (was: 0.9.0.0) > ConsumerBounceTest.testClose transient failure >

[jira] [Assigned] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7539: --- Assignee: (was: Fangmin Lv) > ConsumerBounceTest.testClose transient failure >

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Labels: (was: system-test-failure) > ConsumerBounceTest.testClose transient failure >

[jira] [Created] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7541: --- Summary: Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Key: KAFKA-7541 URL: https://issues.apache.org/jira/browse/KAFKA-7541

[jira] [Updated] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7540: Labels: flaky-test (was: ) > Transient failure: kafka.api.ConsumerBounceTest.testClose >

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662916#comment-16662916 ] Dong Lin commented on KAFKA-7535: - [~ijuma] Thanks for the notice. Yeah I would like to have this issue

[jira] [Resolved] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7539. - Resolution: Invalid Reviewer: (was: Jason Gustafson) Cloning to create this issue was a

[jira] [Updated] (KAFKA-7539) ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Labels: flaky-test (was: ) > ConsumerBounceTest.testClose transient failure >

[jira] [Created] (KAFKA-7543) Kafka Connect JDBC Sink failing to establish connection to Topic, while the connection is working fine with standalone consumer

2018-10-24 Thread Kashyap Ivaturi (JIRA)
Kashyap Ivaturi created KAFKA-7543: -- Summary: Kafka Connect JDBC Sink failing to establish connection to Topic, while the connection is working fine with standalone consumer Key: KAFKA-7543 URL:

[jira] [Created] (KAFKA-7544) Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7544: --- Summary: Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails Key: KAFKA-7544 URL:

[jira] [Updated] (KAFKA-7539) [deleted] ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7539: Summary: [deleted] ConsumerBounceTest.testClose transient failure (was:

[jira] [Created] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7540: --- Summary: Transient failure: kafka.api.ConsumerBounceTest.testClose Key: KAFKA-7540 URL: https://issues.apache.org/jira/browse/KAFKA-7540 Project: Kafka Issue

[jira] [Closed] (KAFKA-7539) [deleted] ConsumerBounceTest.testClose transient failure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-7539. --- > [deleted] ConsumerBounceTest.testClose transient failure >

[jira] [Updated] (KAFKA-7542) Transient Failure: kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure

2018-10-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7542: Labels: flaky-test (was: ) > Transient Failure: >

[jira] [Created] (KAFKA-7542) Transient Failure: kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure

2018-10-24 Thread John Roesler (JIRA)
John Roesler created KAFKA-7542: --- Summary: Transient Failure: kafka.server.GssapiAuthenticationTest.testServerAuthenticationFailure Key: KAFKA-7542 URL: https://issues.apache.org/jira/browse/KAFKA-7542

[jira] [Created] (KAFKA-7545) Use auth_to_local rules from krb5.conf

2018-10-24 Thread Pradeep Bansal (JIRA)
Pradeep Bansal created KAFKA-7545: - Summary: Use auth_to_local rules from krb5.conf Key: KAFKA-7545 URL: https://issues.apache.org/jira/browse/KAFKA-7545 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663274#comment-16663274 ] Dong Lin commented on KAFKA-7481: - Hey [~ewencp], regarding the change for 2.1.0 release, say we don't

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661786#comment-16661786 ] ASF GitHub Bot commented on KAFKA-7535: --- lambdaliu opened a new pull request #5835:

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-24 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661789#comment-16661789 ] lambdaliu commented on KAFKA-7535: -- bug introduced from this

[jira] [Updated] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7481: Fix Version/s: 2.1.0 > Consider options for safer upgrade of offset commit value schema >

[jira] [Updated] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7481: Priority: Critical (was: Blocker) > Consider options for safer upgrade of offset commit value schema >

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

2018-10-24 Thread Jonathan Santilli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661931#comment-16661931 ] Jonathan Santilli commented on KAFKA-7165: -- Hello Juan Rao, I would like to continue working on

[jira] [Comment Edited] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

2018-10-24 Thread Jonathan Santilli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661931#comment-16661931 ] Jonathan Santilli edited comment on KAFKA-7165 at 10/24/18 8:31 AM:

[jira] [Created] (KAFKA-7537) Only include live brokers in the UpdateMetadataRequest sent to existing brokers if there is no change in the partition states

2018-10-24 Thread Zhanxiang (Patrick) Huang (JIRA)
Zhanxiang (Patrick) Huang created KAFKA-7537: Summary: Only include live brokers in the UpdateMetadataRequest sent to existing brokers if there is no change in the partition states Key: KAFKA-7537