[jira] [Created] (KAFKA-14060) Replace EasyMock and PowerMock with Mockito in AbstractWorkerSourceTaskTest

2022-07-08 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14060: - Summary: Replace EasyMock and PowerMock with Mockito in AbstractWorkerSourceTaskTest Key: KAFKA-14060 URL: https://issues.apache.org/jira/browse/KAFKA-14060 Project

[jira] [Assigned] (KAFKA-14060) Replace EasyMock and PowerMock with Mockito in AbstractWorkerSourceTaskTest

2022-07-08 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14060: - Assignee: Chris Egerton > Replace EasyMock and PowerMock with Mockito in AbstractWorker

[jira] [Created] (KAFKA-14059) Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest

2022-07-08 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14059: - Summary: Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest Key: KAFKA-14059 URL: https://issues.apache.org/jira/browse/KAFKA-14059 Project: Kafka

[jira] [Comment Edited] (KAFKA-14058) Replace EasyMock and PowerMock with Mockito in ExactlyOnceWorkerSourceTaskTest

2022-07-11 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565173#comment-17565173 ] Chris Egerton edited comment on KAFKA-14058 at 7/11/22 8:16 PM: --

[jira] [Commented] (KAFKA-14058) Replace EasyMock and PowerMock with Mockito in ExactlyOnceWorkerSourceTaskTest

2022-07-11 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565173#comment-17565173 ] Chris Egerton commented on KAFKA-14058: --- Hi Chris! I assigned these three to mysel

[jira] [Comment Edited] (KAFKA-14058) Replace EasyMock and PowerMock with Mockito in ExactlyOnceWorkerSourceTaskTest

2022-07-11 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565173#comment-17565173 ] Chris Egerton edited comment on KAFKA-14058 at 7/11/22 8:17 PM: --

[jira] [Commented] (KAFKA-10000) Atomic commit of source connector records and offsets

2022-07-14 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566896#comment-17566896 ] Chris Egerton commented on KAFKA-1: --- Hi [~jagsancio]! We can keep it. All of t

[jira] [Commented] (KAFKA-14079) Source task develops memory leak if "error.tolerance" is set to "all"

2022-07-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567700#comment-17567700 ] Chris Egerton commented on KAFKA-14079: --- [~cshannon] is it correct to say that, in

[jira] [Comment Edited] (KAFKA-14079) Source task develops memory leak if "error.tolerance" is set to "all"

2022-07-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567700#comment-17567700 ] Chris Egerton edited comment on KAFKA-14079 at 7/17/22 5:44 PM: --

[jira] [Assigned] (KAFKA-8299) Add type-safe instantiation of generic classes to AbstractConfig

2022-07-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-8299: Assignee: (was: Chris Egerton) > Add type-safe instantiation of generic classes to Abs

[jira] [Assigned] (KAFKA-12476) Worker can block for longer than scheduled rebalance delay and/or session key TTL

2022-07-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12476: - Assignee: (was: Chris Egerton) > Worker can block for longer than scheduled rebalan

[jira] [Assigned] (KAFKA-12463) Update default consumer partition assignor for sink tasks

2022-07-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12463: - Assignee: (was: Chris Egerton) > Update default consumer partition assignor for sin

[jira] [Created] (KAFKA-14091) Suddenly-killed tasks can leave hanging transactions open

2022-07-20 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14091: - Summary: Suddenly-killed tasks can leave hanging transactions open Key: KAFKA-14091 URL: https://issues.apache.org/jira/browse/KAFKA-14091 Project: Kafka I

[jira] [Assigned] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

2022-07-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14089: - Assignee: Chris Egerton > Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTop

[jira] [Commented] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

2022-07-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569204#comment-17569204 ] Chris Egerton commented on KAFKA-14089: --- Thanks [~mimaison]. We don't assert on or

[jira] [Comment Edited] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

2022-07-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569204#comment-17569204 ] Chris Egerton edited comment on KAFKA-14089 at 7/20/22 11:28 PM: -

[jira] [Comment Edited] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

2022-07-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569204#comment-17569204 ] Chris Egerton edited comment on KAFKA-14089 at 7/20/22 11:41 PM: -

[jira] [Commented] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

2022-07-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569715#comment-17569715 ] Chris Egerton commented on KAFKA-14089: --- Thanks Mickael. I put together a draft fi

[jira] [Updated] (KAFKA-14098) Internal Kafka clients used by Kafka Connect should have distinguishable client IDs

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14098: -- Priority: Minor (was: Major) > Internal Kafka clients used by Kafka Connect should have disti

[jira] [Created] (KAFKA-14098) Internal Kafka clients used by Kafka Connect should have distinguishable client IDs

2022-07-22 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14098: - Summary: Internal Kafka clients used by Kafka Connect should have distinguishable client IDs Key: KAFKA-14098 URL: https://issues.apache.org/jira/browse/KAFKA-14098

[jira] [Commented] (KAFKA-14093) Flaky ExactlyOnceSourceIntegrationTest.testFencedLeaderRecovery

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570169#comment-17570169 ] Chris Egerton commented on KAFKA-14093: --- Think the root cause of this is rather si

[jira] [Comment Edited] (KAFKA-14093) Flaky ExactlyOnceSourceIntegrationTest.testFencedLeaderRecovery

2022-07-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570169#comment-17570169 ] Chris Egerton edited comment on KAFKA-14093 at 7/22/22 8:24 PM: --

[jira] [Assigned] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14101: - Assignee: Chris Egerton > Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

[jira] [Assigned] (KAFKA-14099) No REST API request logs in Kafka connect

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14099: - Assignee: Alexandre Garnier > No REST API request logs in Kafka connect > -

[jira] [Commented] (KAFKA-14099) No REST API request logs in Kafka connect

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571115#comment-17571115 ] Chris Egerton commented on KAFKA-14099: --- [~zigarn] Since you filed a PR to address

[jira] [Commented] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571130#comment-17571130 ] Chris Egerton commented on KAFKA-14101: --- Thanks, [~mimaison]. I believe this is du

[jira] [Comment Edited] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571130#comment-17571130 ] Chris Egerton edited comment on KAFKA-14101 at 7/25/22 11:39 PM: -

[jira] [Comment Edited] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-25 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571130#comment-17571130 ] Chris Egerton edited comment on KAFKA-14101 at 7/25/22 11:43 PM: -

[jira] [Assigned] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-07-26 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13586: - Assignee: (was: Greg Harris) > ConfigExceptions thrown by FileConfigProvider during

[jira] [Updated] (KAFKA-13982) Replace EasyMock and PowerMock with Mockito for WorkerConfigTransformerTest

2022-07-26 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13982: -- Fix Version/s: 3.4.0 > Replace EasyMock and PowerMock with Mockito for WorkerConfigTransformer

[jira] [Commented] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-26 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571454#comment-17571454 ] Chris Egerton commented on KAFKA-14101: --- [~tombentley] Yeah, a renaming would help

[jira] [Assigned] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-07-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13586: - Assignee: Chris Egerton > ConfigExceptions thrown by FileConfigProvider during connecto

[jira] [Commented] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-07-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572144#comment-17572144 ] Chris Egerton commented on KAFKA-13586: --- Dan Stelljes (@dstelljes on GitHub) is wo

[jira] [Resolved] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14101. --- Resolution: Fixed > Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary > -

[jira] [Updated] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14101: -- Fix Version/s: 3.3.0 > Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary >

[jira] [Commented] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572517#comment-17572517 ] Chris Egerton commented on KAFKA-14101: --- Resolving since [https://github.com/apach

[jira] [Comment Edited] (KAFKA-14101) Flaky ExactlyOnceSourceIntegrationTest.testConnectorBoundary

2022-07-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572517#comment-17572517 ] Chris Egerton edited comment on KAFKA-14101 at 7/28/22 3:22 PM: --

[jira] [Commented] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

2022-08-03 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574771#comment-17574771 ] Chris Egerton commented on KAFKA-12495: --- [~sagarrao] yes, it's unassigned so anyon

[jira] [Commented] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

2022-08-04 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575299#comment-17575299 ] Chris Egerton commented on KAFKA-12495: --- [~sagarrao] it seems like there are two i

[jira] [Created] (KAFKA-14143) Exactly-once source system tests

2022-08-04 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14143: - Summary: Exactly-once source system tests Key: KAFKA-14143 URL: https://issues.apache.org/jira/browse/KAFKA-14143 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-10000) Atomic commit of source connector records and offsets

2022-08-04 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575322#comment-17575322 ] Chris Egerton commented on KAFKA-1: --- Done. Filed https://issues.apache.org/jir

[jira] [Resolved] (KAFKA-6080) Transactional EoS for source connectors

2022-08-04 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-6080. -- Fix Version/s: 3.3.0 Resolution: Fixed > Transactional EoS for source connectors > -

[jira] [Resolved] (KAFKA-10000) Atomic commit of source connector records and offsets

2022-08-04 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-1. --- Resolution: Done > Atomic commit of source connector records and offsets > -

[jira] [Reopened] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

2022-08-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-13809: --- > FileStreamSinkConnector and FileStreamSourceConnector should propagate full > configuration t

[jira] [Assigned] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

2022-08-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13809: - Assignee: Yash Mayya > FileStreamSinkConnector and FileStreamSourceConnector should pro

[jira] [Resolved] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

2022-08-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13809. --- Fix Version/s: 3.4.0 Resolution: Fixed > FileStreamSinkConnector and FileStreamSource

[jira] [Assigned] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-08-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13586: - Assignee: Dan Stelljes (was: Chris Egerton) > ConfigExceptions thrown by FileConfigPro

[jira] [Updated] (KAFKA-14007) Connect header converters are never closed

2022-08-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14007: -- Fix Version/s: 3.4.0 > Connect header converters are never closed > --

[jira] [Updated] (KAFKA-14012) passing a "method" into the `Utils.closeQuietly` method cause NPE

2022-08-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14012: -- Fix Version/s: 3.4.0 > passing a "method" into the `Utils.closeQuietly` method cause NPE > ---

[jira] [Updated] (KAFKA-14091) Suddenly-killed tasks can leave hanging transactions open

2022-08-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14091: -- Description: Right now, if a task running with exactly-once support is killed ungracefully, i

[jira] [Commented] (KAFKA-14000) Kafka-connect standby server shows empty tasks list

2022-08-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582582#comment-17582582 ] Chris Egerton commented on KAFKA-14000: --- [~sagarrao] we do not recommend that the

[jira] [Assigned] (KAFKA-13156) KafkaStatusBackingStore making incorrect assumption about order of task and connector delete events

2022-08-22 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13156: - Assignee: Chris Egerton (was: Nigel Liang) > KafkaStatusBackingStore making incorrect

[jira] [Updated] (KAFKA-14162) HoistField and MaskField SMTs should not return immutable maps/lists

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14162: -- Summary: HoistField and MaskField SMTs should not return immutable maps/lists (was: HoistFiel

[jira] [Commented] (KAFKA-14162) HoistField and MaskField SMTs should not return immutable maps/lists

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583654#comment-17583654 ] Chris Egerton commented on KAFKA-14162: --- It was noted during PR review that we als

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

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14147: -- Reviewer: Chris Egerton > Some map objects in KafkaConfigBackingStore grow in size monotonical

[jira] [Resolved] (KAFKA-13971) Atomicity violations caused by improper usage of ConcurrentHashMap

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13971. --- Fix Version/s: 3.4.0 Reviewer: Chris Egerton Resolution: Fixed > Atomicity v

[jira] [Updated] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13809: -- Reviewer: Chris Egerton > FileStreamSinkConnector and FileStreamSourceConnector should propaga

[jira] [Updated] (KAFKA-14095) Improve handling of sync offset failures in MirrorMaker

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14095: -- Reviewer: Chris Egerton > Improve handling of sync offset failures in MirrorMaker > --

[jira] [Updated] (KAFKA-14007) Connect header converters are never closed

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14007: -- Reviewer: Chris Egerton > Connect header converters are never closed > ---

[jira] [Updated] (KAFKA-14012) passing a "method" into the `Utils.closeQuietly` method cause NPE

2022-08-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14012: -- Reviewer: Chris Egerton > passing a "method" into the `Utils.closeQuietly` method cause NPE >

[jira] [Resolved] (KAFKA-14180) Help, I've been changed into a monstrous, verminous bug

2022-08-26 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14180. --- Resolution: Invalid "Not a bug" doesn't seem quite accurate for some reason... > Help, I've

[jira] [Comment Edited] (KAFKA-14180) Help, I've been changed into a monstrous, verminous bug

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

[jira] [Updated] (KAFKA-10548) Implement deletion logic for LeaderAndIsrRequests

2022-09-06 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-10548: -- Description: This will allow for specialized deletion logic when receiving LeaderAndIsrReques

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

2022-09-08 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13952. --- Fix Version/s: 3.4.0 Resolution: Fixed > Infinite retry timeout is not working >

[jira] [Resolved] (KAFKA-14143) Exactly-once source system tests

2022-09-08 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14143. --- Resolution: Fixed > Exactly-once source system tests > > >

[jira] [Updated] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

2022-09-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14220: -- Fix Version/s: (was: 3.0.1) > "partition-count" not getting updated after revocation of pa

[jira] [Updated] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

2022-09-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14220: -- Reviewer: Chris Egerton (was: Konstantine Karantasis) > "partition-count" not getting updated

[jira] [Commented] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

2022-09-14 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604716#comment-17604716 ] Chris Egerton commented on KAFKA-14220: --- [~kumarpritam863] this seemed like a legi

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

2022-09-14 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604794#comment-17604794 ] Chris Egerton commented on KAFKA-14132: --- [~christo_lolov] Any preference on how we

[jira] [Updated] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13985: -- Fix Version/s: 3.4.0 > MirrorSourceTask commitRecord throws NPE if SMT is filtering out source

[jira] [Updated] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13985: -- Affects Version/s: 3.3.0 > MirrorSourceTask commitRecord throws NPE if SMT is filtering out so

[jira] [Resolved] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13632. --- Resolution: Fixed > MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered

[jira] [Updated] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13632: -- Affects Version/s: 3.2.0 3.3.0 > MirrorMaker 2.0 NPE and Warning "Failu

[jira] [Updated] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13632: -- Fix Version/s: 3.4.0 > MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtere

[jira] [Resolved] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

2022-09-15 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13985. --- Resolution: Fixed > MirrorSourceTask commitRecord throws NPE if SMT is filtering out source

[jira] (KAFKA-13927) Kafka Connect Sink Connector Success after RetriableException, no commit offset to remote.

2022-09-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13927 ] Chris Egerton deleted comment on KAFKA-13927: --- was (Author: chrisegerton): https://github.com/apache/kafka/pull/12566 > Kafka Connect Sink Connector Success after RetriableException, no co

[jira] [Assigned] (KAFKA-13927) Kafka Connect Sink Connector Success after RetriableException, no commit offset to remote.

2022-09-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13927: - Assignee: Jordan Bull > Kafka Connect Sink Connector Success after RetriableException,

[jira] [Resolved] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-09-19 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12878. --- Fix Version/s: 3.4.0 Resolution: Done > Support --bootstrap-server kafka-streams-appl

[jira] [Created] (KAFKA-14244) Prevent unit/integration tests from terminating JVM

2022-09-20 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14244: - Summary: Prevent unit/integration tests from terminating JVM Key: KAFKA-14244 URL: https://issues.apache.org/jira/browse/KAFKA-14244 Project: Kafka Issue T

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

2022-09-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13187: - Assignee: Chris Egerton (was: Dalibor Plavcic) > Replace EasyMock and PowerMock with M

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

2022-09-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13187: - Assignee: Matthew de Detrich (was: Chris Egerton) > Replace EasyMock and PowerMock wit

[jira] [Commented] (KAFKA-14250) Exception during normal operation in MirrorSourceTask causes the task to fail instead of shutting down gracefully

2022-09-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610141#comment-17610141 ] Chris Egerton commented on KAFKA-14250: --- [~viktorsomogyi] can you confirm which ve

[jira] [Commented] (KAFKA-9228) Reconfigured converters and clients may not be propagated to connector tasks

2019-12-11 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993990#comment-16993990 ] Chris Egerton commented on KAFKA-9228: -- This issue is much harder to reproduce than

[jira] [Commented] (KAFKA-5756) Synchronization issue on flush

2019-12-18 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999546#comment-16999546 ] Chris Egerton commented on KAFKA-5756: -- I believe a very similar issue may still be

[jira] [Reopened] (KAFKA-5756) Synchronization issue on flush

2019-12-18 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-5756: -- > Synchronization issue on flush > -- > > Key: KAFKA-57

[jira] [Commented] (KAFKA-5756) Synchronization issue on flush

2019-12-18 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999547#comment-16999547 ] Chris Egerton commented on KAFKA-5756: -- [~olkuznsmith] [~rhauch] [~hachikuji] do you

[jira] [Created] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-01-06 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-9374: Summary: Worker can be disabled by blocked connectors Key: KAFKA-9374 URL: https://issues.apache.org/jira/browse/KAFKA-9374 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-01-07 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009998#comment-17009998 ] Chris Egerton commented on KAFKA-9374: -- [~tombentley] yeah, it's not great if a lot

[jira] [Comment Edited] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-01-07 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009998#comment-17009998 ] Chris Egerton edited comment on KAFKA-9374 at 1/7/20 7:05 PM: -

[jira] [Updated] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-01-07 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-9374: - Description: If a connector hangs during any of its {{initialize}}, {{start}}, {{stop}}, \{taskC

[jira] [Created] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-01-16 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-9446: Summary: Integration test library should provide utilities to assert connector state Key: KAFKA-9446 URL: https://issues.apache.org/jira/browse/KAFKA-9446 Project: Ka

[jira] [Created] (KAFKA-9472) Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED

2020-01-23 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-9472: Summary: Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED Key: KAFKA-9472 URL: https://issues.apache.org/jira/browse/KAFKA-9472 Proje

[jira] [Commented] (KAFKA-9472) Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED

2020-01-24 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023271#comment-17023271 ] Chris Egerton commented on KAFKA-9472: -- [~kkonstantine] the issues may be similar bu

[jira] [Commented] (KAFKA-9472) Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED

2020-01-24 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023297#comment-17023297 ] Chris Egerton commented on KAFKA-9472: -- After looking into this a bit I suspect the

[jira] [Commented] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-02-10 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034006#comment-17034006 ] Chris Egerton commented on KAFKA-9374: -- Hi [~tombentley], sorry for the delay in rep

[jira] [Commented] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036610#comment-17036610 ] Chris Egerton commented on KAFKA-9446: -- Sounds good. Thanks for the improvements, [~

[jira] [Resolved] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-9446. -- Resolution: Fixed > Integration test library should provide utilities to assert connector state

[jira] [Assigned] (KAFKA-9472) Reducing number of tasks for connector causes deleted tasks to show as UNASSIGNED

2020-02-14 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9472: Assignee: Chris Egerton > Reducing number of tasks for connector causes deleted tasks to s

[jira] [Created] (KAFKA-9560) Connector::validate is utilized concurrently by the framework, but not documented as thread-safe

2020-02-14 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-9560: Summary: Connector::validate is utilized concurrently by the framework, but not documented as thread-safe Key: KAFKA-9560 URL: https://issues.apache.org/jira/browse/KAFKA-9560

[jira] [Created] (KAFKA-9570) SSL cannot be configured for Connect in standalone mode

2020-02-18 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-9570: Summary: SSL cannot be configured for Connect in standalone mode Key: KAFKA-9570 URL: https://issues.apache.org/jira/browse/KAFKA-9570 Project: Kafka Issue T

<    1   2   3   4   5   6   7   8   9   10   >