[jira] [Assigned] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

2018-05-10 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah reassigned KAFKA-6897: --- Assignee: Dhruvil Shah > Mirrormaker waits to shut down forever on produce failure with >

[jira] [Updated] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

2018-05-10 Thread Koelli Mungee (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-6897: - Attachment: mirror_maker_thread_dump.log > Mirrormaker waits to shut down forever on produce

[jira] [Updated] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

2018-05-10 Thread Koelli Mungee (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-6897: - Description: Mirrormaker never shuts down after a produce failure when

[jira] [Created] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

2018-05-10 Thread Koelli Mungee (JIRA)
Koelli Mungee created KAFKA-6897: Summary: Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true Key: KAFKA-6897 URL: https://issues.apache.org/jira/browse/KAFKA-6897

[jira] [Updated] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

2018-05-10 Thread Koelli Mungee (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-6897: - Description: Mirrormaker never shuts down after a produce failure: {code:java} [2018-05-07

[jira] [Commented] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471452#comment-16471452 ] ASF GitHub Bot commented on KAFKA-6725: --- farmdawgnation opened a new pull request #5002: KAFKA-6725:

[jira] [Issue Comment Deleted] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2018-05-10 Thread qiuyueqiong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qiuyueqiong updated KAFKA-5611: --- Comment: was deleted (was: after appy

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2018-05-10 Thread qiuyueqiong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471427#comment-16471427 ] qiuyueqiong commented on KAFKA-5611: after appy

[jira] [Updated] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

2018-05-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-6896: --- Description: We would like to also export the producer metrics from {{StreamThread}} just like

[jira] [Created] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

2018-05-10 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-6896: -- Summary: add producer metrics exporting in KafkaStreams.java Key: KAFKA-6896 URL: https://issues.apache.org/jira/browse/KAFKA-6896 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6299) Fix AdminClient error handling when metadata changes

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471322#comment-16471322 ] ASF GitHub Bot commented on KAFKA-6299: --- hachikuji closed pull request #4989: MINOR: A few small

[jira] [Assigned] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6868: -- Assignee: Colin P. McCabe > BufferUnderflowException in client when querying consumer

[jira] [Updated] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6868: --- Priority: Blocker (was: Major) > BufferUnderflowException in client when querying consumer

[jira] [Resolved] (KAFKA-6894) Improve error message when connecting processor with a global store

2018-05-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6894. -- Resolution: Fixed Fix Version/s: 2.0.0 > Improve error message when connecting processor

[jira] [Commented] (KAFKA-6894) Improve error message when connecting processor with a global store

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471254#comment-16471254 ] ASF GitHub Bot commented on KAFKA-6894: --- guozhangwang closed pull request #5000: KAFKA-6894: Improve

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Updated] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6895: -- Description: Though there does exist a converter in the connect-json library called "JsonConverter",

[jira] [Created] (KAFKA-6895) Schema Inferencing for JsonConverter

2018-05-10 Thread Allen Tang (JIRA)
Allen Tang created KAFKA-6895: - Summary: Schema Inferencing for JsonConverter Key: KAFKA-6895 URL: https://issues.apache.org/jira/browse/KAFKA-6895 Project: Kafka Issue Type: New Feature

[jira] [Resolved] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6893. Resolution: Fixed Fix Version/s: 1.1.1 > Processors created after acceptor started

[jira] [Commented] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471130#comment-16471130 ] ASF GitHub Bot commented on KAFKA-6893: --- hachikuji closed pull request #4999: KAFKA-6893: Create

[jira] [Commented] (KAFKA-6894) Cannot access GlobalKTable store from KStream.transform()

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470980#comment-16470980 ] ASF GitHub Bot commented on KAFKA-6894: --- rayokota opened a new pull request #5000: KAFKA-6894: Fix

[jira] [Created] (KAFKA-6894) Cannot access GlobalKTable store from KStream.transform()

2018-05-10 Thread Robert Yokota (JIRA)
Robert Yokota created KAFKA-6894: Summary: Cannot access GlobalKTable store from KStream.transform() Key: KAFKA-6894 URL: https://issues.apache.org/jira/browse/KAFKA-6894 Project: Kafka

[jira] [Created] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

2018-05-10 Thread Ryan P (JIRA)
Ryan P created KAFKA-6893: - Summary: Processors created after acceptor started which can cause in a brief refusal to accept connections Key: KAFKA-6893 URL: https://issues.apache.org/jira/browse/KAFKA-6893

[jira] [Resolved] (KAFKA-6141) Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest

2018-05-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6141. -- Resolution: Fixed Closing this as log level changed to debug in ZOOKEEPER-2795 / Zookeeper 3.4.12 >

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470728#comment-16470728 ] Jason Gustafson commented on KAFKA-6884: [~asasvari] Yes, you are right. [~cmccabe] submitted a

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-10 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470680#comment-16470680 ] Attila Sasvari commented on KAFKA-6884: --- [~hachikuji] thanks for the additional information! - I

[jira] [Comment Edited] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

2018-05-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470563#comment-16470563 ] Matthias J. Sax edited comment on KAFKA-6892 at 5/10/18 3:49 PM: - Thanks

[jira] [Commented] (KAFKA-6890) Add connector level configurability for producer/consumer client configs

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470566#comment-16470566 ] ASF GitHub Bot commented on KAFKA-6890: --- natengall opened a new pull request #4997: KAFKA-6890: Add

[jira] [Commented] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

2018-05-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470563#comment-16470563 ] Matthias J. Sax commented on KAFKA-6892: Thanks for reporting this. Can you share your

[jira] [Commented] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

2018-05-10 Thread Ben Kirwin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470529#comment-16470529 ] Ben Kirwin commented on KAFKA-661: -- {quote}The leader that is being shut down receives a

[jira] [Updated] (KAFKA-6890) Add connector level configurability for producer/consumer client configs

2018-05-10 Thread Allen Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Allen Tang updated KAFKA-6890: -- Description: Right now, each source connector and sink connector inherit their client configurations

[jira] [Resolved] (KAFKA-6828) Index files are no longer sparse in Java 9/10 due to OpenJDK regression

2018-05-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6828. Resolution: Fixed Great! Let's close this then. > Index files are no longer sparse in Java 9/10

[jira] [Commented] (KAFKA-6828) Index files are no longer sparse in Java 9/10 due to OpenJDK regression

2018-05-10 Thread Enrico Olivelli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470411#comment-16470411 ] Enrico Olivelli commented on KAFKA-6828: [~ijuma] I confirm that with jdk-11 index files are no

[jira] [Updated] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

2018-05-10 Thread Dawid Kulig (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Kulig updated KAFKA-6892: --- Description: Hi. I am observing indefinite memory growth of my kafka-streams application. It gets

[jira] [Resolved] (KAFKA-6870) Concurrency conflicts in SampledStat

2018-05-10 Thread Chia-Ping Tsai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-6870. --- Resolution: Fixed Reviewer: Rajini Sivaram Thanks for the reviews. [~rsivaram] >

[jira] [Updated] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

2018-05-10 Thread Dawid Kulig (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Kulig updated KAFKA-6892: --- Description: Hi. I am observing indefinite memory growth of my kafka-streams application. It gets

[jira] [Updated] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

2018-05-10 Thread Dawid Kulig (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Kulig updated KAFKA-6892: --- Summary: Kafka Streams memory usage grows over the time till OOM (was: Kafka Streams memory usage

[jira] [Created] (KAFKA-6892) Kafka Streams memory usage grows

2018-05-10 Thread Dawid Kulig (JIRA)
Dawid Kulig created KAFKA-6892: -- Summary: Kafka Streams memory usage grows Key: KAFKA-6892 URL: https://issues.apache.org/jira/browse/KAFKA-6892 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-6765) Intermittent test failure in CustomQuotaCallbackTest

2018-05-10 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6765: -- Affects Version/s: 1.1.1 Fix Version/s: 1.1.1 Adding fix to 1.1 branch as well since

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

2018-05-10 Thread Anurag Jain (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470127#comment-16470127 ] Anurag Jain commented on KAFKA-2200: HI [~becket_qin], Please correct me if I am wrong. if a

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-10 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470066#comment-16470066 ] Oleg Kuznetsov commented on KAFKA-6891: --- https://github.com/apache/kafka/pull/4995 >

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470065#comment-16470065 ] ASF GitHub Bot commented on KAFKA-6891: --- oleg-smith opened a new pull request #4995: KAFKA-6891