[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551526#comment-16551526 ] Ted Yu commented on KAFKA-7175: --- Haven't found a way for python to directly reference constant defined in

[jira] [Commented] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551483#comment-16551483 ] ASF GitHub Bot commented on KAFKA-5682: --- stanislavkozlovski opened a new pull request #5410:

[jira] [Assigned] (KAFKA-6946) Keep the session id for incremental fetch when fetch responses are throttled

[ https://issues.apache.org/jira/browse/KAFKA-6946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Lee reassigned KAFKA-6946: -- Assignee: Jon Lee > Keep the session id for incremental fetch when fetch responses are throttled >

[jira] [Assigned] (KAFKA-6944) Add system tests testing the new throttling behavior using older clients/brokers

[ https://issues.apache.org/jira/browse/KAFKA-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Lee reassigned KAFKA-6944: -- Assignee: Jon Lee > Add system tests testing the new throttling behavior using older >

[jira] [Assigned] (KAFKA-6028) Improve the quota throttle communication.

[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Lee reassigned KAFKA-6028: -- Assignee: Jon Lee (was: Jiangjie Qin) > Improve the quota throttle communication. >

[jira] [Commented] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551345#comment-16551345 ] ASF GitHub Bot commented on KAFKA-7126: --- jonlee2 opened a new pull request #5408: KAFKA-7126:

[jira] [Updated] (KAFKA-3244) TopicCommand doesn't allow to add partitions with specific assignment

[ https://issues.apache.org/jira/browse/KAFKA-3244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3244: -- Component/s: admin > TopicCommand doesn't allow to add partitions with specific assignment >

[jira] [Updated] (KAFKA-5748) Fix console producer to set timestamp and partition

[ https://issues.apache.org/jira/browse/KAFKA-5748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5748: -- Component/s: producer > Fix console producer to set timestamp and partition >

[jira] [Commented] (KAFKA-6918) Kafka server fails to start with IBM JAVA

[ https://issues.apache.org/jira/browse/KAFKA-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551270#comment-16551270 ] Ray Chiang commented on KAFKA-6918: --- Using Ubuntu 16.0.4 and this version of IBM Java:   {code:java}

[jira] [Updated] (KAFKA-6843) Document issue with Zookeeper DNS name resolutions changing

[ https://issues.apache.org/jira/browse/KAFKA-6843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6843: -- Component/s: documentation > Document issue with Zookeeper DNS name resolutions changing >

[jira] [Assigned] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Lee reassigned KAFKA-7126: -- Assignee: Jon Lee (was: Dong Lin) > Reduce number of rebalance period for large consumer groups

[jira] [Assigned] (KAFKA-7177) Update 2.0 documentation to reflect changed quota behaviors by KIP-219

[ https://issues.apache.org/jira/browse/KAFKA-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-7177: --- Assignee: Jon Lee > Update 2.0 documentation to reflect changed quota behaviors by KIP-219 >

[jira] [Commented] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551239#comment-16551239 ] Dong Lin commented on KAFKA-7126: - The simply patch in the attachment mostly fixes the issue and there is

[jira] [Resolved] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

[ https://issues.apache.org/jira/browse/KAFKA-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7185. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.0.0 >

[jira] [Commented] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

[ https://issues.apache.org/jira/browse/KAFKA-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551172#comment-16551172 ] ASF GitHub Bot commented on KAFKA-7185: --- rajinisivaram closed pull request #5400: KAFKA-7185: Allow

[jira] [Created] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

Bill Bejeck created KAFKA-7190: -- Summary: Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID Key: KAFKA-7190 URL:

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551089#comment-16551089 ] Matthias J. Sax commented on KAFKA-6520: As mentioned, try the `WordCountExample` that is

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551071#comment-16551071 ] ASF GitHub Bot commented on KAFKA-5037: --- mjsax closed pull request #2815: WIP DO NOT MERGE --

[jira] [Commented] (KAFKA-7154) Apache kafka getting shut down everytime it is started

[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551062#comment-16551062 ] Ray Chiang commented on KAFKA-7154: --- A lot could depend on how you intend to make Kafka available. The

[jira] [Commented] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

[ https://issues.apache.org/jira/browse/KAFKA-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551055#comment-16551055 ] ASF GitHub Bot commented on KAFKA-5039: --- ijuma closed pull request #2820: KAFKA-5039: Logging in

[jira] [Commented] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551045#comment-16551045 ] ASF GitHub Bot commented on KAFKA-7109: --- stanislavkozlovski opened a new pull request #5407:

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551030#comment-16551030 ] ASF GitHub Bot commented on KAFKA-5037: --- guozhangwang closed pull request #5399: KAFKA-5037

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551025#comment-16551025 ] Harjit Singh commented on KAFKA-6520: - [~mjsax] - Is there a sample app for Streaming which I can use

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551012#comment-16551012 ] Matthias J. Sax commented on KAFKA-6520: [~harjitdotsingh] Not sure what you exactly mean... To

[jira] [Resolved] (KAFKA-7081) Add describe all topics API to AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7081. -- Resolution: Won't Fix Closing this KIP in favor of adding filtering support to the Metadata API  

[jira] [Commented] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550903#comment-16550903 ] ASF GitHub Bot commented on KAFKA-7141: --- hachikuji closed pull request #5356: KAFKA-7141:

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Assigned] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

[ https://issues.apache.org/jira/browse/KAFKA-7187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona reassigned KAFKA-7187: Assignee: (was: Andras Katona) > offsetsForTimes in MockConsumer implementation >

[jira] [Updated] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abdelhamide EL ARIB updated KAFKA-7189: --- Description: Like the

[jira] [Created] (KAFKA-7189) Add a Merge Transformer for Kafka Connect

Abdelhamide EL ARIB created KAFKA-7189: -- Summary: Add a Merge Transformer for Kafka Connect Key: KAFKA-7189 URL: https://issues.apache.org/jira/browse/KAFKA-7189 Project: Kafka Issue

[jira] [Assigned] (KAFKA-7134) KafkaLog4jAppender - Appender exceptions are propagated to caller

[ https://issues.apache.org/jira/browse/KAFKA-7134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona reassigned KAFKA-7134: Assignee: Andras Katona > KafkaLog4jAppender - Appender exceptions are propagated to

[jira] [Created] (KAFKA-7188) Avoid reverse DNS lookup in SASL channel builder

Rajini Sivaram created KAFKA-7188: - Summary: Avoid reverse DNS lookup in SASL channel builder Key: KAFKA-7188 URL: https://issues.apache.org/jira/browse/KAFKA-7188 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7159) mark configuration files in confluent-kafka RPM SPEC file

[ https://issues.apache.org/jira/browse/KAFKA-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550735#comment-16550735 ] Attila Sasvari commented on KAFKA-7159: --- - Are you sure you filed the JIRA to the proper project?

[jira] [Assigned] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

[ https://issues.apache.org/jira/browse/KAFKA-7187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona reassigned KAFKA-7187: Assignee: Andras Katona > offsetsForTimes in MockConsumer implementation >

[jira] [Commented] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException

[ https://issues.apache.org/jira/browse/KAFKA-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550587#comment-16550587 ] williamguan commented on KAFKA-7082: Hi, I think the broker should only accept the first create

[jira] [Created] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

Jing Chen created KAFKA-7187: Summary: offsetsForTimes in MockConsumer implementation Key: KAFKA-7187 URL: https://issues.apache.org/jira/browse/KAFKA-7187 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7172) Prometheus /metrics http endpoint for monitoring integration

[ https://issues.apache.org/jira/browse/KAFKA-7172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550539#comment-16550539 ] Hari Sekhon commented on KAFKA-7172: That's a fair suggestion as a workaround for now although I

[jira] [Commented] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

[ https://issues.apache.org/jira/browse/KAFKA-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550504#comment-16550504 ] ASF GitHub Bot commented on KAFKA-7185: --- dhruvilshah3 closed pull request #5400: KAFKA-7185: Allow

[jira] [Commented] (KAFKA-7185) getMatchingAcls throws StringIndexOutOfBoundsException for empty resource name

[ https://issues.apache.org/jira/browse/KAFKA-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550505#comment-16550505 ] ASF GitHub Bot commented on KAFKA-7185: --- dhruvilshah3 opened a new pull request #5400: KAFKA-7185:

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550484#comment-16550484 ] ASF GitHub Bot commented on KAFKA-3702: --- rajinisivaram closed pull request #5397: KAFKA-3702:

[jira] [Commented] (KAFKA-6123) Give client MetricsReporter auto-generated client.id

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550350#comment-16550350 ] Kevin Lu commented on KAFKA-6123: - Created 

[jira] [Resolved] (KAFKA-7098) Improve accuracy of the log cleaner throttle rate

[ https://issues.apache.org/jira/browse/KAFKA-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7098. - Resolution: Fixed > Improve accuracy of the log cleaner throttle rate >

[jira] [Commented] (KAFKA-7098) Improve accuracy of the log cleaner throttle rate

[ https://issues.apache.org/jira/browse/KAFKA-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550300#comment-16550300 ] ASF GitHub Bot commented on KAFKA-7098: --- lindong28 closed pull request #5350: KAFKA-7098: Improve