[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580774#comment-16580774 ] Harald Kirsch commented on KAFKA-1194: -- As far as I understand the issue, it might h

[jira] [Assigned] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7289: - Assignee: Attila Sasvari > Performance tools should allow user to specify output type >

[jira] [Commented] (KAFKA-7279) partitionsFor implicitly creates topic for the existent topic

[ https://issues.apache.org/jira/browse/KAFKA-7279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580729#comment-16580729 ] huxihx commented on KAFKA-7279: --- [~hachikuji] is it as designed? > partitionsFor implicitl

[jira] [Commented] (KAFKA-7295) Fix RequestHandlerAvgIdlePercent metric calculation

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

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580587#comment-16580587 ] ASF GitHub Bot commented on KAFKA-6761: --- guozhangwang closed pull request #5451: KA

[jira] [Created] (KAFKA-7295) Fix RequestHandlerAvgIdlePercent metric calculation

Dong Lin created KAFKA-7295: --- Summary: Fix RequestHandlerAvgIdlePercent metric calculation Key: KAFKA-7295 URL: https://issues.apache.org/jira/browse/KAFKA-7295 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation

[ https://issues.apache.org/jira/browse/KAFKA-7019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580500#comment-16580500 ] ASF GitHub Bot commented on KAFKA-7019: --- lindong28 closed pull request #5221: KAFKA

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580480#comment-16580480 ] Charith Fernando commented on KAFKA-1194: - This issue still exists on my environm

[jira] [Commented] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation

[ https://issues.apache.org/jira/browse/KAFKA-7019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580478#comment-16580478 ] ASF GitHub Bot commented on KAFKA-7019: --- lindong28 closed pull request #5505: Test

[jira] [Created] (KAFKA-7294) Optimize repartitioning for merge()

Matthias J. Sax created KAFKA-7294: -- Summary: Optimize repartitioning for merge() Key: KAFKA-7294 URL: https://issues.apache.org/jira/browse/KAFKA-7294 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580414#comment-16580414 ] John Roesler commented on KAFKA-7269: - [~lucapette], Thanks for your help! Please lea

[jira] [Created] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

Matthias J. Sax created KAFKA-7293: -- Summary: Merge followed by groupByKey/join might violate co-partioning Key: KAFKA-7293 URL: https://issues.apache.org/jira/browse/KAFKA-7293 Project: Kafka

[jira] [Resolved] (KAFKA-7222) KIP-328: Add Window Grace Period (and deprecate Window Retention)

[ https://issues.apache.org/jira/browse/KAFKA-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7222. - Resolution: Fixed Fix Version/s: 2.1.0 [https://github.com/apache/kafka/pull/5369] is merg

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

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580380#comment-16580380 ] ASF GitHub Bot commented on KAFKA-6833: --- bob-barrett opened a new pull request #550

[jira] [Resolved] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

[ https://issues.apache.org/jira/browse/KAFKA-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7169. --- Resolution: Fixed Reviewer: Ron Dagostino Fix Version/s: 2.1.0 > Add support

[jira] [Commented] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

[ https://issues.apache.org/jira/browse/KAFKA-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580251#comment-16580251 ] ASF GitHub Bot commented on KAFKA-7169: --- rajinisivaram closed pull request #5497: K

[jira] [Commented] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580175#comment-16580175 ] John Roesler commented on KAFKA-7277: - Hey [~NIzhikov], Thanks for picking this up.

[jira] [Comment Edited] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579268#comment-16579268 ] Dhruvil Shah edited comment on KAFKA-7282 at 8/14/18 5:48 PM: -

[jira] [Resolved] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

[ https://issues.apache.org/jira/browse/KAFKA-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7119. --- Resolution: Fixed Reviewer: Jun Rao Fix Version/s: 2.1.0 2.

[jira] [Commented] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

[ https://issues.apache.org/jira/browse/KAFKA-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580070#comment-16580070 ] ASF GitHub Bot commented on KAFKA-7119: --- rajinisivaram closed pull request #5487: K

[jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580065#comment-16580065 ] Guozhang Wang commented on KAFKA-6998: -- While drafting the PR, I realized that we've

[jira] [Commented] (KAFKA-7222) KIP-328: Add Window Grace Period (and deprecate Window Retention)

[ https://issues.apache.org/jira/browse/KAFKA-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580061#comment-16580061 ] ASF GitHub Bot commented on KAFKA-7222: --- guozhangwang closed pull request #5369: KA

[jira] [Commented] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation

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

[jira] [Resolved] (KAFKA-6224) Can not build Kafka 1.0.0 with gradle 3.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6224. -- Resolution: Cannot Reproduce Please reopen if the issue still exists. > Can not build Kafka 1.0.0 with

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

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-6833: -- Assignee: Bob Barrett > KafkaProducer throws "Invalid partition given with record" exception >

[jira] [Created] (KAFKA-7292) Converters should report their configuration options

Jeremy Custenborder created KAFKA-7292: -- Summary: Converters should report their configuration options Key: KAFKA-7292 URL: https://issues.apache.org/jira/browse/KAFKA-7292 Project: Kafka

[jira] [Created] (KAFKA-7291) kafka-console-consumer.sh waits on inexistent topic

HUSLEAG Dumitru created KAFKA-7291: -- Summary: kafka-console-consumer.sh waits on inexistent topic Key: KAFKA-7291 URL: https://issues.apache.org/jira/browse/KAFKA-7291 Project: Kafka Issue T

[jira] [Updated] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeremy Custenborder updated KAFKA-7273: --- Description: I found myself wanting to build a converter that stored additional type

[jira] [Updated] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeremy Custenborder updated KAFKA-7273: --- Description: I found myself wanting to build a converter that stored additional type

[jira] [Updated] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7280: -- Description: Request/response handling in FetchSessionHandler is not thread-safe. But we are u

[jira] [Updated] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7280: -- Description: Request/response handling in FetchSessionHandler is not thread-safe. But we are u

[jira] [Updated] (KAFKA-7290) Kafka Streams application fails to rebalance and is stuck in "Updated cluster metadata version"

[ https://issues.apache.org/jira/browse/KAFKA-7290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Van Laer updated KAFKA-7290: Description: Our kafka streams application crashed due to a RocksDBException, after that the consu

[jira] [Created] (KAFKA-7290) Kafka Streams application fails to rebalance and is stuck in "Updated cluster metadata version"

Tim Van Laer created KAFKA-7290: --- Summary: Kafka Streams application fails to rebalance and is stuck in "Updated cluster metadata version" Key: KAFKA-7290 URL: https://issues.apache.org/jira/browse/KAFKA-7290

[jira] [Commented] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579719#comment-16579719 ] Attila Sasvari commented on KAFKA-7289: --- It is a generalization of KAFKA-1939. > P

[jira] [Commented] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

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

[jira] [Commented] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579713#comment-16579713 ] Alastair Munro commented on KAFKA-7282: --- All brokers are running 2.0.0; I confirmed

[jira] [Created] (KAFKA-7289) Performance tools should allow user to specify output type

Attila Sasvari created KAFKA-7289: - Summary: Performance tools should allow user to specify output type Key: KAFKA-7289 URL: https://issues.apache.org/jira/browse/KAFKA-7289 Project: Kafka Is

[jira] [Created] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

Rajini Sivaram created KAFKA-7288: - Summary: Transient failure in SslSelectorTest.testCloseConnectionInClosingState Key: KAFKA-7288 URL: https://issues.apache.org/jira/browse/KAFKA-7288 Project: Kafka

[jira] [Commented] (KAFKA-7287) Set open ACL permissions for old consumer znode path

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

[jira] [Created] (KAFKA-7287) Set open ACL permissions for old consumer znode path

Manikumar created KAFKA-7287: Summary: Set open ACL permissions for old consumer znode path Key: KAFKA-7287 URL: https://issues.apache.org/jira/browse/KAFKA-7287 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579658#comment-16579658 ] Anton Bankovskii commented on KAFKA-6755: - I asked dev to assign this issue to me