[jira] [Updated] (KAFKA-13965) Document broker-side socket-server-metrics

[ https://issues.apache.org/jira/browse/KAFKA-13965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-13965: Labels: newbie newbie++ (was: ) > Document broker-side socket-server-metrics >

[jira] [Created] (KAFKA-13965) Document broker-side socket-server-metrics

James Cheng created KAFKA-13965: --- Summary: Document broker-side socket-server-metrics Key: KAFKA-13965 URL: https://issues.apache.org/jira/browse/KAFKA-13965 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432797#comment-17432797 ] James Cheng commented on KAFKA-9062: [~vvcephei], you said that in 2.6, you removed "bulk loading".

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432794#comment-17432794 ] James Cheng commented on KAFKA-9062: Are there any metrics that we can measure and look at, to see if

[jira] [Commented] (KAFKA-10232) MirrorMaker2 internal topics Formatters

[ https://issues.apache.org/jira/browse/KAFKA-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286270#comment-17286270 ] James Cheng commented on KAFKA-10232: - This was implemented in 

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266396#comment-17266396 ] James Cheng commented on KAFKA-8522: The pull request has been moved to

[jira] [Commented] (KAFKA-10801) Docs on configuration have multiple places using the same HTML anchor tag

[ https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243078#comment-17243078 ] James Cheng commented on KAFKA-10801: - Thanks [~tombentley]!   I just looked it up. For future

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242921#comment-17242921 ] James Cheng commented on KAFKA-8522: Hi, we are also experiencing this behavior. I was wondering what

[jira] [Created] (KAFKA-10801) Docs on configuration have multiple places using the same HTML anchor tag

James Cheng created KAFKA-10801: --- Summary: Docs on configuration have multiple places using the same HTML anchor tag Key: KAFKA-10801 URL: https://issues.apache.org/jira/browse/KAFKA-10801 Project:

[jira] [Commented] (KAFKA-10509) Add metric to track throttle time due to hitting connection rate quota

[ https://issues.apache.org/jira/browse/KAFKA-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211484#comment-17211484 ] James Cheng commented on KAFKA-10509: - Can we also update the documentation at

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210470#comment-17210470 ] James Cheng commented on KAFKA-7447: Hi. The consensus seems to be that this was fixed in

[jira] [Assigned] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

[ https://issues.apache.org/jira/browse/KAFKA-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-8653: -- Assignee: James Cheng (was: Jason Gustafson) > Regression in JoinGroup v0 rebalance timeout

[jira] [Assigned] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

[ https://issues.apache.org/jira/browse/KAFKA-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-8653: -- Assignee: (was: James Cheng) > Regression in JoinGroup v0 rebalance timeout handling >

[jira] [Assigned] (KAFKA-10473) Website is missing docs on JMX metrics for partition size-on-disk (kafka.log:type=Log,name=*)

[ https://issues.apache.org/jira/browse/KAFKA-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-10473: --- Assignee: James Cheng > Website is missing docs on JMX metrics for partition size-on-disk

[jira] [Updated] (KAFKA-10473) Website is missing docs on JMX metrics for partition size-on-disk (kafka.log:type=Log,name=*)

[ https://issues.apache.org/jira/browse/KAFKA-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-10473: Summary: Website is missing docs on JMX metrics for partition size-on-disk

[jira] [Created] (KAFKA-10473) Website is missing docs on JMX metrics for partition size-on-disk

James Cheng created KAFKA-10473: --- Summary: Website is missing docs on JMX metrics for partition size-on-disk Key: KAFKA-10473 URL: https://issues.apache.org/jira/browse/KAFKA-10473 Project: Kafka

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189628#comment-17189628 ] James Cheng commented on KAFKA-8764: [~junrao], in the comment

[jira] [Commented] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134694#comment-17134694 ] James Cheng commented on KAFKA-10105: - Would any of you be able to provide a repro case? Or steps to

[jira] [Commented] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128005#comment-17128005 ] James Cheng commented on KAFKA-10105: - Is this related to

[jira] [Commented] (KAFKA-9935) Kafka not releasing member from Consumer Group

[ https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128007#comment-17128007 ] James Cheng commented on KAFKA-9935: Is this related to

[jira] [Commented] (KAFKA-8180) Deleting large number of topics can block the controller for the time it takes to delete all of them

[ https://issues.apache.org/jira/browse/KAFKA-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127196#comment-17127196 ] James Cheng commented on KAFKA-8180: Do we know if this has been fixed in recent versions? I recall

[jira] [Commented] (KAFKA-9697) ControlPlaneNetworkProcessorAvgIdlePercent is always NaN

[ https://issues.apache.org/jira/browse/KAFKA-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076763#comment-17076763 ] James Cheng commented on KAFKA-9697: Oh, no, we don't have that setup. I had assumed that the 

[jira] [Commented] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

[ https://issues.apache.org/jira/browse/KAFKA-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1705#comment-1705 ] James Cheng commented on KAFKA-9389: [~mitchellh], I think in order for Jira to auto-link your PR,

[jira] [Created] (KAFKA-9697) ControlPlaneNetworkProcessorAvgIdlePercent is always NaN

James Cheng created KAFKA-9697: -- Summary: ControlPlaneNetworkProcessorAvgIdlePercent is always NaN Key: KAFKA-9697 URL: https://issues.apache.org/jira/browse/KAFKA-9697 Project: Kafka Issue

[jira] [Created] (KAFKA-9696) Document the control plane metrics that were added in KIP-402

James Cheng created KAFKA-9696: -- Summary: Document the control plane metrics that were added in KIP-402 Key: KAFKA-9696 URL: https://issues.apache.org/jira/browse/KAFKA-9696 Project: Kafka

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042297#comment-17042297 ] James Cheng commented on KAFKA-4084: Hi   Just wanted to chime in with some of our experience on this

[jira] [Commented] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

[ https://issues.apache.org/jira/browse/KAFKA-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17025451#comment-17025451 ] James Cheng commented on KAFKA-9389: [~mitchellh], I noticed you closed this pull request. What's

[jira] [Created] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

James Cheng created KAFKA-9389: -- Summary: Document how to use kafka-reassign-partitions.sh to change log dirs for a partition Key: KAFKA-9389 URL: https://issues.apache.org/jira/browse/KAFKA-9389

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971825#comment-16971825 ] James Cheng commented on KAFKA-9133: Will there be a 2.3.2 release?   > LogCleaner thread dies

[jira] [Resolved] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng resolved KAFKA-8745. Fix Version/s: 2.4.0 Reviewer: Guozhang Wang Resolution: Fixed > DumpLogSegments

[jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8813: --- Description: In Partition.createLog we do: {code:java} val config =

[jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8813: --- Description: In Partition.createLog we do: {{val config =

[jira] [Commented] (KAFKA-8808) Kafka Inconsistent Retention Period across partitions

[ https://issues.apache.org/jira/browse/KAFKA-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909626#comment-16909626 ] James Cheng commented on KAFKA-8808: How did you create your topics? We ran into something like that

[jira] [Commented] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898440#comment-16898440 ] James Cheng commented on KAFKA-8745: [~guozhang]: This is ready for review. The instructions at

[jira] [Updated] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8745: --- Flags: Patch > DumpLogSegments doesn't show keys, when the message is null >

[jira] [Created] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

James Cheng created KAFKA-8745: -- Summary: DumpLogSegments doesn't show keys, when the message is null Key: KAFKA-8745 URL: https://issues.apache.org/jira/browse/KAFKA-8745 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-8745: -- Assignee: James Cheng > DumpLogSegments doesn't show keys, when the message is null >

[jira] [Commented] (KAFKA-8634) Update ZooKeeper to 3.5.5

[ https://issues.apache.org/jira/browse/KAFKA-8634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883294#comment-16883294 ] James Cheng commented on KAFKA-8634: [~ijuma]: Prior to this PR, can I use Kafka to talk to Zookeeper

[jira] [Commented] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826524#comment-16826524 ] James Cheng commented on KAFKA-8282: In 1.0.0, the behavior was changed such that these metrics are

[jira] [Commented] (KAFKA-8180) Deleting large number of topics can block the controller for the time it takes to delete all of them

[ https://issues.apache.org/jira/browse/KAFKA-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809585#comment-16809585 ] James Cheng commented on KAFKA-8180: Looking forward to seeing this get fixed. This has locked up our

[jira] [Commented] (KAFKA-8069) Committed offsets get cleaned up right after the coordinator loading them back from __consumer_offsets in broker with old inter-broker protocol version (< 2.2)

[ https://issues.apache.org/jira/browse/KAFKA-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788101#comment-16788101 ] James Cheng commented on KAFKA-8069: [~mjsax] [~hachikuji], is this critical enough that we will spin

[jira] [Created] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values"

James Cheng created KAFKA-7884: -- Summary: Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values" Key: KAFKA-7884 URL: https://issues.apache.org/jira/browse/KAFKA-7884

[jira] [Comment Edited] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750278#comment-16750278 ] James Cheng edited comment on KAFKA-7657 at 1/23/19 5:59 PM: - This was fixed

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750278#comment-16750278 ] James Cheng commented on KAFKA-7657: This was fixed in [https://github.com/apache/kafka/pull/6091]

[jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747400#comment-16747400 ] James Cheng commented on KAFKA-6964: [~guozhang], is the reason you are closing it as WONTFIX because

[jira] [Created] (KAFKA-7797) Replication throttling configs aren't in the docs

James Cheng created KAFKA-7797: -- Summary: Replication throttling configs aren't in the docs Key: KAFKA-7797 URL: https://issues.apache.org/jira/browse/KAFKA-7797 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702167#comment-16702167 ] James Cheng commented on KAFKA-6951: [~vultron81]: I think that the kafka-consumer-groups.sh tool

[jira] [Commented] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker

[ https://issues.apache.org/jira/browse/KAFKA-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687423#comment-16687423 ] James Cheng commented on KAFKA-7615: [~adeetikaushal]: This can be implemented by supplying a

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648586#comment-16648586 ] James Cheng commented on KAFKA-4084: [~jiaxinye]: You are probably hitting

[jira] [Comment Edited] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621106#comment-16621106 ] James Cheng edited comment on KAFKA-7332 at 9/19/18 8:00 PM: - Thanks

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621106#comment-16621106 ] James Cheng commented on KAFKA-7332: Thanks [~lindong]. I agree with you that design-wise it makes

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621021#comment-16621021 ] James Cheng commented on KAFKA-7332: [~lindong], this is somewhat related to

[jira] [Commented] (KAFKA-7286) Loading offsets and group metadata hangs with large group metadata records

[ https://issues.apache.org/jira/browse/KAFKA-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16608792#comment-16608792 ] James Cheng commented on KAFKA-7286: How many members would be needed in a group to trigger this

[jira] [Commented] (KAFKA-6746) Allow ZK Znode configurable for Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542310#comment-16542310 ] James Cheng commented on KAFKA-6746: I noticed the same thing as [~gsbiju]. I think [~mimaison] may

[jira] [Commented] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539598#comment-16539598 ] James Cheng commented on KAFKA-7144: The attached repro java file has all the code. I didn’t specify

[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=16539373#comment-16539373 ] James Cheng commented on KAFKA-7141: I think it's a little odd that kafka-consumer-groups doesn't

[jira] [Created] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

James Cheng created KAFKA-7144: -- Summary: Kafka Streams doesn't properly balance partition assignment Key: KAFKA-7144 URL: https://issues.apache.org/jira/browse/KAFKA-7144 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535641#comment-16535641 ] James Cheng edited comment on KAFKA-1342 at 7/7/18 6:12 AM: In an older

[jira] [Commented] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535644#comment-16535644 ] James Cheng commented on KAFKA-1342: Found it: https://github.com/apache/kafka/pull/4075 And

[jira] [Commented] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535641#comment-16535641 ] James Cheng commented on KAFKA-1342: In an older release, there was a logging “bug” in the controller

[jira] [Commented] (KAFKA-5510) Streams should commit all offsets regularly

[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503897#comment-16503897 ] James Cheng commented on KAFKA-5510: KIP-211 should address the issue of offsets disappearing on

[jira] [Created] (KAFKA-6970) Kafka streams lets the user call init() and close() on a state store, when inside Processors

James Cheng created KAFKA-6970: -- Summary: Kafka streams lets the user call init() and close() on a state store, when inside Processors Key: KAFKA-6970 URL: https://issues.apache.org/jira/browse/KAFKA-6970

[jira] [Commented] (KAFKA-6967) TopologyTestDriver does not allow pre-populating state stores that have change logging

[ https://issues.apache.org/jira/browse/KAFKA-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494299#comment-16494299 ] James Cheng commented on KAFKA-6967: If the very first call to the state store is a `store.put()`, it

[jira] [Assigned] (KAFKA-6967) TopologyTestDriver does not allow pre-populating state stores that have change logging

[ https://issues.apache.org/jira/browse/KAFKA-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-6967: -- Assignee: Matthias J. Sax > TopologyTestDriver does not allow pre-populating state stores

[jira] [Created] (KAFKA-6967) TopologyTestDriver does not allow pre-populating state stores that have change logging

James Cheng created KAFKA-6967: -- Summary: TopologyTestDriver does not allow pre-populating state stores that have change logging Key: KAFKA-6967 URL: https://issues.apache.org/jira/browse/KAFKA-6967

[jira] [Commented] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481754#comment-16481754 ] James Cheng commented on KAFKA-3473: I was thinking of the

[jira] [Commented] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481489#comment-16481489 ] James Cheng commented on KAFKA-3473: [~lindong], can you update the docs to include this new metric?

[jira] [Commented] (KAFKA-6830) Add new metrics for consumer/replication fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457470#comment-16457470 ] James Cheng commented on KAFKA-6830: New metrics require a KIP. Would you be able to put one together? 

[jira] [Commented] (KAFKA-6746) Allow ZK Znode configurable for Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426344#comment-16426344 ] James Cheng commented on KAFKA-6746: The zookeeper.connect config value actually lets you specify a

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405558#comment-16405558 ] James Cheng commented on KAFKA-4893: We ran into another error which may be related to this:

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405553#comment-16405553 ] James Cheng commented on KAFKA-4893: We just ran into this. Our mirroring setup automatically prepends

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399698#comment-16399698 ] James Cheng commented on KAFKA-6264: We recently ran into this on one of our clusters. {code:java}

[jira] [Commented] (KAFKA-6588) Add a metric to monitor live log cleaner thread

[ https://issues.apache.org/jira/browse/KAFKA-6588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375316#comment-16375316 ] James Cheng commented on KAFKA-6588: KAFKA-3857 added a metric "time-since-last-run-ms". If it's

[jira] [Commented] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

[ https://issues.apache.org/jira/browse/KAFKA-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348232#comment-16348232 ] James Cheng commented on KAFKA-6505: [~steff1193]: Yes, a KIP is still required even if you are only

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345577#comment-16345577 ] James Cheng commented on KAFKA-6166: This PR didn't have any docs updates. Should it have, or is the

[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=16335399#comment-16335399 ] James Cheng commented on KAFKA-6469: In addition to this bug, I'm kind of curious how you managed to

[jira] [Commented] (KAFKA-3741) Allow setting of default topic configs via StreamsConfig

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16331937#comment-16331937 ] James Cheng commented on KAFKA-3741: Some of these docs seem to have disappeared from top of trunk, or

[jira] [Commented] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16316749#comment-16316749 ] James Cheng commented on KAFKA-6422: I have no ability to merge PRs, but the change looks good to me.

[jira] [Commented] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315086#comment-16315086 ] James Cheng commented on KAFKA-6422: [~Xin Li], you should assign this JIRA to yourself (Edit ->

[jira] [Comment Edited] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16293291#comment-16293291 ] James Cheng edited comment on KAFKA-3955 at 12/15/17 9:45 PM: -- [~ijuma], I

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16293294#comment-16293294 ] James Cheng commented on KAFKA-3410: Do we think KAFKA-1211 resolves this? If so, should we set Fix

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16293291#comment-16293291 ] James Cheng commented on KAFKA-3955: [~ijuma], I said in my comment that: {quote} Note that it is only

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285148#comment-16285148 ] James Cheng commented on KAFKA-3955: log.message.format.version = 0.10.0.1 > Kafka log recovery

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285136#comment-16285136 ] James Cheng commented on KAFKA-3955: We encountered this last week on 0.11.0.1. Thanks to

[jira] [Commented] (KAFKA-6314) Add a tool to delete consumer offsets for a given group

[ https://issues.apache.org/jira/browse/KAFKA-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283235#comment-16283235 ] James Cheng commented on KAFKA-6314: FYI, kafka-consumer-groups.sh already has --delete support, but

[jira] [Updated] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-6312: --- Labels: newbie (was: ) > Add documentation about kafka-consumer-groups.sh's ability to set/change >

[jira] [Created] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

James Cheng created KAFKA-6312: -- Summary: Add documentation about kafka-consumer-groups.sh's ability to set/change offsets Key: KAFKA-6312 URL: https://issues.apache.org/jira/browse/KAFKA-6312 Project:

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253663#comment-16253663 ] James Cheng commented on KAFKA-3806: [~jcrowley], you should check out

[jira] [Created] (KAFKA-6197) Difficult to get to the Kafka Streams javadocs

James Cheng created KAFKA-6197: -- Summary: Difficult to get to the Kafka Streams javadocs Key: KAFKA-6197 URL: https://issues.apache.org/jira/browse/KAFKA-6197 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6175) AbstractIndex should cache index file to avoid unnecessary disk access during resize()

[ https://issues.apache.org/jira/browse/KAFKA-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241010#comment-16241010 ] James Cheng commented on KAFKA-6175: [~lindong] Wow. Great work. Looking forward to this. >

[jira] [Commented] (KAFKA-6175) AbstractIndex should cache index file to avoid unnecessary disk access during resize()

[ https://issues.apache.org/jira/browse/KAFKA-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16239899#comment-16239899 ] James Cheng commented on KAFKA-6175: Do you have any estimates of how much time is saved, similar to

[jira] [Resolved] (KAFKA-6088) Kafka Consumer slows down when reading from highly compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-6088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng resolved KAFKA-6088. Resolution: Won't Fix It is fixed in kafka client 0.11.0.0, and 0.11.0.0 clients can be used

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200571#comment-16200571 ] James Cheng commented on KAFKA-6054: Here is my conversation with [~mjsax] from the Confluent Slack

[jira] [Created] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

James Cheng created KAFKA-6054: -- Summary: ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 Key: KAFKA-6054 URL:

[jira] [Updated] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-5951: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Autogenerate Producer RecordAccumulator

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192224#comment-16192224 ] James Cheng commented on KAFKA-5951: I won't be able to address [~ijuma]'s PR feedback in time for

[jira] [Created] (KAFKA-5952) Refactor Consumer Fetcher metrics

James Cheng created KAFKA-5952: -- Summary: Refactor Consumer Fetcher metrics Key: KAFKA-5952 URL: https://issues.apache.org/jira/browse/KAFKA-5952 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174346#comment-16174346 ] James Cheng commented on KAFKA-5951: [~guozhang] [~ijuma], I'd like to get this into 1.0.0, if

[jira] [Created] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

James Cheng created KAFKA-5951: -- Summary: Autogenerate Producer RecordAccumulator metrics Key: KAFKA-5951 URL: https://issues.apache.org/jira/browse/KAFKA-5951 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-5738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169222#comment-16169222 ] James Cheng commented on KAFKA-5738: The PR for this forgot to add the new Sender metrics to

  1   2   >