[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

2019-02-12 Thread Valeria Vasylieva (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765847#comment-16765847 ] Valeria Vasylieva commented on KAFKA-6755: -- Hi [~rhauch], if it still needed to

[jira] [Assigned] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

2019-02-12 Thread Valeria Vasylieva (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeria Vasylieva reassigned KAFKA-6755: Assignee: Valeria Vasylieva > MaskField SMT should optionally take a literal value

[jira] [Commented] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout

2019-02-12 Thread Gert van Dijk (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765898#comment-16765898 ] Gert van Dijk commented on KAFKA-5792: -- I'm also seeing this issue still with 2.1.0

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

2019-02-12 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765924#comment-16765924 ] Rajini Sivaram commented on KAFKA-7304: --- [~mjsax] We have fixed all the known memor

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

2019-02-12 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7920: -- Assignee: Lee Dongjin > Do not permit zstd use until inter.broker.protocol.version is updated

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

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765962#comment-16765962 ] ASF GitHub Bot commented on KAFKA-7920: --- dongjinleekr commented on pull request #62

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

2019-02-12 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765967#comment-16765967 ] Mateusz Owczarek commented on KAFKA-7882: - [~vvcephei] This is pretty much, how

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

2019-02-12 Thread Valeria Vasylieva (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765976#comment-16765976 ] Valeria Vasylieva commented on KAFKA-6755: -- [~rhauch] I am new to Kafka, could y

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766100#comment-16766100 ] Kartik commented on KAFKA-7794: --- [~ijuma] Can you help me here? Should we return latest off

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

2019-02-12 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniele Ascione updated KAFKA-7794: --- Attachment: image-2019-02-12-16-19-25-170.png > kafka.tools.GetOffsetShell does not return th

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

2019-02-12 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniele Ascione updated KAFKA-7794: --- Attachment: image-2019-02-12-16-21-13-126.png > kafka.tools.GetOffsetShell does not return th

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

2019-02-12 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniele Ascione updated KAFKA-7794: --- Attachment: image-2019-02-12-16-23-38-399.png > kafka.tools.GetOffsetShell does not return th

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

2019-02-12 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766139#comment-16766139 ] Daniele Ascione commented on KAFKA-7794: [~kartikvk1996], I am able to reproduce

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

2019-02-12 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766139#comment-16766139 ] Daniele Ascione edited comment on KAFKA-7794 at 2/12/19 3:24 PM: --

[jira] [Commented] (KAFKA-6572) kafka-consumer-groups does not reset offsets to specified datetime correctly

2019-02-12 Thread Bruno Lenski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766167#comment-16766167 ] Bruno Lenski commented on KAFKA-6572: - Hi We run in the very same issue. I have two

[jira] [Comment Edited] (KAFKA-6572) kafka-consumer-groups does not reset offsets to specified datetime correctly

2019-02-12 Thread Bruno Lenski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766167#comment-16766167 ] Bruno Lenski edited comment on KAFKA-6572 at 2/12/19 3:51 PM: -

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

2019-02-12 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766183#comment-16766183 ] Randall Hauch commented on KAFKA-6755: -- [~nimfadora], thanks for volunteering. Perha

[jira] [Commented] (KAFKA-7897) Invalid use of epoch cache with old message format versions

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766215#comment-16766215 ] ASF GitHub Bot commented on KAFKA-7897: --- hachikuji commented on pull request #6253:

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

2019-02-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766239#comment-16766239 ] Matthias J. Sax commented on KAFKA-7882: [~nijo] you should not use `FinalResults

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

2019-02-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766241#comment-16766241 ] Matthias J. Sax commented on KAFKA-7882: [~nijo] For the original error reported

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7672: --- Priority: Critical (was: Major) > The local state not fully restored after KafkaStream rebal

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

2019-02-12 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766265#comment-16766265 ] Yu Yang commented on KAFKA-7304: [~rsivaram] sure.  I have reduced te priority of this ti

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

2019-02-12 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-7304: --- Priority: Major (was: Critical) > memory leakage in org.apache.kafka.common.network.Selector > -

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

2019-02-12 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-7921: -- Summary: Instable KafkaStreamsTest Key: KAFKA-7921 URL: https://issues.apache.org/jira/browse/KAFKA-7921 Project: Kafka Issue Type: Bug Compone

[jira] [Created] (KAFKA-7922) Returned authorized operations in describe responses (KIP-430)

2019-02-12 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-7922: - Summary: Returned authorized operations in describe responses (KIP-430) Key: KAFKA-7922 URL: https://issues.apache.org/jira/browse/KAFKA-7922 Project: Kafka

[jira] [Updated] (KAFKA-7897) Invalid use of epoch cache with old message format versions

2019-02-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7897: --- Affects Version/s: 1.1.1 2.0.1 2.1.0 > Invalid

[jira] [Commented] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766359#comment-16766359 ] ASF GitHub Bot commented on KAFKA-7401: --- hachikuji commented on pull request #6220:

[jira] [Resolved] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset

2019-02-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7401. Resolution: Fixed Fix Version/s: 1.1.2 > Broker fails to start when recovering a seg

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

2019-02-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766360#comment-16766360 ] Guozhang Wang commented on KAFKA-7921: -- Note that in a recent commit we've updated {

[jira] [Created] (KAFKA-7923) Add unit test to verify Kafka-7401 in AK versions >= 2.0

2019-02-12 Thread Anna Povzner (JIRA)
Anna Povzner created KAFKA-7923: --- Summary: Add unit test to verify Kafka-7401 in AK versions >= 2.0 Key: KAFKA-7923 URL: https://issues.apache.org/jira/browse/KAFKA-7923 Project: Kafka Issue Ty

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

2019-02-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766393#comment-16766393 ] Guozhang Wang commented on KAFKA-7921: -- Yup that's what I proposed as well :) > Ins

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766400#comment-16766400 ] ASF GitHub Bot commented on KAFKA-7656: --- jsancio commented on pull request #6261: K

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

2019-02-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766391#comment-16766391 ] Matthias J. Sax commented on KAFKA-7921: Can we do a "two phase" approach here? F

[jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766403#comment-16766403 ] ASF GitHub Bot commented on KAFKA-7799: --- gwenshap commented on pull request #6236:

[jira] [Created] (KAFKA-7924) Kafka broker does not list nodes first ~ 30s after startup

2019-02-12 Thread Gert van Dijk (JIRA)
Gert van Dijk created KAFKA-7924: Summary: Kafka broker does not list nodes first ~ 30s after startup Key: KAFKA-7924 URL: https://issues.apache.org/jira/browse/KAFKA-7924 Project: Kafka Issu

[jira] [Updated] (KAFKA-7924) Kafka broker does not list nodes first ~ 30s after startup

2019-02-12 Thread Gert van Dijk (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gert van Dijk updated KAFKA-7924: - Description: Steps to reproduce: # Start single Zookeeper instance. # Start single Kafka instance

[jira] [Comment Edited] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout

2019-02-12 Thread Gert van Dijk (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765898#comment-16765898 ] Gert van Dijk edited comment on KAFKA-5792 at 2/12/19 8:28 PM:

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

2019-02-12 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7921: --- Assignee: John Roesler > Instable KafkaStreamsTest > - > >

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

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

[jira] [Resolved] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

2019-02-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7799. -- Resolution: Fixed Fix Version/s: 2.3.0 > Fix flaky test RestServerTest.testCORSEnabled > ---

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-12 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766723#comment-16766723 ] linyue li commented on KAFKA-7672: -- [~guozhang] Thanks for the fix, and I'll validate it

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

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766769#comment-16766769 ] Ismael Juma commented on KAFKA-7481: I would remove the target version and reduce pri

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

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766772#comment-16766772 ] Ismael Juma commented on KAFKA-7565: Any thoughts [~rsivaram]? Maybe related https:/

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

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7304: --- Fix Version/s: (was: 2.0.2) (was: 2.2.0) (was: 1.1.2

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766773#comment-16766773 ] Ismael Juma commented on KAFKA-7556: [~mgharat] are you still planning to work on thi

[jira] [Updated] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7556: --- Fix Version/s: (was: 2.2.0) > KafkaConsumer.beginningOffsets does not return actual first offsets

[jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

2019-02-12 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3955: --- Fix Version/s: (was: 2.2.0) > Kafka log recovery doesn't truncate logs on non-monotonic offsets,

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-7794: -- Attachment: image-2019-02-13-11-43-28-873.png > kafka.tools.GetOffsetShell does not return the offset in some c

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766828#comment-16766828 ] Kartik commented on KAFKA-7794: --- [~audhumla] I tried your steps and for me, it's working a

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-7794: -- Attachment: image-2019-02-13-11-45-21-459.png > kafka.tools.GetOffsetShell does not return the offset in some c

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-7794: -- Attachment: image-2019-02-13-11-43-24-128.png > kafka.tools.GetOffsetShell does not return the offset in some c

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

2019-02-12 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-7794: -- Attachment: image-2019-02-13-11-44-18-736.png > kafka.tools.GetOffsetShell does not return the offset in some c

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

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766843#comment-16766843 ] ASF GitHub Bot commented on KAFKA-7652: --- guozhangwang commented on pull request #61

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

2019-02-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7652. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.2.0 I think this iss