[jira] [Commented] (KAFKA-6367) Fix StateRestoreListener To Use Correct Batch Ending Offset

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

[jira] [Commented] (KAFKA-6469) ISR change notification queue can prevent controller from making progress

[ https://issues.apache.org/jira/browse/KAFKA-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355824#comment-16355824 ] ASF GitHub Bot commented on KAFKA-6469: --- ambroff opened a new pull request #4540: KAFKA-6469 Batch

[jira] [Commented] (KAFKA-6469) ISR change notification queue can prevent controller from making progress

[ https://issues.apache.org/jira/browse/KAFKA-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355828#comment-16355828 ] Kyle Ambroff-Kao commented on KAFKA-6469: - Heh, yeah James, we don't typically run clusters like

[jira] [Commented] (KAFKA-6469) ISR change notification queue can prevent controller from making progress

[ https://issues.apache.org/jira/browse/KAFKA-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355829#comment-16355829 ] Kyle Ambroff-Kao commented on KAFKA-6469: - [~junrao] The number of children of

[jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4969: --- Fix Version/s: 1.1.0 > State-store workload-aware StreamsPartitionAssignor >

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to infinity

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356140#comment-16356140 ] Guozhang Wang commented on KAFKA-6535: -- I see you point now. And yes, I agree that we could improve

[jira] [Created] (KAFKA-6540) Consumer lag metric is not updated when a partition is paused

Jason Gustafson created KAFKA-6540: -- Summary: Consumer lag metric is not updated when a partition is paused Key: KAFKA-6540 URL: https://issues.apache.org/jira/browse/KAFKA-6540 Project: Kafka

[jira] [Commented] (KAFKA-6519) Change log level from ERROR to WARN for not leader for this partition exception

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

[jira] [Commented] (KAFKA-6405) Fix incorrect comment in MetadataUpdater

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

[jira] [Commented] (KAFKA-2423) Introduce Scalastyle

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

[jira] [Commented] (KAFKA-2423) Introduce Scalastyle

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356374#comment-16356374 ] Ray Chiang commented on KAFKA-2423: --- Hmmm...it looks like my PR has a different default text.  Please

[jira] [Commented] (KAFKA-5327) Console Consumer should only poll for up to max messages

[ https://issues.apache.org/jira/browse/KAFKA-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356375#comment-16356375 ] ASF GitHub Bot commented on KAFKA-5327: --- huxihx opened a new pull request #4546: KAFKA-5327: Console

[jira] [Updated] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers

[ https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6481: -- Description: The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should only

[jira] [Commented] (KAFKA-6514) Add API version as a tag for the RequestsPerSec metric

[ https://issues.apache.org/jira/browse/KAFKA-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356321#comment-16356321 ] Ismael Juma commented on KAFKA-6514: [~allenxwang], the tags are part of the name in JMX and hence it

[jira] [Commented] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356331#comment-16356331 ] Guozhang Wang commented on KAFKA-6106: -- [~ckamal] Are you still working on this issue? > Postpone

[jira] [Commented] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder

[ https://issues.apache.org/jira/browse/KAFKA-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356145#comment-16356145 ] Leonardo Toledo commented on KAFKA-3910: Hi, someone can tell me if there are plans to fix and

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to infinity

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356231#comment-16356231 ] Matthias J. Sax commented on KAFKA-6535: So you don't think that adding a "config" to the API

[jira] [Commented] (KAFKA-4641) Improve test coverage of StreamsThread

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

[jira] [Resolved] (KAFKA-4641) Improve test coverage of StreamsThread

[ https://issues.apache.org/jira/browse/KAFKA-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4641. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 1.2.0 > Improve test

[jira] [Updated] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers

[ https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6481: -- Description: The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should only

[jira] [Updated] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers

[ https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6481: -- Description: The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should only

[jira] [Updated] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers

[ https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6481: -- Description: The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should only

[jira] [Commented] (KAFKA-6537) Duplicate consumers after consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356606#comment-16356606 ] Michael Golovanov commented on KAFKA-6537: -- Seems this issue duplicate of 

[jira] [Created] (KAFKA-6541) StackOverflow exceptions in thread 'kafka-coordinator-heartbeat-thread

Anh Le created KAFKA-6541: - Summary: StackOverflow exceptions in thread 'kafka-coordinator-heartbeat-thread Key: KAFKA-6541 URL: https://issues.apache.org/jira/browse/KAFKA-6541 Project: Kafka

[jira] [Comment Edited] (KAFKA-6537) Duplicate consumers after consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356606#comment-16356606 ] Michael Golovanov edited comment on KAFKA-6537 at 2/8/18 7:46 AM: -- Seems

[jira] [Issue Comment Deleted] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Smurygin updated KAFKA-6291: - Comment: was deleted (was: Hello! I faced the same issue during my testing. Is there any

[jira] [Commented] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355103#comment-16355103 ] Ivan Smurygin commented on KAFKA-6291: -- Hello! I faced the same issue during my testing. Is there

[jira] [Commented] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355107#comment-16355107 ] Ivan Smurygin commented on KAFKA-6291: -- Here is another workaround

[jira] [Comment Edited] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355107#comment-16355107 ] Ivan Smurygin edited comment on KAFKA-6291 at 2/7/18 8:13 AM: -- Here is

[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355229#comment-16355229 ] huxihx commented on KAFKA-6522: --- [~bookxiao] hmmm Based on the stack trace, ApiKeys [Line

[jira] [Commented] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355257#comment-16355257 ] james chien commented on KAFKA-6498: [~guozhang] Now I familiar with kafka metrics, so I want to

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355320#comment-16355320 ] Manikumar commented on KAFKA-6524: -- [~huxi_2b] Not sure how "client.id" affects producing to internal

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355342#comment-16355342 ] Ahmed Madkour commented on KAFKA-6524: -- [~huxi_2b] I tried it and I no longer see the errors. So what

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355377#comment-16355377 ] Manikumar commented on KAFKA-6524: -- [~huxi_2b] Thanks for the pointer. looked into the code. Never

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355451#comment-16355451 ] huxihx commented on KAFKA-6524: --- [~omkreddy] Sorry to mistake you for the reporter:) [~ahmed.madkour] Like

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355471#comment-16355471 ] Ahmed Madkour commented on KAFKA-6524: -- Thank you, I am going to close the issue now. > kafka mirror

[jira] [Resolved] (KAFKA-6524) kafka mirror can't producer internal topic

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Madkour resolved KAFKA-6524. -- Resolution: Information Provided > kafka mirror can't producer internal topic >

[jira] [Assigned] (KAFKA-2423) Introduce Scalastyle

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2423: -- Assignee: Ray Chiang (was: Grant Henke) > Introduce Scalastyle > > >

[jira] [Commented] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355562#comment-16355562 ] Randall Hauch commented on KAFKA-6504: -- [~rayokota], ping. Please see [~steff1193]'s comments.

[jira] [Updated] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6529: -- Fix Version/s: 1.0.2 0.11.0.3 1.1.0 > Broker leaks memory

[jira] [Resolved] (KAFKA-6532) Delegation token internals should not impact public interfaces

[ https://issues.apache.org/jira/browse/KAFKA-6532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6532. --- Resolution: Fixed Fix Version/s: 1.1.0 > Delegation token internals should not impact

[jira] [Assigned] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-6504: Assignee: Robert Yokota > Connect: Some per-task-metrics not working >

[jira] [Commented] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355785#comment-16355785 ] Robert Yokota commented on KAFKA-6504: -- [~steff1193], it's not just the metric name change.  The PR