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

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

[jira] [Updated] (KAFKA-7905) KTable Reduce Allow Null value to be pass in Subtractor

2019-02-06 Thread Chris Bogan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Bogan updated KAFKA-7905: --- Attachment: (was: join.html) > KTable Reduce Allow Null value to be pass in Subtractor >

[jira] [Updated] (KAFKA-7905) KTable Reduce Allow Null value to be pass in Subtractor

2019-02-06 Thread Chris Bogan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Bogan updated KAFKA-7905: --- Attachment: join.html > KTable Reduce Allow Null value to be pass in Subtractor > ---

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762318#comment-16762318 ] Ziming Dong edited comment on KAFKA-7672 at 2/7/19 4:58 AM: [

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762318#comment-16762318 ] Ziming Dong edited comment on KAFKA-7672 at 2/7/19 4:54 AM: [

[jira] [Created] (KAFKA-7905) KTable Reduce Allow Null value to be pass in Subtractor

2019-02-06 Thread HARSHIT AGARWAL (JIRA)
HARSHIT AGARWAL created KAFKA-7905: -- Summary: KTable Reduce Allow Null value to be pass in Subtractor Key: KAFKA-7905 URL: https://issues.apache.org/jira/browse/KAFKA-7905 Project: Kafka Iss

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762318#comment-16762318 ] Ziming Dong commented on KAFKA-7672: [~linyli], I see, each time `restore` function o

[jira] [Created] (KAFKA-7904) Add AtMinIsr topic partition category

2019-02-06 Thread Kevin Lu (JIRA)
Kevin Lu created KAFKA-7904: --- Summary: Add AtMinIsr topic partition category Key: KAFKA-7904 URL: https://issues.apache.org/jira/browse/KAFKA-7904 Project: Kafka Issue Type: New Feature

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ziming Dong updated KAFKA-7672: --- Comment: was deleted (was: [~linyli], I see, there is a `runLoop` in `StreamThread`, and the second

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762298#comment-16762298 ] Ziming Dong commented on KAFKA-7672: [~linyli], I see, there is a `runLoop` in `Strea

[jira] [Created] (KAFKA-7903) Replace OffsetCommit request/response with automated protocol

2019-02-06 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7903: -- Summary: Replace OffsetCommit request/response with automated protocol Key: KAFKA-7903 URL: https://issues.apache.org/jira/browse/KAFKA-7903 Project: Kafka Issu

[jira] [Commented] (KAFKA-7828) Execute Trogdor tasks with external commands

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

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

2019-02-06 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7540: -- Assignee: Jason Gustafson > Transient failure: kafka.api.ConsumerBounceTest.testClose

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

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

[jira] [Assigned] (KAFKA-6858) Log.truncateTo() may truncate to an earlier offset than requested

2019-02-06 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio reassigned KAFKA-6858: - Assignee: Jose Armando Garcia Sancio (was: Anna Povzner) > Log.

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

2019-02-06 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio reassigned KAFKA-7656: - Assignee: Jose Armando Garcia Sancio > ReplicaManager fetch fail

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-02-06 Thread prasanthi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762027#comment-16762027 ] prasanthi commented on KAFKA-7895: -- Great! Thank you John for the update. > Ktable supr

[jira] [Commented] (KAFKA-7902) SASL/OAUTHBEARER can become unable to connect: javax.security.sasl.SaslException: Unable to find OAuth Bearer token in Subject's private credentials (size=2)

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

[jira] [Created] (KAFKA-7902) SASL/OAUTHBEARER can become unable to connect: javax.security.sasl.SaslException: Unable to find OAuth Bearer token in Subject's private credentials (size=2)

2019-02-06 Thread Ron Dagostino (JIRA)
Ron Dagostino created KAFKA-7902: Summary: SASL/OAUTHBEARER can become unable to connect: javax.security.sasl.SaslException: Unable to find OAuth Bearer token in Subject's private credentials (size=2) Key: KAFKA-7902

[jira] [Commented] (KAFKA-7020) Error when deleting topic with access denied exception

2019-02-06 Thread Alexander Abramov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16761848#comment-16761848 ] Alexander Abramov commented on KAFKA-7020: -- The issue is still reproducible in K

[jira] [Updated] (KAFKA-7901) Message Expiring at Producer with "Expiring n Records" when Partitions are under replicated

2019-02-06 Thread Zubair Abdul Khaliq (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zubair Abdul Khaliq updated KAFKA-7901: --- Summary: Message Expiring at Producer with "Expiring n Records" when Partitions are u

[jira] [Created] (KAFKA-7901) Message Expiring at Producer with "Unable to send" when Partitions are under replicated

2019-02-06 Thread Zubair Abdul Khaliq (JIRA)
Zubair Abdul Khaliq created KAFKA-7901: -- Summary: Message Expiring at Producer with "Unable to send" when Partitions are under replicated Key: KAFKA-7901 URL: https://issues.apache.org/jira/browse/KAFKA-7901

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

2019-02-06 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16761758#comment-16761758 ] Mateusz Owczarek commented on KAFKA-7882: - Also, I noticed my regression tests ch

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

2019-02-06 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16761706#comment-16761706 ] Mateusz Owczarek commented on KAFKA-7882: - Hey [~vvcephei], thanks for the answer

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

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16761686#comment-16761686 ] Ziming Dong commented on KAFKA-7672: [~linyli], I also met this issue, but I find tha