[jira] [Commented] (KAFKA-15092) KafkaClusterTestKit in test jar depends on MockFaultHandler

[ https://issues.apache.org/jira/browse/KAFKA-15092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767271#comment-17767271 ] Gary Russell commented on KAFKA-15092: -- I see that it is in server-common...-test.jar   Please

[jira] [Commented] (KAFKA-15482) kafka.utils.TestUtils Depends on MockTime Which is Not in Any Jar

[ https://issues.apache.org/jira/browse/KAFKA-15482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767267#comment-17767267 ] Gary Russell commented on KAFKA-15482: -- My apologies; I didn't see that jar in Maven Central.  

[jira] [Updated] (KAFKA-15482) kafka.utils.TestUtils Depends on MockTime Which is Not in Any Jar

[ https://issues.apache.org/jira/browse/KAFKA-15482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Russell updated KAFKA-15482: - Priority: Major (was: Blocker) > kafka.utils.TestUtils Depends on MockTime Which is Not in Any

[jira] [Created] (KAFKA-15482) kafka.utils.TestUtils Depends on MockTime Which is Not in Any Jar

Gary Russell created KAFKA-15482: Summary: kafka.utils.TestUtils Depends on MockTime Which is Not in Any Jar Key: KAFKA-15482 URL: https://issues.apache.org/jira/browse/KAFKA-15482 Project: Kafka

[jira] [Created] (KAFKA-15092) KafkaClusterTestKit in test jar depends on MockFaultHandler

Gary Russell created KAFKA-15092: Summary: KafkaClusterTestKit in test jar depends on MockFaultHandler Key: KAFKA-15092 URL: https://issues.apache.org/jira/browse/KAFKA-15092 Project: Kafka

[jira] [Commented] (KAFKA-13400) offset() is not supported in standby tasks.

[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435406#comment-17435406 ] Gary Russell commented on KAFKA-13400: -- [~mjsax] It's hard to say without seeing code, but stack

[jira] [Commented] (KAFKA-13400) offset() is not supported in standby tasks.

[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434378#comment-17434378 ] Gary Russell commented on KAFKA-13400: -- While this does not appear to be related to Spring, can you

[jira] [Updated] (KAFKA-13262) Mock Clients Now Have Final close() Methods

[ https://issues.apache.org/jira/browse/KAFKA-13262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Russell updated KAFKA-13262: - Description: Subclasses can no longer clean up resources when the consumer is closed. Caused

[jira] [Updated] (KAFKA-13262) Mock Clients Now Have Final close() Methods

[ https://issues.apache.org/jira/browse/KAFKA-13262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Russell updated KAFKA-13262: - Description: Subclasses can no longer clean up resources when the consumer or producer is

[jira] [Created] (KAFKA-13262) Mock Clients Now Have Final close() Methods

Gary Russell created KAFKA-13262: Summary: Mock Clients Now Have Final close() Methods Key: KAFKA-13262 URL: https://issues.apache.org/jira/browse/KAFKA-13262 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-13147) connection-close-total Metric Keeps Incrementing While Broker Down

[ https://issues.apache.org/jira/browse/KAFKA-13147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Russell updated KAFKA-13147: - Description: When the broker is down, the {code}connection-close-total{code} keeps

[jira] [Created] (KAFKA-13147) connection-close-total Metric Keeps Incrementing While Broker Down

Gary Russell created KAFKA-13147: Summary: connection-close-total Metric Keeps Incrementing While Broker Down Key: KAFKA-13147 URL: https://issues.apache.org/jira/browse/KAFKA-13147 Project: Kafka

[jira] [Comment Edited] (KAFKA-13054) Unexpected Polling Behavior

[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377606#comment-17377606 ] Gary Russell edited comment on KAFKA-13054 at 7/8/21, 9:55 PM: --- Yes, after

[jira] [Commented] (KAFKA-13054) Unexpected Polling Behavior

[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377606#comment-17377606 ] Gary Russell commented on KAFKA-13054: -- Yes, after increasing the partitions, I get 2000 on each

[jira] [Commented] (KAFKA-13054) Unexpected Polling Behavior

[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377600#comment-17377600 ] Gary Russell commented on KAFKA-13054: -- I think I see a pattern; the 3rd poll does not fetch any

[jira] [Created] (KAFKA-13054) Unexpected Polling Behavior

Gary Russell created KAFKA-13054: Summary: Unexpected Polling Behavior Key: KAFKA-13054 URL: https://issues.apache.org/jira/browse/KAFKA-13054 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12535) Consider Revising Document Anchors for Properties

Gary Russell created KAFKA-12535: Summary: Consider Revising Document Anchors for Properties Key: KAFKA-12535 URL: https://issues.apache.org/jira/browse/KAFKA-12535 Project: Kafka Issue

[jira] [Commented] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267959#comment-17267959 ] Gary Russell commented on KAFKA-12190: -- Thanks [~awilkinson]. {quote} but I don't think we need to

[jira] [Commented] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265081#comment-17265081 ] Gary Russell commented on KAFKA-12190: -- Given that this is a critical bug, and a regression in a

[jira] [Commented] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247449#comment-17247449 ] Gary Russell commented on KAFKA-10802: -- Thanks, guys, really appreciate it; I think this simple fix

[jira] [Commented] (KAFKA-10790) Detect/Prevent Deadlock on Producer Network Thread

[ https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244110#comment-17244110 ] Gary Russell commented on KAFKA-10790: -- [~chia7712] I am just the reporter; I am not a Kafka

[jira] [Commented] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243273#comment-17243273 ] Gary Russell commented on KAFKA-10802: -- Also >I am not sure I understand why it's logged at INFO

[jira] [Created] (KAFKA-10790) Detect/Prevent Deadlock on Producer Network Thread

Gary Russell created KAFKA-10790: Summary: Detect/Prevent Deadlock on Producer Network Thread Key: KAFKA-10790 URL: https://issues.apache.org/jira/browse/KAFKA-10790 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-10384) Separate converters from generated messages

[ https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238230#comment-17238230 ] Gary Russell edited comment on KAFKA-10384 at 11/24/20, 8:20 PM: - Also

[jira] [Comment Edited] (KAFKA-10384) Separate converters from generated messages

[ https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238230#comment-17238230 ] Gary Russell edited comment on KAFKA-10384 at 11/24/20, 4:00 PM: - Is

[jira] [Commented] (KAFKA-10384) Separate converters from generated messages

[ https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238230#comment-17238230 ] Gary Russell commented on KAFKA-10384: -- Is there any change the provided scope can be removed in

[jira] [Commented] (KAFKA-10683) Consumer.position() Ignores Transaction Marker with read_uncommitted

[ https://issues.apache.org/jira/browse/KAFKA-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229992#comment-17229992 ] Gary Russell commented on KAFKA-10683: -- In my opinion, Kafka should "hide" this pseudo lag -

[jira] [Comment Edited] (KAFKA-10683) Consumer.position() Ignores Transaction Marker with read_uncommitted

[ https://issues.apache.org/jira/browse/KAFKA-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226774#comment-17226774 ] Gary Russell edited comment on KAFKA-10683 at 11/5/20, 3:35 PM: In

[jira] [Commented] (KAFKA-10683) Consumer.position() Ignores Transaction Marker with read_uncommitted

[ https://issues.apache.org/jira/browse/KAFKA-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226774#comment-17226774 ] Gary Russell commented on KAFKA-10683: -- In addition, position() does not take the marker into

[jira] [Created] (KAFKA-10683) Consumer.position() Ignores Transaction Marker with read_uncommitted

Gary Russell created KAFKA-10683: Summary: Consumer.position() Ignores Transaction Marker with read_uncommitted Key: KAFKA-10683 URL: https://issues.apache.org/jira/browse/KAFKA-10683 Project: Kafka

[jira] [Commented] (KAFKA-8531) Change default replication factor config

[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214863#comment-17214863 ] Gary Russell commented on KAFKA-8531: - [~mjsax] Will do; I just didn't think it worth it to open a

[jira] [Commented] (KAFKA-8531) Change default replication factor config

[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214773#comment-17214773 ] Gary Russell commented on KAFKA-8531: - The docs for default.replication.factor should also be changed

[jira] [Commented] (KAFKA-9750) Flaky test kafka.server.ReplicaManagerTest.testFencedErrorCausedByBecomeLeader

[ https://issues.apache.org/jira/browse/KAFKA-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073004#comment-17073004 ] Gary Russell commented on KAFKA-9750: - [~mumrah] Thanks; any chance the 2.5.0 GA (not RC) will be

[jira] [Commented] (KAFKA-9750) Flaky test kafka.server.ReplicaManagerTest.testFencedErrorCausedByBecomeLeader

[ https://issues.apache.org/jira/browse/KAFKA-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072991#comment-17072991 ] Gary Russell commented on KAFKA-9750: - Sorry to comment here; couldn't find anywhere else to ask. 

[jira] [Commented] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice

[ https://issues.apache.org/jira/browse/KAFKA-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983829#comment-16983829 ] Gary Russell commented on KAFKA-7016: - +1 - it's a total pain to have to do a text search to figure

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845029#comment-16845029 ] Gary Russell commented on KAFKA-8195: - {quote} How did you end up in this situation? {quote} Once I

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840587#comment-16840587 ] Gary Russell commented on KAFKA-8195: - I can confirm that, when using a size limit of 1000 (and

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840572#comment-16840572 ] Gary Russell commented on KAFKA-8195: - I understand, but since I'm not really the originator of the

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835058#comment-16835058 ] Gary Russell commented on KAFKA-8195: - [~viktorsomogyi] I tested with the clients from the trunk. It

[jira] [Comment Edited] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835058#comment-16835058 ] Gary Russell edited comment on KAFKA-8195 at 5/7/19 7:53 PM: -

[jira] [Created] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

Gary Russell created KAFKA-8195: --- Summary: Unstable Producer After Send Failure in Transaction Key: KAFKA-8195 URL: https://issues.apache.org/jira/browse/KAFKA-8195 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16234738#comment-16234738 ] Gary Russell edited comment on KAFKA-5766 at 11/1/17 9:26 PM: -- Yes, you can

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16234738#comment-16234738 ] Gary Russell commented on KAFKA-5766: - Yes, you can reduce the CPU load for a down broker by adding