[jira] [Updated] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

2019-01-09 Thread Suman Kalyan Ghosh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suman Kalyan Ghosh updated KAFKA-7809: -- Description: Getting uncaught exception in kafka-producer-network-thread |

[jira] [Commented] (KAFKA-5761) Serializer API should support ByteBuffer

2019-01-09 Thread douyu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739077#comment-16739077 ] douyu commented on KAFKA-5761: -- +1 > Serializer API should support ByteBuffer >

[jira] [Created] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

2019-01-09 Thread Suman Kalyan Ghosh (JIRA)
Suman Kalyan Ghosh created KAFKA-7809: - Summary: Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space Key: KAFKA-7809 URL:

[jira] [Updated] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

2019-01-09 Thread Suman Kalyan Ghosh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suman Kalyan Ghosh updated KAFKA-7809: -- Description: Getting uncaught exception in kafka-producer-network-thread |

[jira] [Commented] (KAFKA-7807) Special Characters in Topic Name Appear to Break Replication

2019-01-09 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738991#comment-16738991 ] Ismael Juma commented on KAFKA-7807: Topic names with special characters are not allowed to be

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

2019-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738970#comment-16738970 ] ASF GitHub Bot commented on KAFKA-7672: --- abbccdda commented on pull request #6115: KAFKA-7672 :

[jira] [Updated] (KAFKA-6431) Lock contention in Purgatory

2019-01-09 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-6431: -- Fix Version/s: 2.2.0 > Lock contention in Purgatory >

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

2019-01-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738973#comment-16738973 ] Boyang Chen commented on KAFKA-7672: Thanks for the thorough investigation and summary here

[jira] [Resolved] (KAFKA-6431) Lock contention in Purgatory

2019-01-09 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-6431. --- Resolution: Fixed > Lock contention in Purgatory >

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

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738897#comment-16738897 ] Guozhang Wang commented on KAFKA-7672: -- [~bchen225242] I read your new fix, and it was not what I've

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738898#comment-16738898 ] Guozhang Wang commented on KAFKA-6767: -- [~pkleindl] I've left a comment on

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

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738896#comment-16738896 ] Guozhang Wang commented on KAFKA-7672: -- [~linyli] [~bchen225242] While trying to prepare a PR for

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738698#comment-16738698 ] Guozhang Wang commented on KAFKA-6767: -- [~pkleindl] Interesting. Let me prepare a PR for the first

[jira] [Updated] (KAFKA-7151) IOException on broker may result in state where unclean leader election is required

2019-01-09 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-7151: Description: We have seen situations like the following: 1) Broker A is a leader for topic

[jira] [Updated] (KAFKA-7151) IOException on broker may result in state where unclean leader election is required

2019-01-09 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-7151: Summary: IOException on broker may result in state where unclean leader election is required

[jira] [Commented] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found

2019-01-09 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738687#comment-16738687 ] Ismael Juma commented on KAFKA-7808: cc [~cmccabe] > AdminClient#describeTopic should not throw

[jira] [Updated] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7798: - Labels: needs-kip (was: ) > Expose embedded client context from KafkaStreams threadMetadata >

[jira] [Commented] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738675#comment-16738675 ] Guozhang Wang commented on KAFKA-7798: -- I've filed a KIP-414 here :) I'm linking the wiki now. >

[jira] [Updated] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7808: - Component/s: core > AdminClient#describeTopic should not throw InvalidTopic if topic name is not

[jira] [Updated] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7808: - Issue Type: Bug (was: Improvement) > AdminClient#describeTopic should not throw InvalidTopic if

[jira] [Created] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found

2019-01-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-7808: Summary: AdminClient#describeTopic should not throw InvalidTopic if topic name is not found Key: KAFKA-7808 URL: https://issues.apache.org/jira/browse/KAFKA-7808

[jira] [Assigned] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2019-01-09 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-7040: --- Assignee: Anna Povzner (was: Lucas Wang) > The replica fetcher thread may truncate

[jira] [Comment Edited] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2019-01-09 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738578#comment-16738578 ] Anna Povzner edited comment on KAFKA-7040 at 1/9/19 7:38 PM: - Hi [~luwang],

[jira] [Commented] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

2019-01-09 Thread Joseph Niemiec (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738593#comment-16738593 ] Joseph Niemiec commented on KAFKA-6706: --- Wanted to follow up here that we upgraded one of our

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2019-01-09 Thread Lucas Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738587#comment-16738587 ] Lucas Wang commented on KAFKA-7040: --- Hi [~apovzner], thanks for the info. Please go ahead and take over

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2019-01-09 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738578#comment-16738578 ] Anna Povzner commented on KAFKA-7040: - Hi [~luwang], we found a related (with the same root cause)

[jira] [Resolved] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

2019-01-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7786. Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > Fast update of

[jira] [Commented] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738562#comment-16738562 ] Boyang Chen commented on KAFKA-7806: Thanks John for bringing this up! FYI, [~shnguyen] has

[jira] [Commented] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

2019-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738557#comment-16738557 ] ASF GitHub Bot commented on KAFKA-7786: --- hachikuji commented on pull request #6101: KAFKA-7786:

[jira] [Created] (KAFKA-7807) Special Characters in Topic Name Appear to Break Replication

2019-01-09 Thread Joseph Niemiec (JIRA)
Joseph Niemiec created KAFKA-7807: - Summary: Special Characters in Topic Name Appear to Break Replication Key: KAFKA-7807 URL: https://issues.apache.org/jira/browse/KAFKA-7807 Project: Kafka

[jira] [Created] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-09 Thread John Roesler (JIRA)
John Roesler created KAFKA-7806: --- Summary: Windowed Aggregations should wrap default key serde if none is specified Key: KAFKA-7806 URL: https://issues.apache.org/jira/browse/KAFKA-7806 Project: Kafka

[jira] [Created] (KAFKA-7805) Use --bootstrap-server option in ducktape tests where applicable

2019-01-09 Thread Viktor Somogyi (JIRA)
Viktor Somogyi created KAFKA-7805: - Summary: Use --bootstrap-server option in ducktape tests where applicable Key: KAFKA-7805 URL: https://issues.apache.org/jira/browse/KAFKA-7805 Project: Kafka

[jira] [Updated] (KAFKA-7804) Update the docs for KIP-377

2019-01-09 Thread Viktor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-7804: -- Description: KIP-377 introduced the {{--bootstrap-server}} option to the {{kafka-topics.sh}}

[jira] [Created] (KAFKA-7804) Update the docs for KIP-377

2019-01-09 Thread Viktor Somogyi (JIRA)
Viktor Somogyi created KAFKA-7804: - Summary: Update the docs for KIP-377 Key: KAFKA-7804 URL: https://issues.apache.org/jira/browse/KAFKA-7804 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata

2019-01-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738163#comment-16738163 ] Matthias J. Sax commented on KAFKA-7798: Sounds like a public API change – is this part of

[jira] [Created] (KAFKA-7803) Streams internal topics config is not updated when the code is changed

2019-01-09 Thread Tim Van Laer (JIRA)
Tim Van Laer created KAFKA-7803: --- Summary: Streams internal topics config is not updated when the code is changed Key: KAFKA-7803 URL: https://issues.apache.org/jira/browse/KAFKA-7803 Project: Kafka

[jira] [Updated] (KAFKA-7803) Kafka Streams internal topics config is not updated when the code is changed

2019-01-09 Thread Tim Van Laer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Van Laer updated KAFKA-7803: Summary: Kafka Streams internal topics config is not updated when the code is changed (was:

[jira] [Commented] (KAFKA-5337) Partition assignment strategy that distributes lag evenly across consumers in each group

2019-01-09 Thread BDeus (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738011#comment-16738011 ] BDeus commented on KAFKA-5337: -- I think it's an interesting feature to add. When a consumer group read

[jira] [Commented] (KAFKA-7771) Group/Transaction coordinators should update assignment based on current partition count

2019-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737987#comment-16737987 ] ASF GitHub Bot commented on KAFKA-7771: --- huxihx commented on pull request #6110:

[jira] [Assigned] (KAFKA-7771) Group/Transaction coordinators should update assignment based on current partition count

2019-01-09 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-7771: - Assignee: huxihx > Group/Transaction coordinators should update assignment based on current >

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

2019-01-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7799. Resolution: Fixed > Fix flaky test RestServerTest.testCORSEnabled >

[jira] [Resolved] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

2019-01-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6833. Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > KafkaProducer

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

2019-01-09 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737953#comment-16737953 ] Khaireddine Rezgui commented on KAFKA-7243: --- Hi guys, can some one take a look on the pull