[jira] [Updated] (KAFKA-14873) Pluggable storage for Kafka Connect internal topics

[ https://issues.apache.org/jira/browse/KAFKA-14873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14873: -- Labels: needs-kip (was: ) > Pluggable storage for Kafka Connect internal topics > ---

[jira] [Updated] (KAFKA-14873) Pluggable storage for Kafka Connect internal topics

[ https://issues.apache.org/jira/browse/KAFKA-14873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14873: -- Component/s: KafkaConnect > Pluggable storage for Kafka Connect internal topics >

[jira] [Commented] (KAFKA-14420) MirrorMaker should not clear filtered configs on target topics

[ https://issues.apache.org/jira/browse/KAFKA-14420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710197#comment-17710197 ] Chris Egerton commented on KAFKA-14420: --- Addressed with [KIP-894|https://cwiki.ap

[jira] [Updated] (KAFKA-14420) MirrorMaker should not clear filtered configs on target topics

[ https://issues.apache.org/jira/browse/KAFKA-14420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14420: -- Fix Version/s: 3.5.0 > MirrorMaker should not clear filtered configs on target topics > --

[jira] [Resolved] (KAFKA-14783) Implement new STOPPED state for connectors

[ https://issues.apache.org/jira/browse/KAFKA-14783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14783. --- Fix Version/s: 3.5.0 Resolution: Done > Implement new STOPPED state for connectors >

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

[ https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710972#comment-17710972 ] Chris Egerton commented on KAFKA-14746: --- Hi Yash, {quote}are you suggesting a KIP

[jira] [Commented] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716280#comment-17716280 ] Chris Egerton commented on KAFKA-14666: --- [~mimaison] I believe this should be a re

[jira] [Updated] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14666: -- Priority: Blocker (was: Major) > MM2 should translate consumer group offsets behind replicati

[jira] [Commented] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716579#comment-17716579 ] Chris Egerton commented on KAFKA-14666: --- Merged to trunk and backported to 3.5. I

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

[ https://issues.apache.org/jira/browse/KAFKA-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718258#comment-17718258 ] Chris Egerton commented on KAFKA-14876: --- [~yash.mayya] I think it's worth document

[jira] [Commented] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718669#comment-17718669 ] Chris Egerton commented on KAFKA-14666: --- Backported to 3.4 and 3.3. > MM2 should

[jira] [Updated] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14666: -- Fix Version/s: 3.4.1 3.3.3 > MM2 should translate consumer group offsets be

[jira] [Updated] (KAFKA-14837) The MirrorCheckPointConnector of MM2 will rebalance frequently, when the source cluster group is many more and changes frequently (but the list of configured synchronous

[ https://issues.apache.org/jira/browse/KAFKA-14837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14837: -- Fix Version/s: 3.4.1 3.3.3 > The MirrorCheckPointConnector of MM2 will reba

[jira] [Updated] (KAFKA-14842) MirrorCheckpointTask can reduce the rpc calls of "listConsumerGroupOffsets(group)" of irrelevant groups at each poll

[ https://issues.apache.org/jira/browse/KAFKA-14842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14842: -- Fix Version/s: 3.4.1 3.3.3 > MirrorCheckpointTask can reduce the rpc calls

[jira] [Updated] (KAFKA-14978) ExactlyOnceWorkerSourceTask does not remove parent metrics

[ https://issues.apache.org/jira/browse/KAFKA-14978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14978: -- Fix Version/s: 3.4.1 > ExactlyOnceWorkerSourceTask does not remove parent metrics > --

[jira] [Assigned] (KAFKA-14980) MirrorMaker consumers don't get configs prefixed with source.cluster

[ https://issues.apache.org/jira/browse/KAFKA-14980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14980: - Assignee: Chris Egerton > MirrorMaker consumers don't get configs prefixed with source.

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

Chris Egerton created KAFKA-15018: - Summary: Potential tombstone offsets corruption for exactly-once source connectors Key: KAFKA-15018 URL: https://issues.apache.org/jira/browse/KAFKA-15018 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725502#comment-17725502 ] Chris Egerton commented on KAFKA-15018: --- One possible fix for this could be to pre

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

[ https://issues.apache.org/jira/browse/KAFKA-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727631#comment-17727631 ] Chris Egerton commented on KAFKA-15012: --- [~yash.mayya] I'm wondering if compatibil

[jira] [Resolved] (KAFKA-14863) Plugins which do not have a valid no-args constructor are visible in the REST API

[ https://issues.apache.org/jira/browse/KAFKA-14863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14863. --- Fix Version/s: 3.6.0 Resolution: Fixed > Plugins which do not have a valid no-args co

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

[ https://issues.apache.org/jira/browse/KAFKA-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15012. --- Fix Version/s: 3.6.0 Resolution: Fixed > JsonConverter fails when there are leading Z

[jira] [Commented] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

[ https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729323#comment-17729323 ] Chris Egerton commented on KAFKA-15053: --- Thanks [~dlgaobo]. I agree that this is a

[jira] [Assigned] (KAFKA-15051) docs: add missing connector plugin endpoint to documentation

[ https://issues.apache.org/jira/browse/KAFKA-15051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-15051: - Assignee: Jorge Esteban Quilcate Otoya > docs: add missing connector plugin endpoint to

[jira] [Created] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

Chris Egerton created KAFKA-15059: - Summary: Exactly-once source tasks fail to start during pending rebalances Key: KAFKA-15059 URL: https://issues.apache.org/jira/browse/KAFKA-15059 Project: Kafka

[jira] [Commented] (KAFKA-14718) Flaky DedicatedMirrorIntegrationTest test suite

[ https://issues.apache.org/jira/browse/KAFKA-14718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729486#comment-17729486 ] Chris Egerton commented on KAFKA-14718: --- I think a 30-second startup timeout is a

[jira] [Commented] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729709#comment-17729709 ] Chris Egerton commented on KAFKA-15059: --- On second thought, it may be unnecessary

[jira] [Resolved] (KAFKA-12857) Using Connect Sink with CooperativeStickyAssignor results in commit offsets failure

[ https://issues.apache.org/jira/browse/KAFKA-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12857. --- Assignee: (was: dgd_contributor) Resolution: Duplicate > Using Connect Sink with C

[jira] [Updated] (KAFKA-12226) High-throughput source tasks fail to commit offsets

[ https://issues.apache.org/jira/browse/KAFKA-12226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12226: -- Description: The current source task thread has the following workflow: # Poll messages from

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

[ https://issues.apache.org/jira/browse/KAFKA-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9228: Assignee: (was: Chris Egerton) > Reconfigured converters and clients may not be propag

[jira] [Created] (KAFKA-13327) Preflight validations of connectors leads to 500 responses

Chris Egerton created KAFKA-13327: - Summary: Preflight validations of connectors leads to 500 responses Key: KAFKA-13327 URL: https://issues.apache.org/jira/browse/KAFKA-13327 Project: Kafka

[jira] [Created] (KAFKA-13328) Preflight validation of header converters is not performed by Connect

Chris Egerton created KAFKA-13328: - Summary: Preflight validation of header converters is not performed by Connect Key: KAFKA-13328 URL: https://issues.apache.org/jira/browse/KAFKA-13328 Project: Kafk

[jira] [Updated] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters

[ https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13328: -- Summary: Connect does not perform preflight validation for per-connector header converters (w

[jira] [Created] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

Chris Egerton created KAFKA-13329: - Summary: Connect does not perform preflight validation for per-connector key and value converters Key: KAFKA-13329 URL: https://issues.apache.org/jira/browse/KAFKA-13329

[jira] [Updated] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters

[ https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13328: -- Description: Users may specify a header converter class for their connector directly in the c

[jira] [Commented] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

[ https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421507#comment-17421507 ] Chris Egerton commented on KAFKA-13329: --- I agree that that'd be beneficial, althou

[jira] [Comment Edited] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

[ https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421507#comment-17421507 ] Chris Egerton edited comment on KAFKA-13329 at 10/1/21, 4:02 PM: -

[jira] [Commented] (KAFKA-10334) Transactions not working properly

[ https://issues.apache.org/jira/browse/KAFKA-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444589#comment-17444589 ] Chris Egerton commented on KAFKA-10334: --- It seems like this may be a duplicate of

[jira] [Updated] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15059: -- Affects Version/s: 3.6.0 (was: 3.3.0) (wa

[jira] [Updated] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15059: -- Priority: Blocker (was: Major) > Exactly-once source tasks fail to start during pending rebal

[jira] [Updated] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15059: -- Fix Version/s: 3.6.0 > Exactly-once source tasks fail to start during pending rebalances > ---

[jira] [Created] (KAFKA-15090) Source tasks are no longer stopped on a separate thread

Chris Egerton created KAFKA-15090: - Summary: Source tasks are no longer stopped on a separate thread Key: KAFKA-15090 URL: https://issues.apache.org/jira/browse/KAFKA-15090 Project: Kafka Iss

[jira] [Created] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

Chris Egerton created KAFKA-15091: - Summary: Javadocs for SourceTask::commit are incorrect Key: KAFKA-15091 URL: https://issues.apache.org/jira/browse/KAFKA-15091 Project: Kafka Issue Type: B

[jira] [Assigned] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

[ https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-15053: - Assignee: Bo Gao > Regression for security.protocol validation starting from 3.3.0 > --

[jira] [Commented] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735711#comment-17735711 ] Chris Egerton commented on KAFKA-15059: --- Ah, thanks Viktor! > Exactly-once source

[jira] [Updated] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

[ https://issues.apache.org/jira/browse/KAFKA-15113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15113: -- Priority: Minor (was: Major) > Gracefully handle cases where a sink connector's admin and con

[jira] [Commented] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

[ https://issues.apache.org/jira/browse/KAFKA-15113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736177#comment-17736177 ] Chris Egerton commented on KAFKA-15113: --- [~yash.mayya] Thanks for filing this! On

[jira] [Comment Edited] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

[ https://issues.apache.org/jira/browse/KAFKA-15113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736177#comment-17736177 ] Chris Egerton edited comment on KAFKA-15113 at 6/22/23 3:35 PM: --

[jira] [Commented] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

[ https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736529#comment-17736529 ] Chris Egerton commented on KAFKA-15053: --- [~dlgaobo] I think that may have been a t

[jira] [Comment Edited] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

[ https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736529#comment-17736529 ] Chris Egerton edited comment on KAFKA-15053 at 6/23/23 3:31 PM: --

[jira] [Updated] (KAFKA-14784) Implement connector offset reset REST API

[ https://issues.apache.org/jira/browse/KAFKA-14784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14784: -- Fix Version/s: 3.6.0 > Implement connector offset reset REST API > ---

[jira] [Resolved] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-4107. -- Resolution: Done > Support offset reset capability in Kafka Connect > -

[jira] [Updated] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-4107: - Fix Version/s: 3.6.0 > Support offset reset capability in Kafka Connect > ---

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736570#comment-17736570 ] Chris Egerton commented on KAFKA-4107: -- Wanted to update everyone here and let you a

[jira] [Assigned] (KAFKA-14972) Make KafkaConsumer usable in async runtimes

[ https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14972: - Assignee: Erik van Oosten > Make KafkaConsumer usable in async runtimes > -

[jira] [Commented] (KAFKA-15127) Allow offsets to be reset at the same time a connector is deleted.

[ https://issues.apache.org/jira/browse/KAFKA-15127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738578#comment-17738578 ] Chris Egerton commented on KAFKA-15127: --- I think it's a little premature to start

[jira] [Commented] (KAFKA-15068) Incorrect replication Latency may be calculated when the timestamp of the record is of type CREATE_TIME

[ https://issues.apache.org/jira/browse/KAFKA-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738591#comment-17738591 ] Chris Egerton commented on KAFKA-15068: --- Thanks for filing this [~hudeqi], good ca

[jira] [Commented] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738733#comment-17738733 ] Chris Egerton commented on KAFKA-15102: --- [~ddufour1a] Thanks for raising this. I b

[jira] [Comment Edited] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738733#comment-17738733 ] Chris Egerton edited comment on KAFKA-15102 at 6/29/23 6:43 PM: --

[jira] [Commented] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

[ https://issues.apache.org/jira/browse/KAFKA-15113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738740#comment-17738740 ] Chris Egerton commented on KAFKA-15113: --- [~yash.mayya] although it seems a little

[jira] [Commented] (KAFKA-15127) Allow offsets to be reset at the same time a connector is deleted.

[ https://issues.apache.org/jira/browse/KAFKA-15127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739095#comment-17739095 ] Chris Egerton commented on KAFKA-15127: --- In that case, perhaps we can leave it una

[jira] [Updated] (KAFKA-13988) Mirrormaker 2 auto.offset.reset=latest not working

[ https://issues.apache.org/jira/browse/KAFKA-13988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13988: -- Fix Version/s: (was: 3.2.0) > Mirrormaker 2 auto.offset.reset=latest not working > ---

[jira] [Updated] (KAFKA-13988) Mirrormaker 2 auto.offset.reset=latest not working

[ https://issues.apache.org/jira/browse/KAFKA-13988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13988: -- Component/s: (was: KafkaConnect) > Mirrormaker 2 auto.offset.reset=latest not working > --

[jira] [Commented] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739146#comment-17739146 ] Chris Egerton commented on KAFKA-15102: --- [~omnia_h_ibrahim] Good call 👍 we should

[jira] [Commented] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739196#comment-17739196 ] Chris Egerton commented on KAFKA-15091: --- I think that was also discussed with KAFK

[jira] [Commented] (KAFKA-15127) Allow offsets to be reset at the same time a connector is deleted.

[ https://issues.apache.org/jira/browse/KAFKA-15127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739635#comment-17739635 ] Chris Egerton commented on KAFKA-15127: --- Thanks Sagar! > Allow offsets to be rese

[jira] [Commented] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740248#comment-17740248 ] Chris Egerton commented on KAFKA-15102: --- Thanks [~omnia_h_ibrahim], I'd love it if

[jira] [Assigned] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-15102: - Assignee: Omnia Ibrahim > Mirror Maker 2 - KIP690 backward compatibility >

[jira] [Commented] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740663#comment-17740663 ] Chris Egerton commented on KAFKA-15102: --- 💯 [~omnia_h_ibrahim] I've assigned you th

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

[ https://issues.apache.org/jira/browse/KAFKA-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14059. --- Resolution: Done > Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14059: -- Fix Version/s: 3.6.0 > Replace EasyMock and PowerMock with Mockito in WorkerSourceTaskTest > -

[jira] [Updated] (KAFKA-15145) AbstractWorkerSourceTask re-processes records filtered out by SMTs on retriable exceptions

[ https://issues.apache.org/jira/browse/KAFKA-15145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15145: -- Fix Version/s: 3.5.1 > AbstractWorkerSourceTask re-processes records filtered out by SMTs on

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

[ https://issues.apache.org/jira/browse/KAFKA-15177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-15177: - Assignee: Chris Egerton > MirrorMaker 2 should implement the alterOffsets KIP-875 API >

[jira] [Commented] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

[ https://issues.apache.org/jira/browse/KAFKA-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742034#comment-17742034 ] Chris Egerton commented on KAFKA-15059: --- [~divijvaidya] no; this was introduced by

[jira] [Updated] (KAFKA-15172) Allow exact mirroring of ACLs between clusters

[ https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15172: -- Labels: needs-kip (was: ) > Allow exact mirroring of ACLs between clusters >

[jira] [Updated] (KAFKA-15179) Add integration tests for the FileStream Sink and Source connectors

[ https://issues.apache.org/jira/browse/KAFKA-15179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15179: -- Issue Type: Test (was: Improvement) > Add integration tests for the FileStream Sink and Sourc

[jira] [Updated] (KAFKA-14938) Flaky test org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest#testConnectorBoundary

[ https://issues.apache.org/jira/browse/KAFKA-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14938: -- Fix Version/s: 3.6.0 > Flaky test > org.apache.kafka.connect.integration.ExactlyOnceSourceInt

[jira] [Updated] (KAFKA-14938) Flaky test org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest#testConnectorBoundary

[ https://issues.apache.org/jira/browse/KAFKA-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14938: -- Fix Version/s: 3.4.2 > Flaky test > org.apache.kafka.connect.integration.ExactlyOnceSourceInt

[jira] [Updated] (KAFKA-14938) Flaky test org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest#testConnectorBoundary

[ https://issues.apache.org/jira/browse/KAFKA-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14938: -- Fix Version/s: 3.5.2 > Flaky test > org.apache.kafka.connect.integration.ExactlyOnceSourceInt

[jira] [Updated] (KAFKA-15182) Normalize offsets before invoking SourceConnector::alterOffsets

[ https://issues.apache.org/jira/browse/KAFKA-15182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15182: -- Affects Version/s: 3.6.0 > Normalize offsets before invoking SourceConnector::alterOffsets > -

[jira] [Resolved] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14669. --- Fix Version/s: 3.6.0 Resolution: Done > Include MirrorMaker connector configurations

[jira] [Reopened] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-14669: --- > Include MirrorMaker connector configurations in docs > ---

[jira] [Commented] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744337#comment-17744337 ] Chris Egerton commented on KAFKA-14669: --- Reopening and marking as a blocker with f

[jira] [Updated] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14669: -- Priority: Blocker (was: Major) > Include MirrorMaker connector configurations in docs > -

[jira] [Updated] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15091: -- Fix Version/s: 3.5.2 > Javadocs for SourceTask::commit are incorrect > ---

[jira] [Updated] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15091: -- Fix Version/s: 3.4.2 > Javadocs for SourceTask::commit are incorrect > ---

[jira] [Updated] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15091: -- Fix Version/s: 3.3.3 > Javadocs for SourceTask::commit are incorrect > ---

[jira] [Updated] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14669: -- Priority: Major (was: Blocker) > Include MirrorMaker connector configurations in docs > -

[jira] [Resolved] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14669. --- Resolution: Done > Include MirrorMaker connector configurations in docs > --

[jira] [Updated] (KAFKA-15216) InternalSinkRecord::newRecord method ignores the headers argument

[ https://issues.apache.org/jira/browse/KAFKA-15216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15216: -- Fix Version/s: 3.5.2 > InternalSinkRecord::newRecord method ignores the headers argument > ---

[jira] [Updated] (KAFKA-15216) InternalSinkRecord::newRecord method ignores the headers argument

[ https://issues.apache.org/jira/browse/KAFKA-15216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15216: -- Fix Version/s: 3.4.2 > InternalSinkRecord::newRecord method ignores the headers argument > ---

[jira] [Updated] (KAFKA-15216) InternalSinkRecord::newRecord method ignores the headers argument

[ https://issues.apache.org/jira/browse/KAFKA-15216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15216: -- Fix Version/s: 3.3.3 > InternalSinkRecord::newRecord method ignores the headers argument > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13431. --- Fix Version/s: 3.6.0 Resolution: Done > Sink Connectors: Support topic-mutating SMTs

[jira] [Updated] (KAFKA-14112) Expose replication-offset-lag Mirror metric

[ https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14112: -- Labels: needs-kip (was: ) > Expose replication-offset-lag Mirror metric > ---

[jira] [Created] (KAFKA-15249) Verify Connect test-plugins artifact is published to Maven Central

Chris Egerton created KAFKA-15249: - Summary: Verify Connect test-plugins artifact is published to Maven Central Key: KAFKA-15249 URL: https://issues.apache.org/jira/browse/KAFKA-15249 Project: Kafka

[jira] [Commented] (KAFKA-15252) Task is not stopped until the poll interval passes in case of task restarting.

[ https://issues.apache.org/jira/browse/KAFKA-15252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748778#comment-17748778 ] Chris Egerton commented on KAFKA-15252: --- I think this is caused by KAFKA-15090. [~

[jira] [Comment Edited] (KAFKA-15252) Task is not stopped until the poll interval passes in case of task restarting.

[ https://issues.apache.org/jira/browse/KAFKA-15252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748778#comment-17748778 ] Chris Egerton edited comment on KAFKA-15252 at 7/29/23 3:12 AM: --

[jira] [Updated] (KAFKA-15249) Verify Connect test-plugins artifact is published to Maven Central

[ https://issues.apache.org/jira/browse/KAFKA-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15249: -- Component/s: KafkaConnect > Verify Connect test-plugins artifact is published to Maven Central

[jira] [Created] (KAFKA-15563) Provide informative error messages when Connect REST requests time out

Chris Egerton created KAFKA-15563: - Summary: Provide informative error messages when Connect REST requests time out Key: KAFKA-15563 URL: https://issues.apache.org/jira/browse/KAFKA-15563 Project: Kaf

[jira] [Updated] (KAFKA-15428) Cluster-wide dynamic log adjustments for Connect

[ https://issues.apache.org/jira/browse/KAFKA-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15428: -- Labels: kip (was: needs-kip) > Cluster-wide dynamic log adjustments for Connect > ---

[jira] [Resolved] (KAFKA-15249) Verify Connect test-plugins artifact is published to Maven Central

[ https://issues.apache.org/jira/browse/KAFKA-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15249. --- Resolution: Done > Verify Connect test-plugins artifact is published to Maven Central >

  1   2   3   4   5   6   7   8   9   10   >