[jira] [Updated] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9142: -- Description: kafka broker :2.0.0 kafka stream client: 2.1.0 topic description please see

[jira] [Updated] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9142: -- Description: kafka broker :2.0.0 kafka stream client: 2.1.0 topic description please see

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967312#comment-16967312 ] panpan.liu commented on KAFKA-9142: --- I have met the same issue:  ["__consumer_offsets replicas grow way

[jira] [Updated] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9142: -- Description: kafka broker :2.0.0 kafka stream client: 2.1.0 topic description please see

[jira] [Updated] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9142: -- Attachment: image-2019-11-05-15-36-52-235.png > topic __transaction_state disk space grows too big >

[jira] [Created] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-04 Thread panpan.liu (Jira)
panpan.liu created KAFKA-9142: - Summary: topic __transaction_state disk space grows too big Key: KAFKA-9142 URL: https://issues.apache.org/jira/browse/KAFKA-9142 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8067) JsonConverter missing and optional field defaults result in a null pointer

2019-11-04 Thread Eric Pheatt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Pheatt updated KAFKA-8067: --- Issue Type: Bug (was: Improvement) > JsonConverter missing and optional field defaults result in a

[jira] [Created] (KAFKA-9141) Global state update error: missing recovery or wrong log message

2019-11-04 Thread Chris Toomey (Jira)
Chris Toomey created KAFKA-9141: --- Summary: Global state update error: missing recovery or wrong log message Key: KAFKA-9141 URL: https://issues.apache.org/jira/browse/KAFKA-9141 Project: Kafka

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9140: - Fix Version/s: 2.4.0 > Consumer gets stuck rejoining the group indefinitely >

[jira] [Commented] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967211#comment-16967211 ] ASF GitHub Bot commented on KAFKA-9140: --- guozhangwang commented on pull request #7647: KAFKA-9140:

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9140: --- Description: There seems to be a race condition that is now causing a rejoining

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9140: --- Attachment: server-start-stdout-stderr.log.tgz kafka-data-logs-2.tgz

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9140: --- Attachment: streams.log.tgz > Consumer gets stuck rejoining the group indefinitely >

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9140: --- Description: There seems to be a race condition that is now causing a rejoining

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9140: --- Priority: Blocker (was: Critical) > Consumer gets stuck rejoining the group

[jira] [Created] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9140: -- Summary: Consumer gets stuck rejoining the group indefinitely Key: KAFKA-9140 URL: https://issues.apache.org/jira/browse/KAFKA-9140 Project: Kafka

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

2019-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967136#comment-16967136 ] ASF GitHub Bot commented on KAFKA-7504: --- cmccabe commented on pull request #7646: KAFKA-7504:

[jira] [Commented] (KAFKA-8508) saslClient failed to initialize properly: it's null.

2019-11-04 Thread Graham Campbell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967135#comment-16967135 ] Graham Campbell commented on KAFKA-8508: ArrayOutOfBoundsException is due to mistakenly falling

[jira] [Commented] (KAFKA-9139) Dynamic broker config types aren't being discovered

2019-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967074#comment-16967074 ] ASF GitHub Bot commented on KAFKA-9139: --- bdbyrne commented on pull request #7644: KAFKA-9139: Fix

[jira] [Created] (KAFKA-9139) Dynamic broker config types aren't being discovered

2019-11-04 Thread Brian Byrne (Jira)
Brian Byrne created KAFKA-9139: -- Summary: Dynamic broker config types aren't being discovered Key: KAFKA-9139 URL: https://issues.apache.org/jira/browse/KAFKA-9139 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

2019-11-04 Thread John Roesler (Jira)
John Roesler created KAFKA-9138: --- Summary: Add system test covering Foreign Key joins (KIP-213) Key: KAFKA-9138 URL: https://issues.apache.org/jira/browse/KAFKA-9138 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-04 Thread Karolis Pocius (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966957#comment-16966957 ] Karolis Pocius edited comment on KAFKA-9133 at 11/4/19 7:49 PM: Some

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-04 Thread Karolis Pocius (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966957#comment-16966957 ] Karolis Pocius commented on KAFKA-9133: --- Some additional information. Broker restart doesn't help

[jira] [Assigned] (KAFKA-8402) bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB

2019-11-04 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-8402: -- Assignee: Ankit Kumar > bin/kafka-preferred-replica-election.sh fails if generated json is

[jira] [Assigned] (KAFKA-6453) Reconsider timestamp propagation semantics

2019-11-04 Thread Victoria Bialas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Bialas reassigned KAFKA-6453: -- Assignee: Victoria Bialas > Reconsider timestamp propagation semantics >

[jira] [Assigned] (KAFKA-6453) Reconsider timestamp propagation semantics

2019-11-04 Thread Victoria Bialas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Bialas reassigned KAFKA-6453: -- Assignee: (was: Victoria Bialas) > Reconsider timestamp propagation semantics >

[jira] [Updated] (KAFKA-7061) Enhanced log compaction

2019-11-04 Thread Senthilnathan Muthusamy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Senthilnathan Muthusamy updated KAFKA-7061: --- Affects Version/s: (was: 2.4.0) 2.5.0 > Enhanced

[jira] [Updated] (KAFKA-9137) Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions

2019-11-04 Thread Lucas Bradstreet (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet updated KAFKA-9137: Description: We have recently seen cases where brokers end up in a bad state where fetch 

[jira] [Commented] (KAFKA-9131) failed producer metadata updates result in the unrelated error message

2019-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966814#comment-16966814 ] Matthias J. Sax commented on KAFKA-9131: [~gkomissarov] I added you to the list of contributor

[jira] [Assigned] (KAFKA-9131) failed producer metadata updates result in the unrelated error message

2019-11-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9131: -- Assignee: Gleb Komissarov > failed producer metadata updates result in the unrelated

[jira] [Commented] (KAFKA-9137) Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions

2019-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966813#comment-16966813 ] ASF GitHub Bot commented on KAFKA-9137: --- lbradstreet commented on pull request #7640: [WIP]

[jira] [Created] (KAFKA-9137) Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions

2019-11-04 Thread Lucas Bradstreet (Jira)
Lucas Bradstreet created KAFKA-9137: --- Summary: Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions Key: KAFKA-9137 URL: https://issues.apache.org/jira/browse/KAFKA-9137

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-11-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966650#comment-16966650 ] Bruno Cadonna commented on KAFKA-9088: -- Just to be clear. I did not say that we cannot change

[jira] [Updated] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Description: for example,i have two topics,one_topic、two_topic,each topic have two

[jira] [Updated] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Description: for example,i have two topics,one_topic、two_topic,each topic have two

[jira] [Commented] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966635#comment-16966635 ] zhangzhisheng commented on KAFKA-9136: -- {code:java} // code placeholder {code} public static long

[jira] [Issue Comment Deleted] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Comment: was deleted (was: {code:java} // code placeholder {code} public static long

[jira] [Updated] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Description: for example,i have two topics,one_topic、two_topic,each topic have two

[jira] [Updated] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Description: for example,i have two topics,one_topic、two_topic,each topic have two

[jira] [Updated] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhisheng updated KAFKA-9136: - Description: topic > get consumer latest commited timestamp >

[jira] [Created] (KAFKA-9136) get consumer latest commited timestamp

2019-11-04 Thread zhangzhisheng (Jira)
zhangzhisheng created KAFKA-9136: Summary: get consumer latest commited timestamp Key: KAFKA-9136 URL: https://issues.apache.org/jira/browse/KAFKA-9136 Project: Kafka Issue Type: Wish

[jira] [Updated] (KAFKA-9135) Kafka producer/consumer are creating too many open file

2019-11-04 Thread Dhirendra Singh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhirendra Singh updated KAFKA-9135: --- Description: We have a 3 node Kafka cluster deployment with 5 topic and 6 partition per

[jira] [Created] (KAFKA-9135) Kafka producer/consumer are creating too many open file

2019-11-04 Thread Dhirendra Singh (Jira)
Dhirendra Singh created KAFKA-9135: -- Summary: Kafka producer/consumer are creating too many open file Key: KAFKA-9135 URL: https://issues.apache.org/jira/browse/KAFKA-9135 Project: Kafka