[jira] [Updated] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12879: -- Affects Version/s: (was: 3.6.0) > Compatibility break in Admin.listOffsets() >

[jira] [Resolved] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12879. --- Resolution: Fixed > Compatibility break in Admin.listOffsets() >

[jira] [Updated] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12879: -- Fix Version/s: (was: 3.6.0) > Compatibility break in Admin.listOffsets() >

[jira] [Created] (KAFKA-15425) Compatibility break in Admin.listOffsets() (2)

Chris Egerton created KAFKA-15425: - Summary: Compatibility break in Admin.listOffsets() (2) Key: KAFKA-15425 URL: https://issues.apache.org/jira/browse/KAFKA-15425 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-14725) Improve cancellation semantics for connector tasks

[ https://issues.apache.org/jira/browse/KAFKA-14725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760775#comment-17760775 ] Chris Egerton commented on KAFKA-14725: --- [~yash.mayya] as part of work on KAFKA-15090 I've filed

[jira] [Comment Edited] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760531#comment-17760531 ] Chris Egerton edited comment on KAFKA-12879 at 8/30/23 7:27 PM: Looks

[jira] [Assigned] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12879: - Assignee: Chris Egerton > Compatibility break in Admin.listOffsets() >

[jira] [Updated] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12879: -- Fix Version/s: 3.6.0 > Compatibility break in Admin.listOffsets() >

[jira] [Commented] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760531#comment-17760531 ] Chris Egerton commented on KAFKA-12879: --- Looks like this behavior change has resurfaced in

[jira] [Updated] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12879: -- Priority: Blocker (was: Major) > Compatibility break in Admin.listOffsets() >

[jira] [Updated] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12879: -- Affects Version/s: 3.6.0 > Compatibility break in Admin.listOffsets() >

[jira] [Reopened] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-12879: --- Assignee: (was: Philip Nee) Reopening due to

[jira] [Assigned] (KAFKA-15416) Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound

[ https://issues.apache.org/jira/browse/KAFKA-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-15416: - Assignee: Chris Egerton > Flaky test

[jira] [Commented] (KAFKA-15416) Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound

[ https://issues.apache.org/jira/browse/KAFKA-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760187#comment-17760187 ] Chris Egerton commented on KAFKA-15416: --- Ran into a third kind of failure while running the test

[jira] [Commented] (KAFKA-15416) Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound

[ https://issues.apache.org/jira/browse/KAFKA-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760173#comment-17760173 ] Chris Egerton commented on KAFKA-15416: --- While prototyping a fix, I ran into a different failure.

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

[ https://issues.apache.org/jira/browse/KAFKA-13327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13327. --- Fix Version/s: 3.7.0 Resolution: Fixed > Preflight validations of connectors leads

[jira] [Created] (KAFKA-15416) Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound

Chris Egerton created KAFKA-15416: - Summary: Flaky test TopicAdminTest::retryEndOffsetsShouldRetryWhenTopicNotFound Key: KAFKA-15416 URL: https://issues.apache.org/jira/browse/KAFKA-15416 Project:

[jira] [Updated] (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:all-tabpanel ] Chris Egerton updated KAFKA-13329: -- Description: Users may specify a key and/or value converter class for their connector

[jira] [Commented] (KAFKA-15377) GET /connectors/{connector}/tasks-config endpoint exposes externalized secret values

[ https://issues.apache.org/jira/browse/KAFKA-15377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755993#comment-17755993 ] Chris Egerton commented on KAFKA-15377: --- I don't think a KIP is necessary, for the same reasons

[jira] [Commented] (KAFKA-15378) Rolling upgrade system tests are failing

[ https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755990#comment-17755990 ] Chris Egerton commented on KAFKA-15378: --- [~lbrutschy] the

[jira] [Updated] (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 updated KAFKA-15102: -- Fix Version/s: 3.3.3 (was: 3.3) > Mirror Maker 2 - KIP690 backward

[jira] [Updated] (KAFKA-15342) Considering upgrading to Mockito 5.4.1 or later

[ https://issues.apache.org/jira/browse/KAFKA-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15342: -- Description: We're currently stuck on Mockito 4.x.y because the 5.x.y line requires Java 11

[jira] [Updated] (KAFKA-15342) Considering upgrading to Mockito 5.4.1 or later

[ https://issues.apache.org/jira/browse/KAFKA-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15342: -- Description: We're currently stuck on Mockito 4.x.y because the 5.x.y line requires Java 11

[jira] [Created] (KAFKA-15342) Considering upgrading to Mockito 5.4.1 or later

Chris Egerton created KAFKA-15342: - Summary: Considering upgrading to Mockito 5.4.1 or later Key: KAFKA-15342 URL: https://issues.apache.org/jira/browse/KAFKA-15342 Project: Kafka Issue

[jira] [Resolved] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14682. --- Fix Version/s: 3.6.0 Resolution: Fixed > Unused stubbings are not reported by

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

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

[jira] [Commented] (KAFKA-15310) Add timezone configuration option in TimestampConverter from connectors

[ https://issues.apache.org/jira/browse/KAFKA-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751747#comment-17751747 ] Chris Egerton commented on KAFKA-15310: --- Hey [~romsouza], thanks for filing this ticket! Since the

[jira] [Updated] (KAFKA-15310) Add timezone configuration option in TimestampConverter from connectors

[ https://issues.apache.org/jira/browse/KAFKA-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15310: -- Labels: needs-kip (was: ) > Add timezone configuration option in TimestampConverter from

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

[ https://issues.apache.org/jira/browse/KAFKA-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-10334. --- Resolution: Duplicate > Transactions not working properly >

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

[ https://issues.apache.org/jira/browse/KAFKA-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751214#comment-17751214 ] Chris Egerton commented on KAFKA-15090: --- This is a tricky one. First off, although we're almost

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

[ https://issues.apache.org/jira/browse/KAFKA-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-15090: -- Description: Before [https://github.com/apache/kafka/pull/9669], in distributed mode, the

[jira] [Updated] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14682: -- Description: We've started using [strict

[jira] [Commented] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751178#comment-17751178 ] Chris Egerton commented on KAFKA-14682: --- I've taken a stab at an upstream Mockito fix. If it's

[jira] [Assigned] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14682: - Assignee: Chris Egerton (was: Christo Lolov) > Unused stubbings are not reported by

[jira] [Updated] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-14682: -- Description: We've started using [strict

[jira] [Commented] (KAFKA-14682) Unused stubbings are not reported by Mockito during CI builds

[ https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751125#comment-17751125 ] Chris Egerton commented on KAFKA-14682: --- [~christo_lolov] were you still planning on working on

[jira] [Commented] (KAFKA-10339) MirrorMaker2 Exactly-once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750338#comment-17750338 ] Chris Egerton commented on KAFKA-10339: --- Now that KAFKA-6080 has been resolved with

[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

[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=17748778#comment-17748778 ] Chris Egerton edited comment on KAFKA-15252 at 7/29/23 3:12 AM: I think

[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=17748778#comment-17748778 ] Chris Egerton commented on KAFKA-15252: --- I think this is caused by KAFKA-15090. [~nikita.krasnov]

[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] [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] [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-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] [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.5.2 > InternalSinkRecord::newRecord method ignores the headers argument >

[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-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] [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-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.5.2 > 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: Blocker (was: Major) > 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=17744337#comment-17744337 ] Chris Egerton commented on KAFKA-14669: --- Reopening and marking as a blocker with fix version 3.6.0

[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] [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] [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] [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 >

[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 >

[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 >

[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

[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] [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=17742034#comment-17742034 ] Chris Egerton commented on KAFKA-15059: --- [~divijvaidya] no; this was introduced by

[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] [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] [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] [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] [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=17740663#comment-17740663 ] Chris Egerton commented on KAFKA-15102: ---  [~omnia_h_ibrahim] I've assigned you this ticket so

[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=17740248#comment-17740248 ] Chris Egerton commented on KAFKA-15102: --- Thanks [~omnia_h_ibrahim], I'd love it if you could take

[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=17739635#comment-17739635 ] Chris Egerton commented on KAFKA-15127: --- Thanks Sagar! > Allow offsets to be reset at the same

[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=17739196#comment-17739196 ] Chris Egerton commented on KAFKA-15091: --- I think that was also discussed with KAFKA-5716. I

[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=17739146#comment-17739146 ] Chris Egerton commented on KAFKA-15102: --- [~omnia_h_ibrahim] Good call  we should definitely

[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] [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] [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=17739095#comment-17739095 ] Chris Egerton commented on KAFKA-15127: --- In that case, perhaps we can leave it unassigned and note

[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=17738740#comment-17738740 ] Chris Egerton commented on KAFKA-15113: --- [~yash.mayya] although it seems a little unlikely, I

[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=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

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

[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=17738591#comment-17738591 ] Chris Egerton commented on KAFKA-15068: --- Thanks for filing this [~hudeqi], good catch! I agree

[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=17738578#comment-17738578 ] Chris Egerton commented on KAFKA-15127: --- I think it's a little premature to start working on this.

[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-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=17736570#comment-17736570 ] Chris Egerton commented on KAFKA-4107: -- Wanted to update everyone here and let you all know that

[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] [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-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] [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=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

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

[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=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

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

[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

[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=17735711#comment-17735711 ] Chris Egerton commented on KAFKA-15059: --- Ah, thanks Viktor! > Exactly-once source tasks fail to

[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] [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:

[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

[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] [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

[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)

[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=17729709#comment-17729709 ] Chris Egerton commented on KAFKA-15059: --- On second thought, it may be unnecessary to check for a

[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=17729486#comment-17729486 ] Chris Egerton commented on KAFKA-14718: --- I think a 30-second startup timeout is a bit too

[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

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