[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&focusedCommentId=16550350#comment-16550350 ] Kevin Lu commented on KAFKA-6123: - Created  [KIP-344|https://cwiki.apache.org/confluence/

[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&focusedCommentId=16550484#comment-16550484 ] ASF GitHub Bot commented on KAFKA-3702: --- rajinisivaram closed pull request #5397: K

[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&focusedCommentId=16550504#comment-16550504 ] ASF GitHub Bot commented on KAFKA-7185: --- dhruvilshah3 closed pull request #5400: KA

[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&focusedCommentId=16550505#comment-16550505 ] ASF GitHub Bot commented on KAFKA-7185: --- dhruvilshah3 opened a new pull request #54

[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&focusedCommentId=16550539#comment-16550539 ] Hari Sekhon commented on KAFKA-7172: That's a fair suggestion as a workaround for now

[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-7082) Concurrent createTopics calls may throw NodeExistsException

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

[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&focusedCommentId=16550650#comment-16550650 ] Ismael Juma commented on KAFKA-7082: If you have two people trying to create the same

[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-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&focusedCommentId=16550735#comment-16550735 ] Attila Sasvari commented on KAFKA-7159: --- - Are you sure you filed the JIRA to the p

[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] [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 calle

[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 Typ

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

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

[ https://issues.apache.org/jira/browse/KAFKA-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550752#comment-16550752 ] ASF GitHub Bot commented on KAFKA-7189: --- elarib opened a new pull request #5405: KA

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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 [flatten|https://docs.confluent.io/current/connect/transforms/

[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&focusedCommentId=16550903#comment-16550903 ] ASF GitHub Bot commented on KAFKA-7141: --- hachikuji closed pull request #5356: KAFKA

[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   http

[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&focusedCommentId=16551012#comment-16551012 ] Matthias J. Sax commented on KAFKA-6520: [~harjitdotsingh] Not sure what you exac

[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&focusedCommentId=16551025#comment-16551025 ] Harjit Singh commented on KAFKA-6520: - [~mjsax] - Is there a sample app for Streaming

[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&focusedCommentId=16551030#comment-16551030 ] ASF GitHub Bot commented on KAFKA-5037: --- guozhangwang closed pull request #5399: KA

[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&focusedCommentId=16551045#comment-16551045 ] ASF GitHub Bot commented on KAFKA-7109: --- stanislavkozlovski opened a new pull reque

[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&focusedCommentId=16551055#comment-16551055 ] ASF GitHub Bot commented on KAFKA-5039: --- ijuma closed pull request #2820: KAFKA-503

[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&focusedCommentId=16551062#comment-16551062 ] Ray Chiang commented on KAFKA-7154: --- A lot could depend on how you intend to make Kafka

[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&focusedCommentId=16551071#comment-16551071 ] ASF GitHub Bot commented on KAFKA-5037: --- mjsax closed pull request #2815: WIP DO NO

[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&focusedCommentId=16551089#comment-16551089 ] Matthias J. Sax commented on KAFKA-6520: As mentioned, try the `WordCountExample`

[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: https://issues.apache.org/jira/browse/KAFKA-719

[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&focusedCommentId=16551172#comment-16551172 ] ASF GitHub Bot commented on KAFKA-7185: --- rajinisivaram closed pull request #5400: K

[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 > getMatchingAcl

[jira] [Updated] (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 ] Dong Lin updated KAFKA-7126: Attachment: 1.diff > Reduce number of rebalance period for large consumer groups after a topic is > create

[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&focusedCommentId=16551239#comment-16551239 ] Dong Lin commented on KAFKA-7126: - The simply patch in the attachment mostly fixes the is

[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] [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 after

[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] [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&focusedCommentId=16551270#comment-16551270 ] Ray Chiang commented on KAFKA-6918: --- Using Ubuntu 16.0.4 and this version of IBM Java:

[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] [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] [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&focusedCommentId=16551345#comment-16551345 ] ASF GitHub Bot commented on KAFKA-7126: --- jonlee2 opened a new pull request #5408: K

[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] [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 > clients/broker

[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] [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&focusedCommentId=16551483#comment-16551483 ] ASF GitHub Bot commented on KAFKA-5682: --- stanislavkozlovski opened a new pull reque

[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&focusedCommentId=16551526#comment-16551526 ] Ted Yu commented on KAFKA-7175: --- Haven't found a way for python to directly reference const

[jira] [Updated] (KAFKA-7147) Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7147: Fix Version/s: 2.1.0 > Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client > pro

[jira] [Updated] (KAFKA-7152) replica should be in-sync if its LEO equals leader's LEO

[ https://issues.apache.org/jira/browse/KAFKA-7152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7152: Fix Version/s: 2.1.0 > replica should be in-sync if its LEO equals leader's LEO > -