[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767939#comment-16767939 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:50 AM: - {quote}This should not

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767939#comment-16767939 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:51 AM: - {quote}This should not

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767939#comment-16767939 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:50 AM: - {quote}This should not

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767939#comment-16767939 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:49 AM: - {quote} This should not

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767939#comment-16767939 ] Murad M commented on KAFKA-7930: {quote} This should not have happened... Note that, all internal topic

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767936#comment-16767936 ] Matthias J. Sax commented on KAFKA-7930: {quote}Now they are being used for different purposes

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767930#comment-16767930 ] Matthias J. Sax commented on KAFKA-6460: I did not think about how to make it work. But what you

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767905#comment-16767905 ] ASF GitHub Bot commented on KAFKA-7930: --- muradm commented on pull request #6267: KAFKA-7930: topic

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767751#comment-16767751 ] Murad M edited comment on KAFKA-7930 at 2/14/19 6:36 AM: - Patch provided:

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767899#comment-16767899 ] Guozhang Wang commented on KAFKA-6460: -- Ah yes, that's a good point. Thinking about this again,

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767895#comment-16767895 ] Murad M commented on KAFKA-7930: Yes, if you create GlobalKTable, it is created from provided topic name.

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767890#comment-16767890 ] Guozhang Wang commented on KAFKA-7930: -- {{GlobalKTable}} should not have changelog topics since it

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767880#comment-16767880 ] Murad M edited comment on KAFKA-7930 at 2/14/19 5:14 AM: - Historically those

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767880#comment-16767880 ] Murad M edited comment on KAFKA-7930 at 2/14/19 5:14 AM: - Historically those

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767880#comment-16767880 ] Murad M commented on KAFKA-7930: Historically those topics was auto-created as per GlobalKTable naming

[jira] [Commented] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases

2019-02-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767814#comment-16767814 ] huxihx commented on KAFKA-7794: --- There are some inconsistencies here where GetOffsetShell wants to seek the

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767791#comment-16767791 ] Matthias J. Sax commented on KAFKA-6460: Internally, the DSL always uses the class `Stores` to

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767766#comment-16767766 ] Guozhang Wang commented on KAFKA-6460: -- [~mjsax] I'm not sure I can follow-up here, could you

[jira] [Created] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

2019-02-13 Thread Brian (JIRA)
Brian created KAFKA-7931: Summary: Java Client: if all ephemeral brokers fail, client can never reconnect to brokers Key: KAFKA-7931 URL: https://issues.apache.org/jira/browse/KAFKA-7931 Project: Kafka

[jira] [Comment Edited] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767479#comment-16767479 ] Guozhang Wang edited comment on KAFKA-6460 at 2/14/19 1:21 AM: --- Hi

[jira] [Comment Edited] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767479#comment-16767479 ] Guozhang Wang edited comment on KAFKA-6460 at 2/14/19 1:16 AM: --- Hi

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767765#comment-16767765 ] Matthias J. Sax commented on KAFKA-7918: Judgment call in the end how much you put together into

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767760#comment-16767760 ] Matthias J. Sax commented on KAFKA-7930: Thanks for creating this ticket. I agree that naming

[jira] [Updated] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7930: --- Labels: features needs-kip patch-available usability (was: features patch-available

[jira] [Updated] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7928: --- Labels: beginner easy-fix needs-kip newbie (was: needs-kip) > Deprecate

[jira] [Commented] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767754#comment-16767754 ] Matthias J. Sax commented on KAFKA-7928: +1 > Deprecate WindowStore.put(key, value) >

[jira] [Updated] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7928: --- Labels: needs-kip (was: ) > Deprecate WindowStore.put(key, value) >

[jira] [Updated] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Murad M updated KAFKA-7930: --- Labels: features patch-available usability (was: features usability) > StreamsResetter makes "changelog"

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767751#comment-16767751 ] Murad M commented on KAFKA-7930: Patch provided: https://github.com/muradm/kafka/pull/1 >

[jira] [Updated] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Murad M updated KAFKA-7930: --- Description: StreamsResetter deletes the topics considered internal. Currently it just checks the naming as

[jira] [Updated] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Murad M updated KAFKA-7930: --- Description: StreamsResetter deletes the topics considered internal. Currently it just checks the naming as

[jira] [Created] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

2019-02-13 Thread Murad M (JIRA)
Murad M created KAFKA-7930: -- Summary: StreamsResetter makes "changelog" topic naming assumptions Key: KAFKA-7930 URL: https://issues.apache.org/jira/browse/KAFKA-7930 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7929) RocksDB Window Store allows segments to expire out from under iterator

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7929: -- Summary: RocksDB Window Store allows segments to expire out from under iterator Key: KAFKA-7929 URL: https://issues.apache.org/jira/browse/KAFKA-7929

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767663#comment-16767663 ] Sophie Blee-Goldman commented on KAFKA-7918: Makes sense, I will consider the caching layer

[jira] [Created] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-02-13 Thread John Roesler (JIRA)
John Roesler created KAFKA-7928: --- Summary: Deprecate WindowStore.put(key, value) Key: KAFKA-7928 URL: https://issues.apache.org/jira/browse/KAFKA-7928 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767623#comment-16767623 ] Matthias J. Sax commented on KAFKA-7918: In general I think yes. However, it implies a little

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767611#comment-16767611 ] Sophie Blee-Goldman commented on KAFKA-7918: In light of the decision to close KAFKA-7917 

[jira] [Commented] (KAFKA-7758) When Naming a Repartition Topic with Aggregations Reuse Repartition Graph Node for Multiple Operations

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767603#comment-16767603 ] ASF GitHub Bot commented on KAFKA-7758: --- bbejeck commented on pull request #6265: KAFKA-7758: Reuse

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767580#comment-16767580 ] Guozhang Wang commented on KAFKA-7918: -- +1. [~ableegoldman] Thanks for looking into it. > Streams

[jira] [Closed] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-7917. --- > Streams store cleanup: collapse layers > -- > >

[jira] [Resolved] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7917. - Resolution: Won't Fix > Streams store cleanup: collapse layers >

[jira] [Commented] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767574#comment-16767574 ] John Roesler commented on KAFKA-7917: - After messing with the code for a while, I'm not happy with

[jira] [Commented] (KAFKA-7921) Instable KafkaStreamsTest

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767548#comment-16767548 ] ASF GitHub Bot commented on KAFKA-7921: --- guozhangwang commented on pull request #6262: KAFKA-7921:

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767517#comment-16767517 ] Matthias J. Sax commented on KAFKA-6460: [~guozhang] I think it would also be important, to

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

2019-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767479#comment-16767479 ] Guozhang Wang commented on KAFKA-6460: -- Hi [~shung], sorry for the late replies. Here's my thoughts

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

2019-02-13 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767474#comment-16767474 ] Rajini Sivaram commented on KAFKA-7565: --- [~hachikuji] I am not sure if this is covered by your PR

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767446#comment-16767446 ] Matthias J. Sax commented on KAFKA-7918: SGTM. > Streams store cleanup: inline byte-store

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767458#comment-16767458 ] Matthias J. Sax commented on KAFKA-7304: Thanks [~rsivaram] and [~yuyang08]! > memory leakage in

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

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7481: --- Fix Version/s: (was: 2.2.0) > Consider options for safer upgrade of offset commit value

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

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7481: --- Priority: Critical (was: Blocker) > Consider options for safer upgrade of offset commit

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767449#comment-16767449 ] Matthias J. Sax commented on KAFKA-7882: Thanks for confirming. Then you are hitting

[jira] [Commented] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767443#comment-16767443 ] Matthias J. Sax commented on KAFKA-7917: > but simplifying the code base. Having a layered code

[jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7652: --- Labels: kip (was: ) > Kafka Streams Session store performance degradation from 0.10.2.2 to

[jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7652: --- Description: I'm creating this issue in response to [~guozhang]'s request on the mailing

[jira] [Updated] (KAFKA-7920) Do not permit zstd use until inter.broker.protocol.version is updated to 2.1

2019-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7920: --- Fix Version/s: 2.2.0 > Do not permit zstd use until inter.broker.protocol.version is updated

[jira] [Updated] (KAFKA-7920) Do not permit zstd use until inter.broker.protocol.version is updated to 2.1

2019-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7920: --- Priority: Blocker (was: Major) > Do not permit zstd use until inter.broker.protocol.version

[jira] [Commented] (KAFKA-7440) Use leader epoch in consumer fetch requests

2019-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767409#comment-16767409 ] ASF GitHub Bot commented on KAFKA-7440: --- hachikuji commented on pull request #6190: KAFKA-7440 Add

[jira] [Commented] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767389#comment-16767389 ] John Roesler commented on KAFKA-7917: - Thanks for the comments, all.   The main motivation here is

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767386#comment-16767386 ] John Roesler commented on KAFKA-7918: - Should we also consider simplifying the StoreChangeLogger by

[jira] [Assigned] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-13 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7917: --- Assignee: John Roesler > Streams store cleanup: collapse layers >

[jira] [Updated] (KAFKA-7927) Read committed receives aborted events

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-7927: - Description: When a kafka client produces ~30k events and at the end it aborts the transaction

[jira] [Updated] (KAFKA-7927) Read committed receives aborted events

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-7927: - Attachment: consumer.log > Read committed receives aborted events >

[jira] [Updated] (KAFKA-7927) Read committed receives aborted events

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-7927: - Attachment: producer.log.gz > Read committed receives aborted events >

[jira] [Updated] (KAFKA-7927) Read committed receives aborted events

2019-02-13 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-7927: - Attachment: KafkaProducer.scala > Read committed receives aborted events >

[jira] [Created] (KAFKA-7927) Read committed receives aborted events

2019-02-13 Thread Gabor Somogyi (JIRA)
Gabor Somogyi created KAFKA-7927: Summary: Read committed receives aborted events Key: KAFKA-7927 URL: https://issues.apache.org/jira/browse/KAFKA-7927 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

2019-02-13 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767006#comment-16767006 ] Mateusz Owczarek commented on KAFKA-7882: - [~mjsax] As I reported, I was using Kafka Streams

[jira] [Created] (KAFKA-7926) Issue with Kafka Broker - UnknownServerException

2019-02-13 Thread Santosh S (JIRA)
Santosh S created KAFKA-7926: Summary: Issue with Kafka Broker - UnknownServerException Key: KAFKA-7926 URL: https://issues.apache.org/jira/browse/KAFKA-7926 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

2019-02-13 Thread Abhi (JIRA)
Abhi created KAFKA-7925: --- Summary: Constant 100% cpu usage by all kafka brokers Key: KAFKA-7925 URL: https://issues.apache.org/jira/browse/KAFKA-7925 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases

2019-02-13 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766934#comment-16766934 ] Daniele Ascione edited comment on KAFKA-7794 at 2/13/19 8:37 AM: -

[jira] [Commented] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases

2019-02-13 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766934#comment-16766934 ] Daniele Ascione commented on KAFKA-7794: [~kartikvk1996] I've used Kafka 0.10.2.1 >