[jira] [Commented] (KAFKA-1229) Reload broker config without a restart

2017-11-13 Thread Lukasz Mierzwa (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250960#comment-16250960 ] Lukasz Mierzwa commented on KAFKA-1229: --- While reloading is not possible is there at least a way to

[jira] [Resolved] (KAFKA-6162) Stream Store tries to create directory with invalid name on Windows

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6162. Resolution: Duplicate > Stream Store tries to create directory with invalid name on Windows

[jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250869#comment-16250869 ] Matthias J. Sax commented on KAFKA-4281: This seems to be covered via KAFKA-5651. \cc [~guozhang]

[jira] [Created] (KAFKA-6206) Kafka processes ignore read/write performance and reliability

2017-11-13 Thread Macoy Jones (JIRA)
Macoy Jones created KAFKA-6206: -- Summary: Kafka processes ignore read/write performance and reliability Key: KAFKA-6206 URL: https://issues.apache.org/jira/browse/KAFKA-6206 Project: Kafka

[jira] [Updated] (KAFKA-6206) Kafka processes ignore read/write performance and reliability

2017-11-13 Thread Macoy Jones (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Macoy Jones updated KAFKA-6206: --- Affects Version/s: 0.10.0.0 > Kafka processes ignore read/write performance and reliability >

[jira] [Updated] (KAFKA-5254) rethink KTable API overloads

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5254: - Fix Version/s: 1.0.0 > rethink KTable API overloads > > >

[jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250727#comment-16250727 ] Matthias J. Sax commented on KAFKA-4696: [~damianguy] Is this resolved already? IIRC, we don't

[jira] [Commented] (KAFKA-4730) Streams does not have an in-memory windowed store

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250720#comment-16250720 ] Matthias J. Sax commented on KAFKA-4730: Is this covered by KAFKA-5651 ? \cc [~guozhang]

[jira] [Commented] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250719#comment-16250719 ] Matthias J. Sax commented on KAFKA-4729: Is this resolved via KAFKA-5651 \cc [~guozhang]

[jira] [Commented] (KAFKA-5254) rethink KTable API overloads

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250711#comment-16250711 ] Matthias J. Sax commented on KAFKA-5254: This seems to be resolve by KAFKA-5651 \cc [~guozhang]

[jira] [Updated] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6167: --- Priority: Blocker (was: Major) > Timestamp on streams directory contains a colon, which is

[jira] [Updated] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6167: --- Fix Version/s: 1.0.1 > Timestamp on streams directory contains a colon, which is an illegal

[jira] [Comment Edited] (KAFKA-5413) Log cleaner fails due to large offset in segment file

2017-11-13 Thread adam keyser (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250419#comment-16250419 ] adam keyser edited comment on KAFKA-5413 at 11/13/17 10:49 PM: --- We are

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

2017-11-13 Thread adam keyser (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250419#comment-16250419 ] adam keyser commented on KAFKA-5413: We are encountering this bug - Is 10.2.2 released? I don't see a

[jira] [Assigned] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4857: -- Assignee: Guozhang Wang (was: Matthias J. Sax) > Replace StreamsKafkaClient with

[jira] [Updated] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4857: --- Labels: (was: needs-kip) > Replace StreamsKafkaClient with AdminClient in Kafka Streams >

[jira] [Updated] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6205: --- Affects Version/s: (was: 0.11.0.0) 0.11.0.2 > Have State Stores

[jira] [Updated] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

2017-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6205: --- Fix Version/s: 0.11.0.3 > Have State Stores Restore Before Initializing Toplogy >

[jira] [Created] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

2017-11-13 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-6205: -- Summary: Have State Stores Restore Before Initializing Toplogy Key: KAFKA-6205 URL: https://issues.apache.org/jira/browse/KAFKA-6205 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4857: - Description: Streams uses {{KafkaClientSupplier}} to get consumer/restore-consumer/producer

[jira] [Updated] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4857: - Summary: Replace StreamsKafkaClient with AdminClient in Kafka Streams (was: Use AdminClient in

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250209#comment-16250209 ] Guozhang Wang commented on KAFKA-4857: -- We have KAFKA-6170 for the KIP-related changes to add

[jira] [Commented] (KAFKA-6170) Add the AdminClient in Streams' KafkaClientSupplier

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250207#comment-16250207 ] Guozhang Wang commented on KAFKA-6170: -- I have updated KAFKA-4857 to separate the two stories > Add

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

2017-11-13 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-4115: --- Assignee: Arjun Satish (was: Shikhar Bhushan) > Grow default heap settings for distributed

[jira] [Assigned] (KAFKA-6197) Difficult to get to the Kafka Streams javadocs

2017-11-13 Thread Joel (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel reassigned KAFKA-6197: --- Assignee: Joel > Difficult to get to the Kafka Streams javadocs >

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249855#comment-16249855 ] Jun Rao commented on KAFKA-6194: [~corlettb], thanks for the info. As Ismael mentioned, there was a

[jira] [Comment Edited] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249801#comment-16249801 ] Ismael Juma edited comment on KAFKA-6194 at 11/13/17 4:49 PM: -- Trying to

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249807#comment-16249807 ] Ted Yu commented on KAFKA-6194: --- bq. throw an exception if the file does not exist after Seems to be a

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249801#comment-16249801 ] Ismael Juma commented on KAFKA-6194: Trying to delete the same segment twice is the first idea that

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249687#comment-16249687 ] Ismael Juma commented on KAFKA-6194: I entered the previous message before seeing your latest update.

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249682#comment-16249682 ] Ismael Juma commented on KAFKA-6194: That's helpful [~corlettb]. So, failure to delete was happening

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249677#comment-16249677 ] Ben Corlett commented on KAFKA-6194: Just had the thought about if it was trying to delete the log

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249661#comment-16249661 ] Ben Corlett commented on KAFKA-6194: Sorry for not getting back to you about getting you the logs. I

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 2:25 PM: -- I had seen

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 2:23 PM: -- I had seen

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 2:23 PM: -- I had seen

[jira] [Commented] (KAFKA-6177) kafka-mirror-maker.sh RecordTooLargeException

2017-11-13 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-6177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249639#comment-16249639 ] Rémi REY commented on KAFKA-6177: - Hello all, Anyone to acknowledge this ticket please ? Thank you. >

[jira] [Commented] (KAFKA-5504) Kafka controller is not getting elected

2017-11-13 Thread Andrey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249625#comment-16249625 ] Andrey commented on KAFKA-5504: --- Was able to reproduce on 0.11.0.1 > Kafka controller is not getting

[jira] [Closed] (KAFKA-6202) Classes OffsetsMessageFormatter and GroupMetadataMessageFormatter shall be used by kafka tools, but in the last releases lost visibility

2017-11-13 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-6202. - > Classes OffsetsMessageFormatter and GroupMetadataMessageFormatter shall be

[jira] [Resolved] (KAFKA-6202) Classes OffsetsMessageFormatter and GroupMetadataMessageFormatter shall be used by kafka tools, but in the last releases lost visibility

2017-11-13 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-6202. --- Resolution: Invalid > Classes OffsetsMessageFormatter and

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 11:58 AM: --- I had seen

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 11:57 AM: --- I had seen

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 11:55 AM: --- I had seen

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-13 Thread Robin Tweedie (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249426#comment-16249426 ] Robin Tweedie commented on KAFKA-6199: -- We tried moving the leadership of every single-partition

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 11:30 AM: --- I had seen

[jira] [Comment Edited] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao edited comment on KAFKA-6189 at 11/13/17 11:29 AM: --- I had seen

[jira] [Commented] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Xinyang Gao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249419#comment-16249419 ] Xinyang Gao commented on KAFKA-6189: I had seen similar behaviors which also lead to message loss,

[jira] [Created] (KAFKA-6204) Interceptor and MetricsReporter should implement java.io.Closeable

2017-11-13 Thread Charly Molter (JIRA)
Charly Molter created KAFKA-6204: Summary: Interceptor and MetricsReporter should implement java.io.Closeable Key: KAFKA-6204 URL: https://issues.apache.org/jira/browse/KAFKA-6204 Project: Kafka

[jira] [Updated] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

2017-11-13 Thread Andrey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey updated KAFKA-6189: -- Description: Steps to reproduce: * Setup test: ** producer sends messages constantly. If cluster not available,