[jira] [Updated] (KAFKA-15630) Improve documentation of offset.lag.max

[ https://issues.apache.org/jira/browse/KAFKA-15630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15630: Labels: newbie (was: ) > Improve documentation of offset.lag.max >

[jira] [Updated] (KAFKA-15630) Improve documentation of offset.lag.max

[ https://issues.apache.org/jira/browse/KAFKA-15630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15630: Description: It would be good to expand on the role of this configuration on offset translation

[jira] [Commented] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working

[ https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848770#comment-17848770 ] Greg Harris commented on KAFKA-16798: - Hi [~sektor.coder] There's already a ticket to improve the

[jira] [Comment Edited] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working

[ https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848670#comment-17848670 ] Greg Harris edited comment on KAFKA-16798 at 5/22/24 3:43 PM: -- Do you have

[jira] [Commented] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working

[ https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848670#comment-17848670 ] Greg Harris commented on KAFKA-16798: - Do you have low-volume topics, less than 100 records/min?

[jira] [Commented] (KAFKA-16798) Mirrormaker2 dedicated mode - sync.group.offsets.interval not working

[ https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848404#comment-17848404 ] Greg Harris commented on KAFKA-16798: - Hi [~sektor.coder] thanks for the ticket! The log message

[jira] [Created] (KAFKA-16809) Run javadoc build in CI

Greg Harris created KAFKA-16809: --- Summary: Run javadoc build in CI Key: KAFKA-16809 URL: https://issues.apache.org/jira/browse/KAFKA-16809 Project: Kafka Issue Type: Task Components:

[jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests

[ https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848254#comment-17848254 ] Greg Harris commented on KAFKA-16801: - I think the options are: # Prevent the 'test' task from

[jira] [Resolved] (KAFKA-16197) Connect Worker poll timeout prints Consumer poll timeout specific warnings.

[ https://issues.apache.org/jira/browse/KAFKA-16197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16197. - Fix Version/s: 3.8.0 Resolution: Fixed > Connect Worker poll timeout prints Consumer

[jira] [Commented] (KAFKA-15494) Remove deprecated calls in build.gradle for preparing future upgrades

[ https://issues.apache.org/jira/browse/KAFKA-15494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848008#comment-17848008 ] Greg Harris commented on KAFKA-15494: - [~bmscomp] Do you have any progress here? I subdivided this

[jira] [Updated] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests

[ https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16801: Labels: newbie (was: ) > Streams upgrade :test target doesn't find any junit tests >

[jira] [Updated] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports

[ https://issues.apache.org/jira/browse/KAFKA-16805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16805: Labels: newbie (was: ) > Stop using a ClosureBackedAction to configure Spotbugs reports >

[jira] [Updated] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil

[ https://issues.apache.org/jira/browse/KAFKA-16803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16803: Labels: newbie (was: ) > Upgrade to a version of ShadowJavaPlugin which doesn't use

[jira] [Created] (KAFKA-16806) Explicitly declare JUnit dependencies for all test modules

Greg Harris created KAFKA-16806: --- Summary: Explicitly declare JUnit dependencies for all test modules Key: KAFKA-16806 URL: https://issues.apache.org/jira/browse/KAFKA-16806 Project: Kafka

[jira] [Created] (KAFKA-16805) Stop using a ClosureBackedAction to configure Spotbugs reports

Greg Harris created KAFKA-16805: --- Summary: Stop using a ClosureBackedAction to configure Spotbugs reports Key: KAFKA-16805 URL: https://issues.apache.org/jira/browse/KAFKA-16805 Project: Kafka

[jira] [Updated] (KAFKA-16802) Move build.gradle java version information inside of a java block

[ https://issues.apache.org/jira/browse/KAFKA-16802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16802: Description: The org.gradle.api.plugins.JavaPluginConvention type has been deprecated.     This

[jira] [Updated] (KAFKA-16804) Replace gradle archivesBaseName with archivesName

[ https://issues.apache.org/jira/browse/KAFKA-16804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16804: Description: The BasePluginExtension.archivesBaseName property has been deprecated.     This is

[jira] [Updated] (KAFKA-16802) Move build.gradle java version information inside of a java block

[ https://issues.apache.org/jira/browse/KAFKA-16802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16802: Description: The org.gradle.api.plugins.JavaPluginConvention type has been deprecated.     This

[jira] [Created] (KAFKA-16804) Replace gradle archivesBaseName with archivesName

Greg Harris created KAFKA-16804: --- Summary: Replace gradle archivesBaseName with archivesName Key: KAFKA-16804 URL: https://issues.apache.org/jira/browse/KAFKA-16804 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16803) Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil

Greg Harris created KAFKA-16803: --- Summary: Upgrade to a version of ShadowJavaPlugin which doesn't use ConfigureUtil Key: KAFKA-16803 URL: https://issues.apache.org/jira/browse/KAFKA-16803 Project:

[jira] [Created] (KAFKA-16802) Move build.gradle java version information inside of a java block

Greg Harris created KAFKA-16802: --- Summary: Move build.gradle java version information inside of a java block Key: KAFKA-16802 URL: https://issues.apache.org/jira/browse/KAFKA-16802 Project: Kafka

[jira] [Created] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests

Greg Harris created KAFKA-16801: --- Summary: Streams upgrade :test target doesn't find any junit tests Key: KAFKA-16801 URL: https://issues.apache.org/jira/browse/KAFKA-16801 Project: Kafka

[jira] [Created] (KAFKA-16800) Resolve Gradle 9.0 deprecations

Greg Harris created KAFKA-16800: --- Summary: Resolve Gradle 9.0 deprecations Key: KAFKA-16800 URL: https://issues.apache.org/jira/browse/KAFKA-16800 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-16788) Resource leakage due to absence of close() call on connector start failure

[ https://issues.apache.org/jira/browse/KAFKA-16788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847383#comment-17847383 ] Greg Harris commented on KAFKA-16788: - Nice find [~ashok89]! Are you interested in working on a fix

[jira] [Updated] (KAFKA-16776) Builds flaky-failing with leaked client-metrics-reaper thread

[ https://issues.apache.org/jira/browse/KAFKA-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16776: Description: I observed the assertion added by KAFKA-16477 failing in my build:

[jira] [Created] (KAFKA-16776) Builds flaky-failing with leaked client-metrics-reaper thread

Greg Harris created KAFKA-16776: --- Summary: Builds flaky-failing with leaked client-metrics-reaper thread Key: KAFKA-16776 URL: https://issues.apache.org/jira/browse/KAFKA-16776 Project: Kafka

[jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition

[ https://issues.apache.org/jira/browse/KAFKA-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846684#comment-17846684 ] Greg Harris commented on KAFKA-16768: - [~muralibasani] Do you mean call Acceptor#close? That might

[jira] [Commented] (KAFKA-16765) NioEchoServer leaks accepted SocketChannel instances due to race condition

[ https://issues.apache.org/jira/browse/KAFKA-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846475#comment-17846475 ] Greg Harris commented on KAFKA-16765: - This is also a bug in EchoServer:

[jira] [Updated] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition

[ https://issues.apache.org/jira/browse/KAFKA-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16768: Description: The SocketServer has threads for Acceptors and Processors. These threads

[jira] [Created] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition

Greg Harris created KAFKA-16768: --- Summary: SocketServer leaks accepted SocketChannel instances due to race condition Key: KAFKA-16768 URL: https://issues.apache.org/jira/browse/KAFKA-16768 Project:

[jira] [Created] (KAFKA-16765) NioEchoServer leaks accepted SocketChannel instances due to race condition

Greg Harris created KAFKA-16765: --- Summary: NioEchoServer leaks accepted SocketChannel instances due to race condition Key: KAFKA-16765 URL: https://issues.apache.org/jira/browse/KAFKA-16765 Project:

[jira] [Created] (KAFKA-16739) Exclude protected variables from aggregated JavaDocs

Greg Harris created KAFKA-16739: --- Summary: Exclude protected variables from aggregated JavaDocs Key: KAFKA-16739 URL: https://issues.apache.org/jira/browse/KAFKA-16739 Project: Kafka Issue

[jira] [Created] (KAFKA-16703) SocketServer leaks ServerSocketChannel when port is already in-use

Greg Harris created KAFKA-16703: --- Summary: SocketServer leaks ServerSocketChannel when port is already in-use Key: KAFKA-16703 URL: https://issues.apache.org/jira/browse/KAFKA-16703 Project: Kafka

[jira] [Created] (KAFKA-16702) KafkaLog4jAppenderTest leaks producer instances

Greg Harris created KAFKA-16702: --- Summary: KafkaLog4jAppenderTest leaks producer instances Key: KAFKA-16702 URL: https://issues.apache.org/jira/browse/KAFKA-16702 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-15804) Broker leaks ServerSocketChannel when exception is thrown from ZkConfigManager during startup

[ https://issues.apache.org/jira/browse/KAFKA-15804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-15804: --- Fix Version/s: 3.8.0 Assignee: Greg Harris Resolution: Fixed > Broker

[jira] [Updated] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally

[ https://issues.apache.org/jira/browse/KAFKA-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16701: Description: These tests are failing for me on a local development environment, but don't appear

[jira] [Created] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally

Greg Harris created KAFKA-16701: --- Summary: Some SocketServerTest buffered close tests flaky failing locally Key: KAFKA-16701 URL: https://issues.apache.org/jira/browse/KAFKA-16701 Project: Kafka

[jira] [Resolved] (KAFKA-16356) Remove class-name dispatch in RemoteLogMetadataSerde

[ https://issues.apache.org/jira/browse/KAFKA-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16356. - Fix Version/s: 3.8.0 Resolution: Fixed > Remove class-name dispatch in

[jira] [Commented] (KAFKA-16643) Add ModifierOrder checkstyle rule

[ https://issues.apache.org/jira/browse/KAFKA-16643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842190#comment-17842190 ] Greg Harris commented on KAFKA-16643: - I think that might be a different checkstyle rule:

[jira] [Created] (KAFKA-16643) Add ModifierOrder checkstyle rule

Greg Harris created KAFKA-16643: --- Summary: Add ModifierOrder checkstyle rule Key: KAFKA-16643 URL: https://issues.apache.org/jira/browse/KAFKA-16643 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-15342) Considering upgrading to Mockito 5.4.1 or later

[ https://issues.apache.org/jira/browse/KAFKA-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842126#comment-17842126 ] Greg Harris commented on KAFKA-15342: - [~chia7712] I think there may be more value to the

[jira] [Commented] (KAFKA-15905) Restarts of MirrorCheckpointTask should not permanently interrupt offset translation

[ https://issues.apache.org/jira/browse/KAFKA-15905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842121#comment-17842121 ] Greg Harris commented on KAFKA-15905: - Rather than re-reading the checkpoints topic, we could add

[jira] [Commented] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once

[ https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842119#comment-17842119 ] Greg Harris commented on KAFKA-16622: - To clarify your specific points: > but the problem here is

[jira] [Commented] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once

[ https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842117#comment-17842117 ] Greg Harris commented on KAFKA-16622: - Yeah [~ecomar] from the final state of the OffsetSyncStore,

[jira] [Created] (KAFKA-16641) MM2 offset translation should interpolate between sparse OffsetSyncs

Greg Harris created KAFKA-16641: --- Summary: MM2 offset translation should interpolate between sparse OffsetSyncs Key: KAFKA-16641 URL: https://issues.apache.org/jira/browse/KAFKA-16641 Project: Kafka

[jira] [Commented] (KAFKA-16640) Replace TestUtils#resource by scala.util.Using

[ https://issues.apache.org/jira/browse/KAFKA-16640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842110#comment-17842110 ] Greg Harris commented on KAFKA-16640: - Okay, I understand now. SGTM! > Replace TestUtils#resource

[jira] [Commented] (KAFKA-16640) Replace TestUtils#resource by scala.util.Using

[ https://issues.apache.org/jira/browse/KAFKA-16640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842104#comment-17842104 ] Greg Harris commented on KAFKA-16640: - Hi [~chia7712] does this depend on

[jira] [Commented] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once

[ https://issues.apache.org/jira/browse/KAFKA-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841072#comment-17841072 ] Greg Harris commented on KAFKA-16622: - [~ecomar] Do you know if the MirrorCheckpointTask

[jira] [Commented] (KAFKA-16344) Internal topic mm2-offset-syncsinternal created with single partition is putting more load on the broker

[ https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832334#comment-17832334 ] Greg Harris commented on KAFKA-16344: - [~janardhanag] I don't understand what you mean. Can you be

[jira] [Commented] (KAFKA-16223) Replace EasyMock and PowerMock with Mockito for KafkaConfigBackingStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-16223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832325#comment-17832325 ] Greg Harris commented on KAFKA-16223: - PR 1/3 merged, leaving this open. > Replace EasyMock and

[jira] [Created] (KAFKA-16450) Add thread-safe alternative to Exit

Greg Harris created KAFKA-16450: --- Summary: Add thread-safe alternative to Exit Key: KAFKA-16450 URL: https://issues.apache.org/jira/browse/KAFKA-16450 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-16420) Refactor utils.Exit call-sites to use thread-safe alternative

[ https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16420: Summary: Refactor utils.Exit call-sites to use thread-safe alternative (was: Add thread-safe

[jira] [Updated] (KAFKA-16420) Refactor utils.Exit call-sites to use thread-safe alternative

[ https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16420: Description: The Exit class is not thread-safe, and exposes our tests to race conditions and

[jira] [Resolved] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

[ https://issues.apache.org/jira/browse/KAFKA-16349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16349. - Fix Version/s: 3.8.0 Assignee: Greg Harris Resolution: Fixed >

[jira] [Comment Edited] (KAFKA-16344) Internal topic mm2-offset-syncsinternal created with single partition is putting more load on the broker

[ https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830685#comment-17830685 ] Greg Harris edited comment on KAFKA-16344 at 3/25/24 8:06 PM: -- Hi

[jira] [Commented] (KAFKA-16344) Internal topic mm2-offset-syncsinternal created with single partition is putting more load on the broker

[ https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830685#comment-17830685 ] Greg Harris commented on KAFKA-16344: - Hi [~janardhanag] Yes, you should consider increasing

[jira] [Updated] (KAFKA-16420) Add thread-safe alternative to utils.Exit

[ https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16420: Summary: Add thread-safe alternative to utils.Exit (was: Replace utils.Exit with a thread-safe

[jira] [Commented] (KAFKA-16420) Replace utils.Exit with a thread-safe alternative

[ https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830603#comment-17830603 ] Greg Harris commented on KAFKA-16420: - I can't find a single ticket for "Remove Zookeeper", but I

[jira] [Created] (KAFKA-16421) Refactor CommandDefaultOptions subclasses to throw exceptions instead of calling exit.

Greg Harris created KAFKA-16421: --- Summary: Refactor CommandDefaultOptions subclasses to throw exceptions instead of calling exit. Key: KAFKA-16421 URL: https://issues.apache.org/jira/browse/KAFKA-16421

[jira] [Commented] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

[ https://issues.apache.org/jira/browse/KAFKA-16349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830590#comment-17830590 ] Greg Harris commented on KAFKA-16349: - I added a tactical fix for the Exit class in my PR to resolve

[jira] [Created] (KAFKA-16420) Replace utils.Exit with a thread-safe alternative

Greg Harris created KAFKA-16420: --- Summary: Replace utils.Exit with a thread-safe alternative Key: KAFKA-16420 URL: https://issues.apache.org/jira/browse/KAFKA-16420 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-16398) mirror-maker2 running into OOM while filtering (dropping) high number of messages

[ https://issues.apache.org/jira/browse/KAFKA-16398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830576#comment-17830576 ] Greg Harris commented on KAFKA-16398: - Hi [~srivignesh] Thank you for providing your configuration.

[jira] [Commented] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

[ https://issues.apache.org/jira/browse/KAFKA-16349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830010#comment-17830010 ] Greg Harris commented on KAFKA-16349: - I did some more exploration here. # Some of the "exit 1"

[jira] [Updated] (KAFKA-16409) kafka-delete-records / DeleteRecordsCommand should use standard exception handling

[ https://issues.apache.org/jira/browse/KAFKA-16409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16409: Component/s: tools > kafka-delete-records / DeleteRecordsCommand should use standard exception >

[jira] [Created] (KAFKA-16410) kafka-leader-election / LeaderElectionCommand doesn't set exit code on error

Greg Harris created KAFKA-16410: --- Summary: kafka-leader-election / LeaderElectionCommand doesn't set exit code on error Key: KAFKA-16410 URL: https://issues.apache.org/jira/browse/KAFKA-16410 Project:

[jira] [Updated] (KAFKA-16409) kafka-delete-records / DeleteRecordsCommand should use standard exception handling

[ https://issues.apache.org/jira/browse/KAFKA-16409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16409: Labels: newbie (was: ) > kafka-delete-records / DeleteRecordsCommand should use standard

[jira] [Created] (KAFKA-16409) kafka-delete-records / DeleteRecordsCommand should use standard exception handling

Greg Harris created KAFKA-16409: --- Summary: kafka-delete-records / DeleteRecordsCommand should use standard exception handling Key: KAFKA-16409 URL: https://issues.apache.org/jira/browse/KAFKA-16409

[jira] [Updated] (KAFKA-16408) kafka-get-offsets / GetOffsetShell doesn't handle --version or --help

[ https://issues.apache.org/jira/browse/KAFKA-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16408: Description: The kafka-get-offsets script was moved to Java for the 3.7.0 release. It now

[jira] [Updated] (KAFKA-16408) kafka-get-offsets / GetOffsetShell doesn't handle --version or --help

[ https://issues.apache.org/jira/browse/KAFKA-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16408: Description: The kafka-get-offsets script was moved to Java for the 3.7.0 release. It now

[jira] [Created] (KAFKA-16408) kafka-get-offsets / GetOffsetShell doesn't handle --version or --help

Greg Harris created KAFKA-16408: --- Summary: kafka-get-offsets / GetOffsetShell doesn't handle --version or --help Key: KAFKA-16408 URL: https://issues.apache.org/jira/browse/KAFKA-16408 Project: Kafka

[jira] [Commented] (KAFKA-16354) FinalizedFeatureChangeListenerTest should use mocked latches

[ https://issues.apache.org/jira/browse/KAFKA-16354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829950#comment-17829950 ] Greg Harris commented on KAFKA-16354: - Hi [~yangpoan] Thank you for looking into it more, it sounds

[jira] [Resolved] (KAFKA-16354) FinalizedFeatureChangeListenerTest should use mocked latches

[ https://issues.apache.org/jira/browse/KAFKA-16354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16354. - Resolution: Won't Fix > FinalizedFeatureChangeListenerTest should use mocked latches >

[jira] [Commented] (KAFKA-16398) mirror-maker2 running into OOM while filtering (dropping) high number of messages

[ https://issues.apache.org/jira/browse/KAFKA-16398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829913#comment-17829913 ] Greg Harris commented on KAFKA-16398: - Hi [~srivignesh] I'm sorry you're having difficulties with

[jira] [Updated] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

[ https://issues.apache.org/jira/browse/KAFKA-16349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16349: Description: `ShutdownableThread` calls `Exit.exit()` when the thread's operation throws

[jira] [Commented] (KAFKA-16291) Mirrormaker2 wrong checkpoints

[ https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825467#comment-17825467 ] Greg Harris commented on KAFKA-16291: - [~claudio.benfatto] That's a good idea, I agree that the

[jira] [Created] (KAFKA-16364) MM2 High-Resolution Offset Translation

Greg Harris created KAFKA-16364: --- Summary: MM2 High-Resolution Offset Translation Key: KAFKA-16364 URL: https://issues.apache.org/jira/browse/KAFKA-16364 Project: Kafka Issue Type: New Feature

[jira] [Comment Edited] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825454#comment-17825454 ] Greg Harris edited comment on KAFKA-15841 at 3/11/24 9:46 PM: --

[jira] [Commented] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825454#comment-17825454 ] Greg Harris commented on KAFKA-15841: - [~henriquemota] Okay I think i understand better what you're

[jira] [Commented] (KAFKA-16356) Remove class-name dispatch in RemoteLogMetadataSerde

[ https://issues.apache.org/jira/browse/KAFKA-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825439#comment-17825439 ] Greg Harris commented on KAFKA-16356: - [~linu] I have given you permissions to assign tickets. You

[jira] [Commented] (KAFKA-16362) Fix type-unsafety in KStreamKStreamJoin caused by isLeftSide

[ https://issues.apache.org/jira/browse/KAFKA-16362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825397#comment-17825397 ] Greg Harris commented on KAFKA-16362: - cc [~mjsax] [~ableegoldman] I looked through the (currently

[jira] [Created] (KAFKA-16362) Fix type-unsafety in KStreamKStreamJoin caused by isLeftSide

Greg Harris created KAFKA-16362: --- Summary: Fix type-unsafety in KStreamKStreamJoin caused by isLeftSide Key: KAFKA-16362 URL: https://issues.apache.org/jira/browse/KAFKA-16362 Project: Kafka

[jira] [Commented] (KAFKA-16360) Release plan of 3.x kafka releases.

[ https://issues.apache.org/jira/browse/KAFKA-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825385#comment-17825385 ] Greg Harris commented on KAFKA-16360: - Hi [~kaushik srinivas], thanks for your question! The

[jira] [Created] (KAFKA-16356) Remove class-name dispatch in RemoteLogMetadataSerde

Greg Harris created KAFKA-16356: --- Summary: Remove class-name dispatch in RemoteLogMetadataSerde Key: KAFKA-16356 URL: https://issues.apache.org/jira/browse/KAFKA-16356 Project: Kafka Issue

[jira] [Created] (KAFKA-16354) FinalizedFeatureChangeListenerTest should use mocked latches

Greg Harris created KAFKA-16354: --- Summary: FinalizedFeatureChangeListenerTest should use mocked latches Key: KAFKA-16354 URL: https://issues.apache.org/jira/browse/KAFKA-16354 Project: Kafka

[jira] [Created] (KAFKA-16349) ShutdownableThread fails build by calling Exit with race condition

Greg Harris created KAFKA-16349: --- Summary: ShutdownableThread fails build by calling Exit with race condition Key: KAFKA-16349 URL: https://issues.apache.org/jira/browse/KAFKA-16349 Project: Kafka

[jira] [Resolved] (KAFKA-16288) Values.convertToDecimal throws ClassCastExceptions on String inputs

[ https://issues.apache.org/jira/browse/KAFKA-16288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16288. - Fix Version/s: 3.8.0 Resolution: Fixed > Values.convertToDecimal throws

[jira] [Commented] (KAFKA-16344) Internal topic mm2-offset-syncsinternal created with single partition is putting more load on the broker

[ https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823817#comment-17823817 ] Greg Harris commented on KAFKA-16344: - Hi [~janardhanag], thanks for the ticket. At the current

[jira] [Commented] (KAFKA-10582) Mirror Maker 2 not replicating new topics until restart

[ https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823303#comment-17823303 ] Greg Harris commented on KAFKA-10582: - Hi [~frankgrimes97] Thanks for finding this ticket. I think

[jira] [Resolved] (KAFKA-10582) Mirror Maker 2 not replicating new topics until restart

[ https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10582. - Fix Version/s: 3.5.0 Resolution: Fixed > Mirror Maker 2 not replicating new topics until

[jira] [Updated] (KAFKA-16326) Kafka Connect unable to find javax dependency on Quarkus update to 3.X

[ https://issues.apache.org/jira/browse/KAFKA-16326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16326: Fix Version/s: 4.0.0 > Kafka Connect unable to find javax dependency on Quarkus update to 3.X >

[jira] [Commented] (KAFKA-16326) Kafka Connect unable to find javax dependency on Quarkus update to 3.X

[ https://issues.apache.org/jira/browse/KAFKA-16326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823300#comment-17823300 ] Greg Harris commented on KAFKA-16326: - Hi [~pauortegatw] ! It looks like this will require Kafka to

[jira] [Created] (KAFKA-16303) Add upgrade notes about recent MM2 offset translation changes

Greg Harris created KAFKA-16303: --- Summary: Add upgrade notes about recent MM2 offset translation changes Key: KAFKA-16303 URL: https://issues.apache.org/jira/browse/KAFKA-16303 Project: Kafka

[jira] [Updated] (KAFKA-15202) MM2 OffsetSyncStore clears too many syncs when sync spacing is variable

[ https://issues.apache.org/jira/browse/KAFKA-15202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15202: Fix Version/s: 3.6.0 > MM2 OffsetSyncStore clears too many syncs when sync spacing is variable >

[jira] [Comment Edited] (KAFKA-16291) Mirrormaker2 wrong checkpoints

[ https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819368#comment-17819368 ] Greg Harris edited comment on KAFKA-16291 at 2/21/24 7:01 PM: -- Hi

[jira] [Commented] (KAFKA-16291) Mirrormaker2 wrong checkpoints

[ https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819368#comment-17819368 ] Greg Harris commented on KAFKA-16291: - Hi [~claudio.benfatto] Thanks for the bug report and the very

[jira] [Resolved] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-6675. Fix Version/s: 3.6.0 Assignee: Greg Harris (was: Valeria Vasylieva) Resolution:

[jira] [Created] (KAFKA-16289) Values.parseString on heterogeneous lists and maps sometimes corrupts data by inferring incorrect schema

Greg Harris created KAFKA-16289: --- Summary: Values.parseString on heterogeneous lists and maps sometimes corrupts data by inferring incorrect schema Key: KAFKA-16289 URL:

[jira] [Created] (KAFKA-16288) Values.convertToDecimal throws ClassCastExceptions on String inputs

Greg Harris created KAFKA-16288: --- Summary: Values.convertToDecimal throws ClassCastExceptions on String inputs Key: KAFKA-16288 URL: https://issues.apache.org/jira/browse/KAFKA-16288 Project: Kafka

[jira] [Commented] (KAFKA-15333) Flaky build failure throwing Connect Exception: Could not connect to server....

[ https://issues.apache.org/jira/browse/KAFKA-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17817529#comment-17817529 ] Greg Harris commented on KAFKA-15333: - Caused by this Gradle bug:

[jira] [Resolved] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account

[ https://issues.apache.org/jira/browse/KAFKA-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15407. - Resolution: Invalid > Not able to connect to kafka from the Private NLB from outside the VPC >

  1   2   3   4   5   6   >