[jira] [Resolved] (KAFKA-6796) Surprising UNKNOWN_TOPIC error for produce/fetch requests to non-replicas

2018-04-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6796. Resolution: Fixed Fix Version/s: 1.2.0 > Surprising UNKNOWN_TOPIC error for produce/fetch

[jira] [Commented] (KAFKA-6796) Surprising UNKNOWN_TOPIC error for produce/fetch requests to non-replicas

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16451660#comment-16451660 ] ASF GitHub Bot commented on KAFKA-6796: --- ijuma closed pull request #4883: KAFKA-6796; Fix surprising

[jira] [Assigned] (KAFKA-6824) Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener

2018-04-24 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-6824: --- Assignee: Rajini Sivaram > Transient failure in

[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2018-04-24 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16451438#comment-16451438 ] Apurva Mehta commented on KAFKA-6817: - Hi [~odinodinodin]. Did you try setting the

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16451356#comment-16451356 ] ASF GitHub Bot commented on KAFKA-6376: --- guozhangwang closed pull request #4922: KAFKA-6376:

[jira] [Commented] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

2018-04-24 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16451257#comment-16451257 ] Guozhang Wang commented on KAFKA-6819: -- Thanks for your feedbacks John. For 2.a), the only reason

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16451258#comment-16451258 ] ASF GitHub Bot commented on KAFKA-6761: --- bbejeck opened a new pull request #4923: KAFKA-6761: Part 1

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-04-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 4/24/18 9:13 PM: Patch looks good to me.

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-04-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 4/24/18 9:12 PM: +1 from me. was (Author:

[jira] [Issue Comment Deleted] (KAFKA-6824) Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener

2018-04-24 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-6824: Comment: was deleted (was: Another failure of this test, but now a different reason: (JDK 8)

[jira] [Updated] (KAFKA-6824) Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener

2018-04-24 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-6824: Description: Observed two failures of this test (both in PR builds) :( *Failure #1: (JDK 7 and

[jira] [Commented] (KAFKA-6820) Improve on StreamsMetrics Public APIs

2018-04-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450473#comment-16450473 ] John Roesler commented on KAFKA-6820: - I'm +1 on separating the built-in metrics from the methods we

[jira] [Commented] (KAFKA-6824) Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener

2018-04-24 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450453#comment-16450453 ] Anna Povzner commented on KAFKA-6824: - Another failure of this test, but now a different reason: (JDK

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

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

[jira] [Commented] (KAFKA-6705) producer.send() should not block due to metadata not available

2018-04-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450350#comment-16450350 ] Dong Lin commented on KAFKA-6705: - I am going to close this ticket. Thinking about this more, the benefit

[jira] [Resolved] (KAFKA-6705) producer.send() should not block due to metadata not available

2018-04-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6705. - Resolution: Won't Fix > producer.send() should not block due to metadata not available >

[jira] [Commented] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450337#comment-16450337 ] ASF GitHub Bot commented on KAFKA-6677: --- mjsax closed pull request #4868: KAFKA-6677: Fixed

[jira] [Comment Edited] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables

2018-04-24 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450299#comment-16450299 ] Robert Yokota edited comment on KAFKA-6142 at 4/24/18 5:59 PM: --- We might

[jira] [Created] (KAFKA-6824) Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener

2018-04-24 Thread Anna Povzner (JIRA)
Anna Povzner created KAFKA-6824: --- Summary: Transient failure in DynamicBrokerReconfigurationTest.testAddRemoveSslListener Key: KAFKA-6824 URL: https://issues.apache.org/jira/browse/KAFKA-6824 Project:

[jira] [Commented] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables

2018-04-24 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450299#comment-16450299 ] Robert Yokota commented on KAFKA-6142: -- We might also want variables to be able to refer to

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-04-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450300#comment-16450300 ] Matthias J. Sax commented on KAFKA-5998: Actual processing should not be affected. Only in case of

[jira] [Created] (KAFKA-6823) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

2018-04-24 Thread Anna Povzner (JIRA)
Anna Povzner created KAFKA-6823: --- Summary: Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize Key: KAFKA-6823 URL: https://issues.apache.org/jira/browse/KAFKA-6823 Project:

[jira] [Commented] (KAFKA-6526) Update controller to handle changes to unclean.leader.election.enable

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

[jira] [Commented] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

2018-04-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450057#comment-16450057 ] Matthias J. Sax commented on KAFKA-6786: Thanks for your interest [~abhi_sh]! I assigned the Jira

[jira] [Assigned] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

2018-04-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6786: -- Assignee: Abhishek Sharma > Remove additional configs in StreamsStandbyTask >

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: We faced the problem when StateStore (0.10.2.1) stuck in loading data during

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: We faced the problem when StateStore (0.10.2.1) stuck in loading data during

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: We faced the problem when StateStore (0.10.2.1) stuck in loading data during

[jira] [Assigned] (KAFKA-5677) Remove deprecated punctuate method

2018-04-24 Thread Jimin Hsieh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jimin Hsieh reassigned KAFKA-5677: -- Assignee: Jimin Hsieh > Remove deprecated punctuate method >

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Created] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
Phil Mikhailov created KAFKA-6822: - Summary: Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0 Key: KAFKA-6822 URL: https://issues.apache.org/jira/browse/KAFKA-6822 Project: Kafka

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

2018-04-24 Thread Phil Mikhailov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Mikhailov updated KAFKA-6822: -- Description: Kafka consumer 0.10.2.1 calculates offsets like this: Fetcher:524 {code:java}

[jira] [Created] (KAFKA-6821) The producer attempted to use a producer id which is not currently assigned to its transactional id

2018-04-24 Thread RandySun (JIRA)
RandySun created KAFKA-6821: --- Summary: The producer attempted to use a producer id which is not currently assigned to its transactional id Key: KAFKA-6821 URL: https://issues.apache.org/jira/browse/KAFKA-6821

[jira] [Commented] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

2018-04-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449370#comment-16449370 ] Dong Lin commented on KAFKA-6795: - Thanks [~apovzner]! Nice catch. You are right that the right behavior 

[jira] [Commented] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449366#comment-16449366 ] ASF GitHub Bot commented on KAFKA-6813: --- guozhangwang opened a new pull request #4919: [WIP]

[jira] [Comment Edited] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

2018-04-24 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449275#comment-16449275 ] Anna Povzner edited comment on KAFKA-6795 at 4/24/18 6:03 AM: -- [~lindong]