[jira] [Assigned] (KAFKA-6586) Refactor Connect executables

2022-12-03 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-6586: - Assignee: Yash Mayya > Refactor Connect executables > > >

[jira] [Created] (KAFKA-14455) Kafka Connect create and update REST APIs should surface failures while writing to the config topic

2022-12-08 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14455: -- Summary: Kafka Connect create and update REST APIs should surface failures while writing to the config topic Key: KAFKA-14455 URL: https://issues.apache.org/jira/browse/KAFKA-14455

[jira] [Created] (KAFKA-14569) Migrate EmbeddedKafkaCluster used by Connect integration tests from EmbeddedZookeeper to KRaft

2023-01-04 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14569: -- Summary: Migrate EmbeddedKafkaCluster used by Connect integration tests from EmbeddedZookeeper to KRaft Key: KAFKA-14569 URL: https://issues.apache.org/jira/browse/KAFKA-14569

[jira] [Updated] (KAFKA-14569) Migrate EmbeddedKafkaCluster used by Connect integration tests from EmbeddedZookeeper to KRaft

2023-01-04 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14569: --- Description: ZooKeeper mode is going to be deprecated in Apache Kafka 4.0. Connect currently uses a

[jira] [Created] (KAFKA-14134) Replace EasyMock with Mockito for WorkerConnectorTest

2022-08-02 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14134: -- Summary: Replace EasyMock with Mockito for WorkerConnectorTest Key: KAFKA-14134 URL: https://issues.apache.org/jira/browse/KAFKA-14134 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-14133) Remaining EasyMock to Mockito tests

2022-08-03 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574561#comment-17574561 ] Yash Mayya commented on KAFKA-14133: Hi [~christo_lolov], are you planning to work o

[jira] [Commented] (KAFKA-13952) Infinite retry timeout is not working

2022-08-03 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574748#comment-17574748 ] Yash Mayya commented on KAFKA-13952: [~jmalek] this definitely looks like a bug in t

[jira] [Updated] (KAFKA-14147) Some map objects in KafkaConfigBackingStore grow in size monotonically

2022-08-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14147: --- Description: Similar to https://issues.apache.org/jira/browse/KAFKA-8869   {{deferredTaskUpdates,

[jira] [Created] (KAFKA-14147) Some map objects in KafkaConfigBackingStore grow in size monotonically

2022-08-08 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14147: -- Summary: Some map objects in KafkaConfigBackingStore grow in size monotonically Key: KAFKA-14147 URL: https://issues.apache.org/jira/browse/KAFKA-14147 Project: Kafka

[jira] (KAFKA-14147) Some map objects in KafkaConfigBackingStore grow in size monotonically

2022-08-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14147 ] Yash Mayya deleted comment on KAFKA-14147: was (Author: yash.mayya): https://github.com/apache/kafka/pull/12490 > Some map objects in KafkaConfigBackingStore grow in size monotonically > ---

[jira] [Created] (KAFKA-14162) HoistField SMT should not return an immutable map for schemaless key/value

2022-08-11 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14162: -- Summary: HoistField SMT should not return an immutable map for schemaless key/value Key: KAFKA-14162 URL: https://issues.apache.org/jira/browse/KAFKA-14162 Project: Kafka

[jira] [Assigned] (KAFKA-14162) HoistField SMT should not return an immutable map for schemaless key/value

2022-08-11 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14162: -- Assignee: Yash Mayya > HoistField SMT should not return an immutable map for schemaless key/v

[jira] [Assigned] (KAFKA-14147) Some map objects in KafkaConfigBackingStore grow in size monotonically

2022-08-11 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14147: -- Assignee: Yash Mayya > Some map objects in KafkaConfigBackingStore grow in size monotonically

[jira] [Assigned] (KAFKA-14134) Replace EasyMock with Mockito for WorkerConnectorTest

2022-08-11 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14134: -- Assignee: Yash Mayya > Replace EasyMock with Mockito for WorkerConnectorTest > --

[jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests

2022-08-12 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14133: --- Description: {color:#de350b}There are tests which use both PowerMock and EasyMock. I have put those

[jira] [Commented] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-19 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581826#comment-17581826 ] Yash Mayya commented on KAFKA-13431: Hi [~erdody], pinging you here in case you miss

[jira] [Assigned] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-21 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-13431: -- Assignee: Yash Mayya (was: Diego Erdody) > Sink Connectors: Support topic-mutating SMTs for

[jira] [Comment Edited] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya edited comment on KAFKA-13431 at 8/22/22 10:47 AM:

[jira] [Commented] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya commented on KAFKA-13431: Thanks Diego.   [~ChrisEgerton] with regard t

[jira] [Comment Edited] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya edited comment on KAFKA-13431 at 8/22/22 10:49 AM:

[jira] [Comment Edited] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya edited comment on KAFKA-13431 at 8/22/22 10:48 AM:

[jira] [Comment Edited] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya edited comment on KAFKA-13431 at 8/22/22 12:15 PM:

[jira] [Comment Edited] (KAFKA-13431) Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

2022-08-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582899#comment-17582899 ] Yash Mayya edited comment on KAFKA-13431 at 8/22/22 12:16 PM:

[jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests

2022-08-23 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14133: --- Description: {color:#de350b}There are tests which use both PowerMock and EasyMock. I have put those

[jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests

2022-08-23 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14133: --- Description: {color:#de350b}There are tests which use both PowerMock and EasyMock. I have put those

[jira] [Updated] (KAFKA-14134) Replace EasyMock with Mockito for WorkerConnectorTest

2022-08-23 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14134: --- Reviewer: Chris Egerton > Replace EasyMock with Mockito for WorkerConnectorTest > --

[jira] [Assigned] (KAFKA-13952) Infinite retry timeout is not working

2022-08-23 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-13952: -- Assignee: Yash Mayya > Infinite retry timeout is not working > --

[jira] [Commented] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585384#comment-17585384 ] Yash Mayya commented on KAFKA-14015: Hm this looks like it maybe a bug in the Standa

[jira] [Commented] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390 ] Yash Mayya commented on KAFKA-14015: In essence, this should work as expected when C

[jira] [Comment Edited] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390 ] Yash Mayya edited comment on KAFKA-14015 at 8/26/22 2:00 PM: -

[jira] [Comment Edited] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390 ] Yash Mayya edited comment on KAFKA-14015 at 8/26/22 2:02 PM: -

[jira] [Comment Edited] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-27 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390 ] Yash Mayya edited comment on KAFKA-14015 at 8/27/22 8:50 AM: -

[jira] [Comment Edited] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-27 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390 ] Yash Mayya edited comment on KAFKA-14015 at 8/27/22 8:51 AM: -

[jira] [Updated] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-28 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14015: --- Component/s: KafkaConnect > ConfigProvider with ttl fails to restart tasks > ---

[jira] [Assigned] (KAFKA-14015) ConfigProvider with ttl fails to restart tasks

2022-08-28 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14015: -- Assignee: Yash Mayya (was: Sagar Rao) > ConfigProvider with ttl fails to restart tasks > ---

[jira] [Created] (KAFKA-14193) Connect system test ConnectRestApiTest is failing

2022-08-31 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14193: -- Summary: Connect system test ConnectRestApiTest is failing Key: KAFKA-14193 URL: https://issues.apache.org/jira/browse/KAFKA-14193 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-14191) Add end-to-end latency metrics to Connectors

2022-09-03 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14191: --- Component/s: KafkaConnect > Add end-to-end latency metrics to Connectors > -

[jira] [Updated] (KAFKA-14132) Remaining PowerMock to Mockito tests

2022-09-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14132: --- Description: {color:#de350b}Some of the tests below use EasyMock as well. For those migrate both Po

[jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests

2022-09-21 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14133: --- Description: {color:#de350b}There are tests which use both PowerMock and EasyMock. I have put those

[jira] [Created] (KAFKA-14342) KafkaOffsetBackingStore should clear offsets for source partitions on tombstone messages

2022-10-31 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14342: -- Summary: KafkaOffsetBackingStore should clear offsets for source partitions on tombstone messages Key: KAFKA-14342 URL: https://issues.apache.org/jira/browse/KAFKA-14342

[jira] [Created] (KAFKA-14353) Make Kafka Connect REST request timeouts configurable

2022-11-02 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14353: -- Summary: Make Kafka Connect REST request timeouts configurable Key: KAFKA-14353 URL: https://issues.apache.org/jira/browse/KAFKA-14353 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-14353) Make Kafka Connect REST API request timeouts configurable

2022-11-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14353: --- Summary: Make Kafka Connect REST API request timeouts configurable (was: Make Kafka Connect REST re

[jira] [Commented] (KAFKA-14353) Make Kafka Connect REST API request timeouts configurable

2022-11-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627727#comment-17627727 ] Yash Mayya commented on KAFKA-14353: [KIP-882|https://cwiki.apache.org/confluence/di

[jira] [Created] (KAFKA-14368) Add an offset write REST API to Kafka Connect

2022-11-08 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14368: -- Summary: Add an offset write REST API to Kafka Connect Key: KAFKA-14368 URL: https://issues.apache.org/jira/browse/KAFKA-14368 Project: Kafka Issue Type: New Fea

[jira] [Assigned] (KAFKA-14353) Kafka Connect REST API configuration validation timeout improvements

2024-06-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14353: -- Assignee: (was: Yash Mayya) > Kafka Connect REST API configuration validation timeout imp

[jira] [Assigned] (KAFKA-14569) Migrate EmbeddedKafkaCluster used by Connect integration tests from EmbeddedZookeeper to KRaft

2024-06-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14569: -- Assignee: (was: Yash Mayya) > Migrate EmbeddedKafkaCluster used by Connect integration te

[jira] [Assigned] (KAFKA-14858) Standalone herder does not handle exceptions thrown from connector taskConfigs method

2024-06-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14858: -- Assignee: (was: Yash Mayya) > Standalone herder does not handle exceptions thrown from co

[jira] [Assigned] (KAFKA-14844) Kafka Connect's OffsetBackingStore interface should handle (de)serialization and connector namespacing

2024-06-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14844: -- Assignee: (was: Yash Mayya) > Kafka Connect's OffsetBackingStore interface should handle

[jira] [Assigned] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2024-06-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14956: -- Assignee: (was: Yash Mayya) > Flaky test > org.apache.kafka.connect.integration.OffsetsA

[jira] [Created] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-25 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-16196: -- Summary: Cast transform doesn't handle invalid whole value casts gracefully Key: KAFKA-16196 URL: https://issues.apache.org/jira/browse/KAFKA-16196 Project: Kafka

[jira] [Updated] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-25 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-16196: --- Description: The Cast transform currently doesn't handle invalid whole value casts gracefully. A wh

[jira] [Updated] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-25 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-16196: --- Description: The Cast transform currently doesn't handle invalid whole value casts gracefully. A wh

[jira] [Updated] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-25 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-16196: --- Description: The Cast transform currently doesn't handle invalid whole value casts gracefully. A wh

[jira] [Updated] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully

2024-01-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-16196: --- Fix Version/s: 3.8.0 > Cast transform doesn't handle invalid whole value casts gracefully >

[jira] [Assigned] (KAFKA-14855) Harden integration testing logic for asserting that a connector is deleted

2023-09-11 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14855: -- Assignee: Yash Mayya > Harden integration testing logic for asserting that a connector is del

[jira] [Commented] (KAFKA-14067) Sink connector override.consumer.group.id can conflict with worker group.id

2023-09-12 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764114#comment-17764114 ] Yash Mayya commented on KAFKA-14067: This has been fixed in [https://github.com/apac

[jira] [Updated] (KAFKA-14067) Sink connector override.consumer.group.id can conflict with worker group.id

2023-09-12 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14067: --- Fix Version/s: 3.7.0 > Sink connector override.consumer.group.id can conflict with worker group.id >

[jira] [Resolved] (KAFKA-14067) Sink connector override.consumer.group.id can conflict with worker group.id

2023-09-12 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-14067. Resolution: Fixed > Sink connector override.consumer.group.id can conflict with worker group.id >

[jira] [Created] (KAFKA-15470) Allow creating connectors in a stopped state

2023-09-15 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-15470: -- Summary: Allow creating connectors in a stopped state Key: KAFKA-15470 URL: https://issues.apache.org/jira/browse/KAFKA-15470 Project: Kafka Issue Type: New Feat

[jira] [Commented] (KAFKA-15470) Allow creating connectors in a stopped state

2023-09-17 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766107#comment-17766107 ] Yash Mayya commented on KAFKA-15470: https://cwiki.apache.org/confluence/display/KAF

[jira] [Updated] (KAFKA-15248) Add BooleanConverter to Kafka Connect

2023-09-26 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-15248: --- Fix Version/s: 3.7.0 > Add BooleanConverter to Kafka Connect > -

[jira] [Resolved] (KAFKA-15177) MirrorMaker 2 should implement the alterOffsets KIP-875 API

2023-09-27 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-15177. Fix Version/s: 3.6.0 Resolution: Fixed > MirrorMaker 2 should implement the alterOffsets KI

[jira] [Resolved] (KAFKA-15547) Thread leak in MirrorMakerConfigTest#testClientConfigProperties

2023-10-04 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-15547. Fix Version/s: 3.7.0 Resolution: Fixed > Thread leak in MirrorMakerConfigTest#testClientCon

[jira] [Updated] (KAFKA-15547) Thread leak in MirrorMakerConfigTest#testClientConfigProperties

2023-10-04 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-15547: --- Issue Type: Test (was: Bug) > Thread leak in MirrorMakerConfigTest#testClientConfigProperties > ---

[jira] [Created] (KAFKA-15570) Add unit tests for MemoryConfigBackingStore

2023-10-10 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-15570: -- Summary: Add unit tests for MemoryConfigBackingStore Key: KAFKA-15570 URL: https://issues.apache.org/jira/browse/KAFKA-15570 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-14746) Throwing in Connector.taskConfigs in distributed mode generates a lot of logs

2023-04-09 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709965#comment-17709965 ] Yash Mayya commented on KAFKA-14746: I agree that the intent of the retries seems to

[jira] [Assigned] (KAFKA-14858) Standalone herder does not handle exceptions thrown from connector taskConfigs method

2023-04-09 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14858: -- Assignee: Yash Mayya > Standalone herder does not handle exceptions thrown from connector >

[jira] [Updated] (KAFKA-14910) Consider cancelling ongoing alter / reset connector offsets requests when the connector is resumed

2023-04-14 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14910: --- Summary: Consider cancelling ongoing alter / reset connector offsets requests when the connector is

[jira] [Created] (KAFKA-14910) Consider cancelling ongoing alter connector offsets requests when the connector is resumed

2023-04-14 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14910: -- Summary: Consider cancelling ongoing alter connector offsets requests when the connector is resumed Key: KAFKA-14910 URL: https://issues.apache.org/jira/browse/KAFKA-14910

[jira] [Commented] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs

2023-04-17 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713158#comment-17713158 ] Yash Mayya commented on KAFKA-14876: Yep, makes sense, I can raise a PR for that tom

[jira] [Commented] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs

2023-04-17 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713183#comment-17713183 ] Yash Mayya commented on KAFKA-14876: [~ChrisEgerton] I think we should document the

[jira] [Comment Edited] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs

2023-04-17 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713158#comment-17713158 ] Yash Mayya edited comment on KAFKA-14876 at 4/17/23 4:11 PM: -

[jira] [Commented] (KAFKA-14923) Upgrade io.netty_netty-codec for CVE-2022-41881

2023-04-20 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714541#comment-17714541 ] Yash Mayya commented on KAFKA-14923: [~vikashmishra0808] looks like [https://github.

[jira] [Updated] (KAFKA-14930) Public documentation for new Kafka Connect offset management REST APIs

2023-04-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14930: --- Fix Version/s: 3.6.0 > Public documentation for new Kafka Connect offset management REST APIs >

[jira] [Assigned] (KAFKA-14930) Public documentation for new Kafka Connect offset management REST APIs

2023-04-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14930: -- Assignee: Yash Mayya > Public documentation for new Kafka Connect offset management REST APIs

[jira] [Updated] (KAFKA-14930) Public documentation for new Kafka Connect offset management REST APIs

2023-04-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14930: --- Description: Add public documentation for the 3 new Kafka Connect offset management REST APIs being

[jira] [Updated] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs in 3.5

2023-04-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14876: --- Description: Add public documentation for the new Kafka Connect offset management REST API being in

[jira] [Created] (KAFKA-14933) Document Kafka Connect's log level REST APIs added in KIP-495

2023-04-25 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14933: -- Summary: Document Kafka Connect's log level REST APIs added in KIP-495 Key: KAFKA-14933 URL: https://issues.apache.org/jira/browse/KAFKA-14933 Project: Kafka Is

[jira] [Commented] (KAFKA-14947) Duplicate records are getting created in the topic.

2023-04-27 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717095#comment-17717095 ] Yash Mayya commented on KAFKA-14947: [~krishnendudas] this seems like a bug in the c

[jira] [Comment Edited] (KAFKA-14947) Duplicate records are getting created in the topic.

2023-04-27 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717095#comment-17717095 ] Yash Mayya edited comment on KAFKA-14947 at 4/27/23 9:58 AM: -

[jira] [Assigned] (KAFKA-13187) Replace EasyMock and PowerMock with Mockito for DistributedHerderTest

2023-04-28 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-13187: -- Assignee: Yash Mayya (was: Matthew de Detrich) > Replace EasyMock and PowerMock with Mockito

[jira] [Commented] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs in 3.5

2023-05-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718464#comment-17718464 ] Yash Mayya commented on KAFKA-14876: [~gharris1727] [~ChrisEgerton] sounds good, I'v

[jira] [Updated] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs in 3.5

2023-05-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14876: --- Description: Add public documentation for the new Kafka Connect REST APIs from [KIP-875|https://cwi

[jira] [Commented] (KAFKA-14947) Duplicate records are getting created in the topic.

2023-05-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718513#comment-17718513 ] Yash Mayya commented on KAFKA-14947: [~krishnendudas] the offset commits for source

[jira] [Assigned] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2023-05-02 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-14956: -- Assignee: Yash Mayya > Flaky test > org.apache.kafka.connect.integration.OffsetsApiIntegrati

[jira] [Updated] (KAFKA-14930) Public documentation for new Kafka Connect offset management REST APIs

2023-05-07 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14930: --- Description: Add public documentation for the new Kafka Connect offset management REST APIs from [

[jira] [Created] (KAFKA-14974) Restore backward compatibility in KafkaBasedLog

2023-05-08 Thread Yash Mayya (Jira)
Yash Mayya created KAFKA-14974: -- Summary: Restore backward compatibility in KafkaBasedLog Key: KAFKA-14974 URL: https://issues.apache.org/jira/browse/KAFKA-14974 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-14974) Restore backward compatibility in KafkaBasedLog

2023-05-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14974: --- Affects Version/s: 3.5.0 3.4.1 3.3.3 > Restore backwar

[jira] [Updated] (KAFKA-14455) Kafka Connect create and update REST APIs should surface failures while writing to the config topic

2023-05-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14455: --- Fix Version/s: 3.5.0 3.4.1 3.3.3 > Kafka Connect create and up

[jira] [Commented] (KAFKA-14974) Restore backward compatibility in KafkaBasedLog

2023-05-08 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720566#comment-17720566 ] Yash Mayya commented on KAFKA-14974: Thanks [~rhauch], your understanding here is co

[jira] [Commented] (KAFKA-15012) JsonConverter fails when there are leading Zeros in a field

2023-05-22 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725223#comment-17725223 ] Yash Mayya commented on KAFKA-15012: Thanks for filing this Jira [~ranjanrao]. Simpl

[jira] [Commented] (KAFKA-15018) Potential tombstone offsets corruption for exactly-once source connectors

2023-05-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725713#comment-17725713 ] Yash Mayya commented on KAFKA-15018: Thanks for filing this bug ticket [~ChrisEgerto

[jira] [Updated] (KAFKA-14952) Publish metrics when source connector fails to poll data

2023-05-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya updated KAFKA-14952: --- Labels: connect connect-api kip-required (was: connect connect-api) > Publish metrics when source c

[jira] [Commented] (KAFKA-14995) Automate asf.yaml collaborators refresh

2023-05-24 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725722#comment-17725722 ] Yash Mayya commented on KAFKA-14995: [~dajac] that GitHub team isn't publicly access

[jira] [Resolved] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-14956. Resolution: Fixed > Flaky test > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#t

[jira] [Commented] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727025#comment-17727025 ] Yash Mayya commented on KAFKA-14956: This test seems to be consistently passing afte

[jira] [Assigned] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-15034: -- Assignee: Yash Mayya > Improvement of ReplaceField performance for long list > --

[jira] [Commented] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727119#comment-17727119 ] Yash Mayya commented on KAFKA-15034: Thanks for filing this ticket [~baz33]. I think

[jira] [Commented] (KAFKA-15012) JsonConverter fails when there are leading Zeros in a field

2023-05-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727653#comment-17727653 ] Yash Mayya commented on KAFKA-15012: Thanks [~ChrisEgerton], that's a fair point. I

[jira] [Comment Edited] (KAFKA-15012) JsonConverter fails when there are leading Zeros in a field

2023-05-30 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725223#comment-17725223 ] Yash Mayya edited comment on KAFKA-15012 at 5/30/23 6:34 PM: -

  1   2   >