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

2023-07-06 Thread Chris Egerton (Jira)
[ 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

2023-07-05 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15127) Allow offsets to be reset at the same time a connector is deleted.

2023-07-03 Thread Chris Egerton (Jira)
[ 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-15091) Javadocs for SourceTask::commit are incorrect

2023-06-30 Thread Chris Egerton (Jira)
[ 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-15102) Mirror Maker 2 - KIP690 backward compatibility

2023-06-30 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-13988) Mirrormaker 2 auto.offset.reset=latest not working

2023-06-30 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-13988) Mirrormaker 2 auto.offset.reset=latest not working

2023-06-30 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15127) Allow offsets to be reset at the same time a connector is deleted.

2023-06-30 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

2023-06-29 Thread Chris Egerton (Jira)
[ 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] [Comment Edited] (KAFKA-15102) Mirror Maker 2 - KIP690 backward compatibility

2023-06-29 Thread Chris Egerton (Jira)
[ 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-15102) Mirror Maker 2 - KIP690 backward compatibility

2023-06-29 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15068) Incorrect replication Latency may be calculated when the timestamp of the record is of type CREATE_TIME

2023-06-29 Thread Chris Egerton (Jira)
[ 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-15127) Allow offsets to be reset at the same time a connector is deleted.

2023-06-29 Thread Chris Egerton (Jira)
[ 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] [Assigned] (KAFKA-14972) Make KafkaConsumer usable in async runtimes

2023-06-26 Thread Chris Egerton (Jira)
[ 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-4107) Support offset reset capability in Kafka Connect

2023-06-23 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-4107) Support offset reset capability in Kafka Connect

2023-06-23 Thread Chris Egerton (Jira)
[ 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] [Resolved] (KAFKA-4107) Support offset reset capability in Kafka Connect

2023-06-23 Thread Chris Egerton (Jira)
[ 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-14784) Implement connector offset reset REST API

2023-06-23 Thread Chris Egerton (Jira)
[ 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] [Comment Edited] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

2023-06-23 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

2023-06-23 Thread Chris Egerton (Jira)
[ 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-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

2023-06-22 Thread Chris Egerton (Jira)
[ 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-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

2023-06-22 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

2023-06-22 Thread Chris Egerton (Jira)
[ 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-15059) Exactly-once source tasks fail to start during pending rebalances

2023-06-21 Thread Chris Egerton (Jira)
[ 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] [Assigned] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

2023-06-20 Thread Chris Egerton (Jira)
[ 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] [Created] (KAFKA-15091) Javadocs for SourceTask::commit are incorrect

2023-06-14 Thread Chris Egerton (Jira)
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] [Created] (KAFKA-15090) Source tasks are no longer stopped on a separate thread

2023-06-14 Thread Chris Egerton (Jira)
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] [Updated] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

2023-06-07 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

2023-06-07 Thread Chris Egerton (Jira)
[ 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

2023-06-07 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

2023-06-06 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-14718) Flaky DedicatedMirrorIntegrationTest test suite

2023-06-05 Thread Chris Egerton (Jira)
[ 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] [Created] (KAFKA-15059) Exactly-once source tasks fail to start during pending rebalances

2023-06-05 Thread Chris Egerton (Jira)
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] [Assigned] (KAFKA-15051) docs: add missing connector plugin endpoint to documentation

2023-06-05 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

2023-06-05 Thread Chris Egerton (Jira)
[ 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] [Resolved] (KAFKA-15012) JsonConverter fails when there are leading Zeros in a field

2023-06-02 Thread Chris Egerton (Jira)
[ 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] [Resolved] (KAFKA-14863) Plugins which do not have a valid no-args constructor are visible in the REST API

2023-06-02 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15012) JsonConverter fails when there are leading Zeros in a field

2023-05-30 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-15018) Potential tombstone offsets corruption for exactly-once source connectors

2023-05-23 Thread Chris Egerton (Jira)
[ 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] [Created] (KAFKA-15018) Potential tombstone offsets corruption for exactly-once source connectors

2023-05-23 Thread Chris Egerton (Jira)
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] [Assigned] (KAFKA-14980) MirrorMaker consumers don't get configs prefixed with source.cluster

2023-05-12 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-14978) ExactlyOnceWorkerSourceTask does not remove parent metrics

2023-05-11 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-14842) MirrorCheckpointTask can reduce the rpc calls of "listConsumerGroupOffsets(group)" of irrelevant groups at each poll

2023-05-02 Thread Chris Egerton (Jira)
[ 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-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

2023-05-02 Thread Chris Egerton (Jira)
[ 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-14666) MM2 should translate consumer group offsets behind replication flow

2023-05-02 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

2023-05-02 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-14876) Public documentation for new Kafka Connect offset management REST APIs in 3.5

2023-05-01 Thread Chris Egerton (Jira)
[ 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

2023-04-26 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-14666) MM2 should translate consumer group offsets behind replication flow

2023-04-26 Thread Chris Egerton (Jira)
[ 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

2023-04-25 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-14746) Throwing in Connector.taskConfigs in distributed mode generates a lot of logs

2023-04-11 Thread Chris Egerton (Jira)
[ 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] [Resolved] (KAFKA-14783) Implement new STOPPED state for connectors

2023-04-11 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-14420) MirrorMaker should not clear filtered configs on target topics

2023-04-10 Thread Chris Egerton (Jira)
[ 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] [Commented] (KAFKA-14420) MirrorMaker should not clear filtered configs on target topics

2023-04-10 Thread Chris Egerton (Jira)
[ 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-14873) Pluggable storage for Kafka Connect internal topics

2023-04-02 Thread Chris Egerton (Jira)
[ 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] [Updated] (KAFKA-14873) Pluggable storage for Kafka Connect internal topics

2023-04-02 Thread Chris Egerton (Jira)
[ 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] [Resolved] (KAFKA-14838) MM2 Worker/Connector/Task clients should specify client ID based on flow and role

2023-03-31 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14838. --- Resolution: Done > MM2 Worker/Connector/Task clients should specify client ID based on flow

[jira] [Reopened] (KAFKA-14838) MM2 Worker/Connector/Task clients should specify client ID based on flow and role

2023-03-31 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-14838: --- > MM2 Worker/Connector/Task clients should specify client ID based on flow and > role > ---

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

2023-03-29 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14858 ] Chris Egerton deleted comment on KAFKA-14858: --- was (Author: chrisegerton): These tickets cover bugs with the same scenario but in different modes (standalone vs. distributed). > Standalon

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

2023-03-29 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706676#comment-17706676 ] Chris Egerton commented on KAFKA-14858: --- These tickets cover bugs with the same sc

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

2023-03-29 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14746: -- Summary: Throwing in Connector.taskConfigs in distributed mode generates a lot of logs (was:

[jira] [Updated] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14843: -- Fix Version/s: 3.2.4 > Connector plugins config endpoint does not include Common configs > ---

[jira] [Updated] (KAFKA-14645) Plugin classloader not used when retrieving connector plugin config defs via REST API

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14645: -- Fix Version/s: 3.2.4 > Plugin classloader not used when retrieving connector plugin config def

[jira] [Updated] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14843: -- Fix Version/s: 3.3.3 > Connector plugins config endpoint does not include Common configs > ---

[jira] [Updated] (KAFKA-14645) Plugin classloader not used when retrieving connector plugin config defs via REST API

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14645: -- Fix Version/s: 3.3.3 > Plugin classloader not used when retrieving connector plugin config def

[jira] [Updated] (KAFKA-14645) Plugin classloader not used when retrieving connector plugin config defs via REST API

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14645: -- Fix Version/s: 3.4.1 > Plugin classloader not used when retrieving connector plugin config def

[jira] [Updated] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14843: -- Fix Version/s: 3.4.1 > Connector plugins config endpoint does not include Common configs > ---

[jira] [Resolved] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14843. --- Fix Version/s: 3.5.0 Resolution: Fixed > Connector plugins config endpoint does not i

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

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14842. --- Fix Version/s: 3.5.0 Resolution: Done > MirrorCheckpointTask can reduce the rpc calls

[jira] [Comment Edited] (KAFKA-14746) Throwing in Connector.taskConfigs generates a lot of logs

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705974#comment-17705974 ] Chris Egerton edited comment on KAFKA-14746 at 3/28/23 12:42 PM: -

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

2023-03-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705974#comment-17705974 ] Chris Egerton commented on KAFKA-14746: --- [~mimaison] do you think it's worth consi

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

2023-03-28 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14858: - Summary: Standalone herder does not handle exceptions thrown from connector taskConfigs method Key: KAFKA-14858 URL: https://issues.apache.org/jira/browse/KAFKA-14858

[jira] [Updated] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14843: -- Affects Version/s: 3.3.2 3.3.1 3.2.3

[jira] [Updated] (KAFKA-14843) Connector plugins config endpoint does not include Common configs

2023-03-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14843: -- Description: Connector plugins GET config endpoint introduced in [https://cwiki.apache.org/co

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

2023-03-27 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14855: - Summary: Harden integration testing logic for asserting that a connector is deleted Key: KAFKA-14855 URL: https://issues.apache.org/jira/browse/KAFKA-14855 Project:

[jira] [Commented] (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 synchrono

2023-03-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704244#comment-17704244 ] Chris Egerton commented on KAFKA-14837: --- [~hudeqi] have you tried adjusting the {{

[jira] [Resolved] (KAFKA-14814) Skip restart of connectors when redundant resume request is made

2023-03-23 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14814. --- Fix Version/s: 3.5.0 Resolution: Fixed > Skip restart of connectors when redundant re

[jira] [Assigned] (KAFKA-12694) Specifying a struct-based defaultValue on a SchemaBuilder causes a DataException

2023-03-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12694: - Assignee: Chris Egerton > Specifying a struct-based defaultValue on a SchemaBuilder cau

[jira] [Assigned] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder

2023-03-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-3910: Assignee: Chris Egerton (was: Shikhar Bhushan) > Cyclic schema support in ConnectSchema a

[jira] [Resolved] (KAFKA-14797) MM2 does not emit offset syncs when conservative translation logic exceeds positive max.offset.lag

2023-03-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14797. --- Resolution: Fixed > MM2 does not emit offset syncs when conservative translation logic excee

[jira] [Resolved] (KAFKA-14816) Connect loading SSL configs when contacting non-HTTPS URLs

2023-03-20 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14816. --- Reviewer: Justine Olshan Resolution: Fixed > Connect loading SSL configs when contacti

[jira] [Updated] (KAFKA-14816) Connect loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Summary: Connect loading SSL configs when contacting non-HTTPS URLs (was: Connect Http Client

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Affects Version/s: 3.4.0 > Connect Http Client loading SSL configs when contacting non-HTTPS U

[jira] [Assigned] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14816: - Assignee: Chris Egerton > Connect Http Client loading SSL configs when contacting non-H

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Fix Version/s: 3.5.0 3.4.1 > Connect Http Client loading SSL configs when c

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Priority: Blocker (was: Trivial) > Connect Http Client loading SSL configs when contacting no

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Description: Due to changes made here: [https://github.com/apache/kafka/pull/12828] Connect no

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Description: Due to changes made here: [https://github.com/apache/kafka/pull/12828] Connect no

[jira] [Commented] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701915#comment-17701915 ] Chris Egerton commented on KAFKA-14816: --- Thanks [~imcdo] for filing this. I believ

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Description: Due to changes made here: [https://github.com/apache/kafka/pull/12828] Connect no

[jira] [Updated] (KAFKA-14816) Connect Http Client loading SSL configs when contacting non-HTTPS URLs

2023-03-17 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14816: -- Summary: Connect Http Client loading SSL configs when contacting non-HTTPS URLs (was: Connect

[jira] [Assigned] (KAFKA-14814) Skip restart of connectors when redundant resume request is made

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14814: - Assignee: (was: Chris Egerton) > Skip restart of connectors when redundant resume r

[jira] [Updated] (KAFKA-14814) Skip restart of connectors when redundant resume request is made

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14814: -- Priority: Minor (was: Major) > Skip restart of connectors when redundant resume request is ma

[jira] [Created] (KAFKA-14814) Skip restart of connectors when redundant resume request is made

2023-03-16 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14814: - Summary: Skip restart of connectors when redundant resume request is made Key: KAFKA-14814 URL: https://issues.apache.org/jira/browse/KAFKA-14814 Project: Kafka

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

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701271#comment-17701271 ] Chris Egerton commented on KAFKA-14666: --- This is touched on more extensively in a

[jira] [Updated] (KAFKA-14809) Connect incorrectly logs that no records were produced by source tasks

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14809: -- Fix Version/s: 3.2.4 3.1.3 3.0.3 3.5.0

[jira] [Updated] (KAFKA-14809) Connect incorrectly logs that no records were produced by source tasks

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14809: -- Affects Version/s: 3.3.2 3.3.1 3.2.3

[jira] [Resolved] (KAFKA-14809) Connect incorrectly logs that no records were produced by source tasks

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14809. --- Resolution: Fixed > Connect incorrectly logs that no records were produced by source tasks >

[jira] [Commented] (KAFKA-14809) Connect incorrectly logs that no records were produced by source tasks

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701151#comment-17701151 ] Chris Egerton commented on KAFKA-14809: --- This is arguably the root cause of KAFKA-

[jira] [Updated] (KAFKA-14799) Source tasks fail if connector attempts to abort empty transaction

2023-03-16 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14799: -- Fix Version/s: 3.4.1 3.3.3 > Source tasks fail if connector attempts to abo

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