[jira] [Commented] (KAFKA-17484) Logs are deleted in Kafka 1.1.1 if logs.segment.bytes is changed

2024-09-04 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879394#comment-17879394 ] Greg Harris commented on KAFKA-17484: - Hi [~georgios] Thanks for the ticket! Are yo

[jira] [Commented] (KAFKA-17424) Memory optimisation for Kafka-connect

2024-08-28 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877474#comment-17877474 ] Greg Harris commented on KAFKA-17424: - [~ajit97] An OOME stack trace isn't really su

[jira] [Commented] (KAFKA-17424) Memory optimisation for Kafka-connect

2024-08-26 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876766#comment-17876766 ] Greg Harris commented on KAFKA-17424: - Hi [~ajit97] Thanks for the ticket! Can you

[jira] [Commented] (KAFKA-17053) Restructure build.gradle to configure publishing last

2024-08-23 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876357#comment-17876357 ] Greg Harris commented on KAFKA-17053: - I copied my original upstream bug report to t

[jira] [Resolved] (KAFKA-12818) Memory leakage when kafka connect 2.7 uses directory config provider

2024-08-23 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-12818. - Resolution: Duplicate > Memory leakage when kafka connect 2.7 uses directory config provider > -

[jira] [Commented] (KAFKA-12818) Memory leakage when kafka connect 2.7 uses directory config provider

2024-08-23 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876353#comment-17876353 ] Greg Harris commented on KAFKA-12818: - Thanks [~dnk] for finding the duplicate! > M

[jira] [Resolved] (KAFKA-17369) Remove org.reflections from logging and licenses

2024-08-19 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17369. - Fix Version/s: 4.0.0 Resolution: Fixed > Remove org.reflections from logging and licenses

[jira] [Created] (KAFKA-17369) Remove org.reflections from logging and licenses

2024-08-19 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17369: --- Summary: Remove org.reflections from logging and licenses Key: KAFKA-17369 URL: https://issues.apache.org/jira/browse/KAFKA-17369 Project: Kafka Issue Type: Ta

[jira] [Resolved] (KAFKA-15203) Remove dependency on Reflections

2024-08-19 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15203. - Fix Version/s: 4.0.0 (was: 5.0.0) Assignee: (was: Ganesh Sada

[jira] [Commented] (KAFKA-17270) Let test code use Exit.java rather than Exit.scala

2024-08-06 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871405#comment-17871405 ] Greg Harris commented on KAFKA-17270: - Eliminating the scala form would also make it

[jira] [Commented] (KAFKA-17270) the input function of Exit#setHaltProcedure/Exit#setExitProcedure should return `Unit` rather than `Nothing`

2024-08-06 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871394#comment-17871394 ] Greg Harris commented on KAFKA-17270: - Also, if you're only changing the setExitProc

[jira] [Commented] (KAFKA-17270) the input function of Exit#setHaltProcedure/Exit#setExitProcedure should return `Unit` rather than `Nothing`

2024-08-06 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871392#comment-17871392 ] Greg Harris commented on KAFKA-17270: - Nothing is the scala bottom type (a type whic

[jira] [Created] (KAFKA-17242) MirrorCheckpointTask prints spurious timeout for starting checkpoint and offset sync stores

2024-08-01 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17242: --- Summary: MirrorCheckpointTask prints spurious timeout for starting checkpoint and offset sync stores Key: KAFKA-17242 URL: https://issues.apache.org/jira/browse/KAFKA-17242

[jira] [Commented] (KAFKA-17232) MirrorCheckpointConnector does not generate task configs if initial consumer group load times out

2024-07-31 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870057#comment-17870057 ] Greg Harris commented on KAFKA-17232: - Thanks [~frankvicky] for volunteering. Some t

[jira] [Assigned] (KAFKA-17232) MirrorCheckpointConnector does not generate task configs if initial consumer group load times out

2024-07-31 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17232: --- Assignee: TengYao Chi > MirrorCheckpointConnector does not generate task configs if initial

[jira] [Updated] (KAFKA-17233) MirrorCheckpointConnector should use batched listConsumerGroupOffsets

2024-07-31 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17233: Affects Version/s: 3.5.0 (was: 3.9.0) > MirrorCheckpointConnector shoul

[jira] [Created] (KAFKA-17233) MirrorCheckpointConnector should use batched listConsumerGroupOffsets

2024-07-31 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17233: --- Summary: MirrorCheckpointConnector should use batched listConsumerGroupOffsets Key: KAFKA-17233 URL: https://issues.apache.org/jira/browse/KAFKA-17233 Project: Kafka

[jira] [Commented] (KAFKA-17232) MirrorCheckpointConnector does not generate task configs if initial consumer group load times out

2024-07-31 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870028#comment-17870028 ] Greg Harris commented on KAFKA-17232: - loadInitialConsumerGroups may have gotten a l

[jira] [Created] (KAFKA-17232) MirrorCheckpointConnector does not generate task configs if initial consumer group load times out

2024-07-31 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17232: --- Summary: MirrorCheckpointConnector does not generate task configs if initial consumer group load times out Key: KAFKA-17232 URL: https://issues.apache.org/jira/browse/KAFKA-17232

[jira] [Created] (KAFKA-17220) Define new metrics for MirrorMaker2

2024-07-30 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17220: --- Summary: Define new metrics for MirrorMaker2 Key: KAFKA-17220 URL: https://issues.apache.org/jira/browse/KAFKA-17220 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-29 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869468#comment-17869468 ] Greg Harris commented on KAFKA-17186: - I don't think i've ever thought about it like

[jira] [Updated] (KAFKA-17202) EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers

2024-07-26 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17202: Priority: Minor (was: Major) > EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpoint

[jira] [Updated] (KAFKA-17207) ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients

2024-07-26 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17207: Affects Version/s: 3.9.0 > ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), l

[jira] [Created] (KAFKA-17207) ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients

2024-07-26 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17207: --- Summary: ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients Key: KAFKA-17207 URL: https://issues.apache.org/jira/browse/KAFKA-17207 P

[jira] [Commented] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-26 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868989#comment-17868989 ] Greg Harris commented on KAFKA-17186: - I think you want `.scheduled.rebalance.max.de

[jira] [Commented] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

2024-07-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868819#comment-17868819 ] Greg Harris commented on KAFKA-17204: - Hi [~frankvicky] I assigned the issue to you,

[jira] [Assigned] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

2024-07-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17204: --- Assignee: TengYao Chi > KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient >

[jira] [Created] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

2024-07-25 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17204: --- Summary: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient Key: KAFKA-17204 URL: https://issues.apache.org/jira/browse/KAFKA-17204 Project: Kafka

[jira] [Created] (KAFKA-17203) StreamThread leaking producer instances

2024-07-25 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17203: --- Summary: StreamThread leaking producer instances Key: KAFKA-17203 URL: https://issues.apache.org/jira/browse/KAFKA-17203 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-17202) EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers

2024-07-25 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17202: --- Summary: EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers Key: KAFKA-17202 URL: https://issues.apache.org/jira/browse/KAFKA-17202

[jira] [Created] (KAFKA-17201) SelectorTest.testInboundConnectionsCountInConnectionCreationMetric leaks sockets and threads

2024-07-25 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17201: --- Summary: SelectorTest.testInboundConnectionsCountInConnectionCreationMetric leaks sockets and threads Key: KAFKA-17201 URL: https://issues.apache.org/jira/browse/KAFKA-17201

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

2024-07-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868797#comment-17868797 ] Greg Harris commented on KAFKA-16701: - [~bboyleonp] Thanks for looking into this mor

[jira] [Commented] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868750#comment-17868750 ] Greg Harris commented on KAFKA-17186: - > Does this imply that I should introduce mul

[jira] [Created] (KAFKA-17195) transaction-coordinator:test failing with junit error

2024-07-24 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17195: --- Summary: transaction-coordinator:test failing with junit error Key: KAFKA-17195 URL: https://issues.apache.org/jira/browse/KAFKA-17195 Project: Kafka Issue Typ

[jira] [Comment Edited] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-24 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868422#comment-17868422 ] Greg Harris edited comment on KAFKA-17186 at 7/24/24 4:27 PM:

[jira] [Commented] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-24 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868422#comment-17868422 ] Greg Harris commented on KAFKA-17186: - [~yitian998] Relevant logs are here:   {nofo

[jira] [Commented] (KAFKA-17192) MirrorMaker2 worker config does not pass config.providers value to connectors

2024-07-24 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868415#comment-17868415 ] Greg Harris commented on KAFKA-17192: - Hi [~k0b3rit] thanks for the bug report! The

[jira] [Commented] (KAFKA-17189) Add Thread::isAlive to DetectThreadLeak#of filter

2024-07-23 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868117#comment-17868117 ] Greg Harris commented on KAFKA-17189: - [https://docs.oracle.com/javase/7/docs/api/ja

[jira] [Commented] (KAFKA-17186) Cannot receive message after stopping Source Mirror Maker 2

2024-07-23 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868108#comment-17868108 ] Greg Harris commented on KAFKA-17186: - Hi [~yitian998] thanks for the bug report. A

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

2024-07-22 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867834#comment-17867834 ] Greg Harris commented on KAFKA-16701: - Hi [~bboyleonp] Yes, please assign this to yo

[jira] [Updated] (KAFKA-17148) Kafka storage tool prints MetaPropertiesEnsemble

2024-07-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17148: Fix Version/s: 3.7.2 3.8.0 > Kafka storage tool prints MetaPropertiesEnsemble >

[jira] [Resolved] (KAFKA-17150) Connect converter validation does not accept class aliases

2024-07-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17150. - Assignee: Greg Harris Resolution: Fixed > Connect converter validation does not accept cla

[jira] [Created] (KAFKA-17157) Refactor mutability and state transitions in DistributedHerder

2024-07-17 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17157: --- Summary: Refactor mutability and state transitions in DistributedHerder Key: KAFKA-17157 URL: https://issues.apache.org/jira/browse/KAFKA-17157 Project: Kafka

[jira] [Commented] (KAFKA-17150) Connect converter validation does not accept class aliases

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866541#comment-17866541 ] Greg Harris commented on KAFKA-17150: - The difference seems to be caused by the diff

[jira] [Updated] (KAFKA-17150) Connect converter validation does not accept class aliases

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17150: Description: Connect allows users to specify aliases instead of full classes when configuring plu

[jira] [Updated] (KAFKA-17150) Connect converter validation does not accept class aliases

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17150: Description: Connect allows users to specify aliases instead of full classes when configuring plu

[jira] [Created] (KAFKA-17150) Connect converter validation does not accept class aliases

2024-07-16 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17150: --- Summary: Connect converter validation does not accept class aliases Key: KAFKA-17150 URL: https://issues.apache.org/jira/browse/KAFKA-17150 Project: Kafka Issu

[jira] [Updated] (KAFKA-17148) Kafka storage tool prints MetaPropertiesEnsemble

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17148: Description: Using this following command on the 3.6 branch yields this result: {noformat} $ bin/k

[jira] [Updated] (KAFKA-17148) Kafka storage tool prints MetaPropertiesEnsemble

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17148: Affects Version/s: 3.7.1 3.7.0 3.8.0 > Kafka storage

[jira] [Commented] (KAFKA-17148) Kafka storage tool prints MetaPropertiesEnsemble

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866512#comment-17866512 ] Greg Harris commented on KAFKA-17148: - I verified that this is introduced by [https

[jira] [Updated] (KAFKA-17148) Kafka storage tool prints MetaPropertiesEnsemble

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17148: Summary: Kafka storage tool prints MetaPropertiesEnsemble (was: Kafka storage tool prints Metadat

[jira] [Created] (KAFKA-17148) Kafka storage tool prints MetadataPropertiesEnsemble

2024-07-16 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17148: --- Summary: Kafka storage tool prints MetadataPropertiesEnsemble Key: KAFKA-17148 URL: https://issues.apache.org/jira/browse/KAFKA-17148 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-17145) Reinstate Utils.join() method in org.apache.kafka.common.utils

2024-07-16 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866436#comment-17866436 ] Greg Harris commented on KAFKA-17145: - The containing package is not part of the pub

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164 ] Greg Harris commented on KAFKA-16937: - I thought about this some more. Right now the

[jira] [Comment Edited] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164 ] Greg Harris edited comment on KAFKA-16937 at 7/11/24 5:15 PM:

[jira] [Commented] (KAFKA-17101) Mirror maker internal topics cleanup policy changes to 'delete' from 'compact'

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865138#comment-17865138 ] Greg Harris commented on KAFKA-17101: - Also you mentioned MM1, is that a typo or are

[jira] [Commented] (KAFKA-17101) Mirror maker internal topics cleanup policy changes to 'delete' from 'compact'

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865137#comment-17865137 ] Greg Harris commented on KAFKA-17101: - [~kaushik srinivas] Unfortunately I don't see

[jira] [Comment Edited] (KAFKA-17101) Mirror maker internal topics cleanup policy changes to 'delete' from 'compact'

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864935#comment-17864935 ] Greg Harris edited comment on KAFKA-17101 at 7/11/24 3:40 PM:

[jira] [Commented] (KAFKA-17117) Avoid instantiating classpath plugins when service loading plugins

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865134#comment-17865134 ] Greg Harris commented on KAFKA-17117: - Considering that the only plugins typically o

[jira] [Resolved] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17111. - Resolution: Fixed > ServiceConfigurationError in JsonSerializer/Deserializer during Plugin > Di

[jira] [Resolved] (KAFKA-17119) After enabled kafka-ranger-plugin and baned the user for using describe in policy, but that user still can use describe.

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-17119. - Resolution: Cannot Reproduce > After enabled kafka-ranger-plugin and baned the user for using de

[jira] [Commented] (KAFKA-17119) After enabled kafka-ranger-plugin and baned the user for using describe in policy, but that user still can use describe.

2024-07-11 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865131#comment-17865131 ] Greg Harris commented on KAFKA-17119: - Hi [~StarBoy1005] The Apache Kafka project do

[jira] [Created] (KAFKA-17117) Avoid instantiating classpath plugins when service loading plugins

2024-07-10 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17117: --- Summary: Avoid instantiating classpath plugins when service loading plugins Key: KAFKA-17117 URL: https://issues.apache.org/jira/browse/KAFKA-17117 Project: Kafka

[jira] [Updated] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17111: Priority: Blocker (was: Major) > ServiceConfigurationError in JsonSerializer/Deserializer during

[jira] [Assigned] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17111: --- Assignee: Vikas Balani (was: Greg Harris) > ServiceConfigurationError in JsonSerializer/De

[jira] [Commented] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864804#comment-17864804 ] Greg Harris commented on KAFKA-17111: - Hi [~vbalani] Thank you for the bug report! I

[jira] [Assigned] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17111: --- Assignee: Greg Harris (was: Vikas Balani) > ServiceConfigurationError in JsonSerializer/De

[jira] [Updated] (KAFKA-17111) ServiceConfigurationError in JsonSerializer/Deserializer during Plugin Discovery

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17111: Description: h3. Problem: JsonSerializer and JsonDeserializer use objectMapper.findAndRegisterMod

[jira] [Commented] (KAFKA-17097) Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040)

2024-07-10 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864782#comment-17864782 ] Greg Harris commented on KAFKA-17097: - [~mimaison] Sorry, I was the one to close the

[jira] [Commented] (KAFKA-17103) MockClient tight loops when no metadata is present in KafkaProducerTest

2024-07-09 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864380#comment-17864380 ] Greg Harris commented on KAFKA-17103: - Also it's possible that there's an existing m

[jira] [Created] (KAFKA-17103) MockClient tight loops when no metadata is present in KafkaProducerTest

2024-07-09 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17103: --- Summary: MockClient tight loops when no metadata is present in KafkaProducerTest Key: KAFKA-17103 URL: https://issues.apache.org/jira/browse/KAFKA-17103 Project: Kafka

[jira] [Commented] (KAFKA-17101) Mirror maker internal topics cleanup policy changes to 'delete' from 'compact'

2024-07-09 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864259#comment-17864259 ] Greg Harris commented on KAFKA-17101: - [~kaushik srinivas] Do you have a custom topi

[jira] [Updated] (KAFKA-17100) GlobalStreamThread#start should not busy-wait

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17100: Labels: newbie (was: ) > GlobalStreamThread#start should not busy-wait >

[jira] [Created] (KAFKA-17100) GlobalStreamThread#start should not busy-wait

2024-07-08 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17100: --- Summary: GlobalStreamThread#start should not busy-wait Key: KAFKA-17100 URL: https://issues.apache.org/jira/browse/KAFKA-17100 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-17095) Fix the typo: CreateableTopicConfig -> CreatableTopicConfig

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863953#comment-17863953 ] Greg Harris commented on KAFKA-17095: - > I believe the renaming should not break it.

[jira] [Updated] (KAFKA-17097) Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040)

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17097: Description: {color:#172b4d}See [https://cwiki.apache.org/confluence/pages/viewpage.action?pageId

[jira] [Updated] (KAFKA-17097) Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040)

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17097: Labels: newbie (was: ) > Add replace.null.with.default configuration to ValueToKey and ReplaceFie

[jira] [Created] (KAFKA-17097) Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040)

2024-07-08 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17097: --- Summary: Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040) Key: KAFKA-17097 URL: https://issues.apache.org/jira/browse/KAFKA-17097 P

[jira] [Resolved] (KAFKA-15838) [Connect] ExtractField and InsertField NULL Values are replaced by default value even in NULLABLE fields

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15838. - Fix Version/s: 3.9.0 Resolution: Fixed The InsertField, ExtractField, HeaderFrom, Cast, S

[jira] [Commented] (KAFKA-17095) Fix the typo: CreateableTopicConfig -> CreatableTopicConfig

2024-07-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863890#comment-17863890 ] Greg Harris commented on KAFKA-17095: - Is this a backwards compatible change? If som

[jira] [Commented] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2024-07-05 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863422#comment-17863422 ] Greg Harris commented on KAFKA-10370: - Another option is to try and pull the excepti

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

2024-07-05 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-16801: --- Assignee: Evgeny Ushakov > Streams upgrade :test target doesn't find any junit tests >

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

2024-07-05 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863396#comment-17863396 ] Greg Harris commented on KAFKA-16801: - Hi [~eugene.u] Thanks for volunteering. I've

[jira] [Commented] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2024-07-03 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862891#comment-17862891 ] Greg Harris commented on KAFKA-10370: - I'm reopening this issue as we have a fresh b

[jira] [Reopened] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

2024-07-03 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reopened KAFKA-10370: - Assignee: (was: Ning Zhang) > WorkerSinkTask: IllegalStateException cased by consumer.seek

[jira] [Created] (KAFKA-17078) Add SecurityManager reflective shim

2024-07-03 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17078: --- Summary: Add SecurityManager reflective shim Key: KAFKA-17078 URL: https://issues.apache.org/jira/browse/KAFKA-17078 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-17053) Restructure build.gradle to configure publishing last

2024-06-28 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17053: Description: Recently we had to downgrade the ShadowJavaPlugin because it produces incorrect resu

[jira] [Created] (KAFKA-17053) Restructure build.gradle to configure publishing last

2024-06-28 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17053: --- Summary: Restructure build.gradle to configure publishing last Key: KAFKA-17053 URL: https://issues.apache.org/jira/browse/KAFKA-17053 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-17052) Downgrade ShadowJavaPlugin to 8.1.3 to avoid publishing classifier bug

2024-06-28 Thread Greg Harris (Jira)
Greg Harris created KAFKA-17052: --- Summary: Downgrade ShadowJavaPlugin to 8.1.3 to avoid publishing classifier bug Key: KAFKA-17052 URL: https://issues.apache.org/jira/browse/KAFKA-17052 Project: Kafka

[jira] [Updated] (KAFKA-17049) Incremental rebalances assign too many tasks for the same connector together

2024-06-27 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17049: Summary: Incremental rebalances assign too many tasks for the same connector together (was: unbal

[jira] [Assigned] (KAFKA-17049) unbalanced connectors

2024-06-27 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17049: --- Assignee: (was: Greg Harris) > unbalanced connectors > - > >

[jira] [Assigned] (KAFKA-17049) unbalanced connectors

2024-06-27 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-17049: --- Assignee: Greg Harris > unbalanced connectors > - > > K

[jira] [Commented] (KAFKA-17049) unbalanced connectors

2024-06-27 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860586#comment-17860586 ] Greg Harris commented on KAFKA-17049: - Thank you for providing a detailed reproducti

[jira] [Updated] (KAFKA-16072) Create Junit 5 extension to detect thread leak

2024-06-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16072: Fix Version/s: (was: 3.9.0) > Create Junit 5 extension to detect thread leak > ---

[jira] [Commented] (KAFKA-17025) KafkaThread and KafkaProducer expose method to set setUncaughtExceptionHandler

2024-06-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859995#comment-17859995 ] Greg Harris commented on KAFKA-17025: - [~loserwang1024] I added you as a contributor

[jira] [Updated] (KAFKA-17025) KafkaThread and KafkaProducer expose method to set setUncaughtExceptionHandler

2024-06-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-17025: Fix Version/s: (was: 3.6.3) > KafkaThread and KafkaProducer expose method to set setUncaughtEx

[jira] [Commented] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client in order to defined ACL with a notion of group

2024-06-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859992#comment-17859992 ] Greg Harris commented on KAFKA-16707: - Hi [~handfreezer] Thank you for clarifying th

[jira] [Commented] (KAFKA-10413) rebalancing leads to unevenly balanced connectors

2024-06-25 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859957#comment-17859957 ] Greg Harris commented on KAFKA-10413: - Hi [~yazgoo] Could you provide some more deta

[jira] [Commented] (KAFKA-17025) KafkaThread and KafkaProducer expose method to set setUncaughtExceptionHandler

2024-06-24 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859793#comment-17859793 ] Greg Harris commented on KAFKA-17025: - I don't think that it is appropriate for the

[jira] [Commented] (KAFKA-17001) Consider using another class to replace `AbstractConfig` to be class which always returns the up-to-date configs

2024-06-24 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859766#comment-17859766 ] Greg Harris commented on KAFKA-17001: - [~chia7712] That sounds reasonable. The Suppl

  1   2   3   4   5   6   7   >