[jira] [Commented] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817522#comment-17817522 ] Greg Harris commented on KAFKA-15841: - Hi [~henriquemota]! Can you share more detai

[jira] [Updated] (KAFKA-16145) Windows Kafka Shutdown

[ https://issues.apache.org/jira/browse/KAFKA-16145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16145: Component/s: core (was: connect) > Windows Kafka Shutdown > -

[jira] [Updated] (KAFKA-9790) Wrong metric bean name for connect worker metrics

[ https://issues.apache.org/jira/browse/KAFKA-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-9790: --- Component/s: connect > Wrong metric bean name for connect worker metrics > --

[jira] [Resolved] (KAFKA-10735) Kafka producer producing corrupted avro values when confluent cluster is recreated and producer application is not restarted

[ https://issues.apache.org/jira/browse/KAFKA-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10735. - Resolution: Cannot Reproduce Hi, since this doesn't contain any Apache Kafka code, and doesn't p

[jira] [Updated] (KAFKA-12309) The revocation algorithm produces uneven distributions

[ https://issues.apache.org/jira/browse/KAFKA-12309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-12309: Component/s: connect > The revocation algorithm produces uneven distributions > --

[jira] [Updated] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration

[ https://issues.apache.org/jira/browse/KAFKA-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-10719: Component/s: mirrormaker > MirrorMaker2 fails to update its runtime configuration > --

[jira] [Resolved] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration

[ https://issues.apache.org/jira/browse/KAFKA-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10719. - Fix Version/s: 3.7.0 3.6.2 Resolution: Fixed > MirrorMaker2 fails to u

[jira] [Updated] (KAFKA-10266) Fix connector configs in docs to mention the correct default value inherited from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-10266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-10266: Component/s: connect > Fix connector configs in docs to mention the correct default value inherite

[jira] [Updated] (KAFKA-14773) Make MirrorMaker startup synchronous

[ https://issues.apache.org/jira/browse/KAFKA-14773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-14773: Component/s: mirrormaker > Make MirrorMaker startup synchronous >

[jira] [Updated] (KAFKA-13656) Connect Transforms support for nested structures

[ https://issues.apache.org/jira/browse/KAFKA-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-13656: Component/s: connect > Connect Transforms support for nested structures >

[jira] [Updated] (KAFKA-14652) Improve MM2 logging by adding the flow information to the context (KIP-916)

[ https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-14652: Component/s: mirrormaker > Improve MM2 logging by adding the flow information to the context (KIP-

[jira] [Updated] (KAFKA-15892) Flaky test: testAlterSinkConnectorOffsets – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15892: Component/s: connect > Flaky test: testAlterSinkConnectorOffsets – > org.apache.kafka.connect.int

[jira] [Updated] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15914: Component/s: connect > Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - > Of

[jira] [Updated] (KAFKA-14823) Clean up ConfigProvider API

[ https://issues.apache.org/jira/browse/KAFKA-14823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-14823: Component/s: connect > Clean up ConfigProvider API > --- > >

[jira] [Updated] (KAFKA-15891) Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15891: Component/s: connect > Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – > org

[jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets

[ https://issues.apache.org/jira/browse/KAFKA-15918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15918: Component/s: connect > Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets >

[jira] [Updated] (KAFKA-13756) Connect validate endpoint should return proper response for invalid connector class

[ https://issues.apache.org/jira/browse/KAFKA-13756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-13756: Component/s: connect > Connect validate endpoint should return proper response for invalid connect

[jira] [Updated] (KAFKA-8314) Managing the doc field in case of schema projection - kafka connect

[ https://issues.apache.org/jira/browse/KAFKA-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-8314: --- Component/s: connect > Managing the doc field in case of schema projection - kafka connect >

[jira] [Comment Edited] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817494#comment-17817494 ] Greg Harris edited comment on KAFKA-13505 at 2/14/24 7:01 PM:

[jira] [Commented] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817494#comment-17817494 ] Greg Harris commented on KAFKA-13505: - Hi [~twbecker] Thanks for bringing this issue

[jira] [Created] (KAFKA-16257) SchemaProjector should be extensible to logical types

Greg Harris created KAFKA-16257: --- Summary: SchemaProjector should be extensible to logical types Key: KAFKA-16257 URL: https://issues.apache.org/jira/browse/KAFKA-16257 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-9376. Fix Version/s: 2.5.0 Resolution: Fixed > Plugin class loader not found using MM2 > -

[jira] [Commented] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816808#comment-17816808 ] Greg Harris commented on KAFKA-9376: Closing the loop here, this was a log message wh

[jira] [Commented] (KAFKA-9070) Kafka Connect - Get the wrong offset value comes from Kafka Connect after increase the number of offset storage topic partition to 3

[ https://issues.apache.org/jira/browse/KAFKA-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816806#comment-17816806 ] Greg Harris commented on KAFKA-9070: Adding partitions to a topic is generally an uns

[jira] [Resolved] (KAFKA-7217) Loading dynamic topic data into kafka connector sink using regex

[ https://issues.apache.org/jira/browse/KAFKA-7217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-7217. Fix Version/s: 1.1.0 Resolution: Fixed > Loading dynamic topic data into kafka connector sin

[jira] [Resolved] (KAFKA-6340) Support of transactions in KafkaConnect

[ https://issues.apache.org/jira/browse/KAFKA-6340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-6340. Fix Version/s: 3.3.0 Resolution: Fixed > Support of transactions in KafkaConnect > -

[jira] [Resolved] (KAFKA-4961) Mirrormaker crash with org.apache.kafka.common.protocol.types.SchemaException

[ https://issues.apache.org/jira/browse/KAFKA-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-4961. Resolution: Won't Fix > Mirrormaker crash with org.apache.kafka.common.protocol.types.SchemaExcepti

[jira] [Resolved] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-3213. Fix Version/s: 3.5.0 Resolution: Fixed > [CONNECT] It looks like we are not backing off prop

[jira] [Commented] (KAFKA-13338) kafka upgrade 6.1.1 asking to change log.cleanup.policy from delete to compact

[ https://issues.apache.org/jira/browse/KAFKA-13338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816800#comment-17816800 ] Greg Harris commented on KAFKA-13338: - Apache Kafka does not have 5.x or 6.x release

[jira] [Resolved] (KAFKA-13338) kafka upgrade 6.1.1 asking to change log.cleanup.policy from delete to compact

[ https://issues.apache.org/jira/browse/KAFKA-13338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-13338. - Resolution: Invalid > kafka upgrade 6.1.1 asking to change log.cleanup.policy from delete to com

[jira] [Resolved] (KAFKA-13163) MySQL Sink Connector - JsonConverter - DataException: Unknown schema type: null

[ https://issues.apache.org/jira/browse/KAFKA-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-13163. - Resolution: Invalid > MySQL Sink Connector - JsonConverter - DataException: Unknown schema type:

[jira] [Updated] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors

[ https://issues.apache.org/jira/browse/KAFKA-16068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16068: Labels: newbie++ (was: ) > Use TestPlugins in ConnectorValidationIntegrationTest to silence plugi

[jira] [Updated] (KAFKA-14919) MM2 ForwardingAdmin tests should not conflate admin operations

[ https://issues.apache.org/jira/browse/KAFKA-14919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-14919: Labels: newbie (was: ) > MM2 ForwardingAdmin tests should not conflate admin operations > ---

[jira] [Updated] (KAFKA-15349) ducker-ak should fail fast when gradlew systemTestLibs fails

[ https://issues.apache.org/jira/browse/KAFKA-15349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15349: Labels: newbie++ (was: ) > ducker-ak should fail fast when gradlew systemTestLibs fails > ---

[jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking

[ https://issues.apache.org/jira/browse/KAFKA-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816791#comment-17816791 ] Greg Harris commented on KAFKA-16084: - Hi [~high.lee] and [~ardada2468] Thanks for v

[jira] [Created] (KAFKA-16242) Mark flaky tests as integration tests

Greg Harris created KAFKA-16242: --- Summary: Mark flaky tests as integration tests Key: KAFKA-16242 URL: https://issues.apache.org/jira/browse/KAFKA-16242 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-16225) Flaky test suite LogDirFailureTest

Greg Harris created KAFKA-16225: --- Summary: Flaky test suite LogDirFailureTest Key: KAFKA-16225 URL: https://issues.apache.org/jira/browse/KAFKA-16225 Project: Kafka Issue Type: Bug Co

[jira] [Commented] (KAFKA-16193) Storing mm2 topics on source side

[ https://issues.apache.org/jira/browse/KAFKA-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811003#comment-17811003 ] Greg Harris commented on KAFKA-16193: - Hi [~filatov_m] I believe this is a supported

[jira] [Assigned] (KAFKA-15343) Fix MirrorConnectIntegrationTests causing ci build failures.

[ https://issues.apache.org/jira/browse/KAFKA-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-15343: --- Assignee: Greg Harris > Fix MirrorConnectIntegrationTests causing ci build failures. >

[jira] [Commented] (KAFKA-15343) Fix MirrorConnectIntegrationTests causing ci build failures.

[ https://issues.apache.org/jira/browse/KAFKA-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810124#comment-17810124 ] Greg Harris commented on KAFKA-15343: - I opened an issue in Gradle for this bug, sin

[jira] [Resolved] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter

[ https://issues.apache.org/jira/browse/KAFKA-16166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16166. - Fix Version/s: 3.8.0 Resolution: Fixed > Generify RetryWithToleranceOperator and ErrorRep

[jira] [Commented] (KAFKA-15826) WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808804#comment-17808804 ] Greg Harris commented on KAFKA-15826: - The BlockingConnectorTest which was leaking t

[jira] [Assigned] (KAFKA-15826) WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-15826: --- Assignee: (was: Greg Harris) > WorkerSinkTask leaks Consumer if plugin start or stop bl

[jira] [Created] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter

Greg Harris created KAFKA-16166: --- Summary: Generify RetryWithToleranceOperator and ErrorReporter Key: KAFKA-16166 URL: https://issues.apache.org/jira/browse/KAFKA-16166 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race

[ https://issues.apache.org/jira/browse/KAFKA-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16087. - Fix Version/s: 3.8.0 Resolution: Fixed > Tasks dropping incorrect records when errors.tol

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-5863: --- Fix Version/s: 3.8.0 > Potential null dereference in DistributedHerder#reconfigureConnector() > -

[jira] [Resolved] (KAFKA-15834) Subscribing to non-existent topic blocks StreamThread from stopping

[ https://issues.apache.org/jira/browse/KAFKA-15834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15834. - Resolution: Fixed > Subscribing to non-existent topic blocks StreamThread from stopping > --

[jira] [Updated] (KAFKA-15834) Subscribing to non-existent topic blocks StreamThread from stopping

[ https://issues.apache.org/jira/browse/KAFKA-15834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15834: Fix Version/s: 3.8.0 > Subscribing to non-existent topic blocks StreamThread from stopping > -

[jira] [Resolved] (KAFKA-16051) Deadlock on connector initialization

[ https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16051. - Fix Version/s: 3.8.0 Resolution: Fixed > Deadlock on connector initialization > -

[jira] [Resolved] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15816. - Fix Version/s: 3.8.0 Resolution: Fixed > Typos in tests leak network sockets > --

[jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15816: Description: There are a few tests which leak network sockets due to small typos in the tests the

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805849#comment-17805849 ] Greg Harris commented on KAFKA-8115: We doubled the timeout for this test in KAFKA-15

[jira] [Resolved] (KAFKA-15760) org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated is flaky

[ https://issues.apache.org/jira/browse/KAFKA-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15760. - Fix Version/s: 3.8.0 Assignee: David Mao Resolution: Fixed > org.apache.kafka.tr

[jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking

[ https://issues.apache.org/jira/browse/KAFKA-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804460#comment-17804460 ] Greg Harris commented on KAFKA-16084: - [~cegerton] I agree. In this case, none of t

[jira] [Updated] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race

[ https://issues.apache.org/jira/browse/KAFKA-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16087: Affects Version/s: 3.2.0 2.6.0 > Tasks dropping incorrect records when erro

[jira] [Updated] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race

[ https://issues.apache.org/jira/browse/KAFKA-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16087: Description: The ErrantRecordReporter introduced in KIP-610 (2.6.0) allows sink connectors to pus

[jira] [Updated] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race

[ https://issues.apache.org/jira/browse/KAFKA-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16087: Summary: Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchrono

[jira] [Updated] (KAFKA-16087) Sink connector dropping incorrect record when ErrantRecordReporter used asynchronously

[ https://issues.apache.org/jira/browse/KAFKA-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16087: Description: The ErrantRecordReporter introduced in KIP-610 allows sink connectors to push record

[jira] [Created] (KAFKA-16087) Sink connector dropping incorrect record when ErrantRecordReporter used asynchronously

Greg Harris created KAFKA-16087: --- Summary: Sink connector dropping incorrect record when ErrantRecordReporter used asynchronously Key: KAFKA-16087 URL: https://issues.apache.org/jira/browse/KAFKA-16087

[jira] [Created] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking

Greg Harris created KAFKA-16084: --- Summary: Simplify and deduplicate StandaloneHerderTest mocking Key: KAFKA-16084 URL: https://issues.apache.org/jira/browse/KAFKA-16084 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-16051) Deadlock on connector initialization

[ https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801909#comment-17801909 ] Greg Harris commented on KAFKA-16051: - I added permissions for you on Jira, and assi

[jira] [Assigned] (KAFKA-16051) Deadlock on connector initialization

[ https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-16051: --- Assignee: Octavian Ciubotaru > Deadlock on connector initialization > -

[jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15816: Description: There are a few tests which leak network sockets due to small typos in the tests the

[jira] [Created] (KAFKA-16069) Source Tasks re-transform records after Retriable exceptions

Greg Harris created KAFKA-16069: --- Summary: Source Tasks re-transform records after Retriable exceptions Key: KAFKA-16069 URL: https://issues.apache.org/jira/browse/KAFKA-16069 Project: Kafka I

[jira] [Created] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors

Greg Harris created KAFKA-16068: --- Summary: Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors Key: KAFKA-16068 URL: https://issues.apache.org/jira/browse/KAFKA-16068

[jira] [Updated] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors

[ https://issues.apache.org/jira/browse/KAFKA-16068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16068: Description: The ConnectorValidationIntegrationTest creates test plugins, some with erroneous beh

[jira] [Commented] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector

[ https://issues.apache.org/jira/browse/KAFKA-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800554#comment-17800554 ] Greg Harris commented on KAFKA-16047: - I found this code-review comment thread about

[jira] [Updated] (KAFKA-15996) json serializer too slow

[ https://issues.apache.org/jira/browse/KAFKA-15996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15996: Component/s: KafkaConnect (was: connect) > json serializer too slow > ---

[jira] [Updated] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector

[ https://issues.apache.org/jira/browse/KAFKA-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16047: Component/s: KafkaConnect (was: connect) > Source connector with EOS enabled

[jira] [Updated] (KAFKA-15912) Parallelize conversion and transformation steps in Connect

[ https://issues.apache.org/jira/browse/KAFKA-15912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15912: Component/s: KafkaConnect (was: connect) > Parallelize conversion and transfo

[jira] [Updated] (KAFKA-16041) Replace Afterburn module with Blackbird

[ https://issues.apache.org/jira/browse/KAFKA-16041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16041: Component/s: KafkaConnect (was: connect) > Replace Afterburn module with Blac

[jira] [Updated] (KAFKA-15976) KIP-995: Allow users to specify initial offsets while creating connectors

[ https://issues.apache.org/jira/browse/KAFKA-15976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15976: Component/s: KafkaConnect (was: connect) > KIP-995: Allow users to specify in

[jira] [Updated] (KAFKA-16051) Deadlock on connector initialization

[ https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-16051: Component/s: KafkaConnect (was: connect) > Deadlock on connector initializati

[jira] [Updated] (KAFKA-15888) DistributedHerder log context should not use the same client ID for each Connect worker by default

[ https://issues.apache.org/jira/browse/KAFKA-15888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15888: Component/s: (was: connect) > DistributedHerder log context should not use the same client ID

[jira] [Updated] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15841: Component/s: KafkaConnect (was: connect) > Add Support for Topic-Level Partit

[jira] [Updated] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15524: Component/s: KafkaConnect (was: connect) > Flaky test > org.apache.kafka.con

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

[ https://issues.apache.org/jira/browse/KAFKA-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15570: Component/s: (was: connect) > Add unit tests for MemoryConfigBackingStore > --

[jira] [Updated] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account

[ https://issues.apache.org/jira/browse/KAFKA-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15407: Component/s: KafkaConnect (was: connect) > Not able to connect to kafka from

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

[ https://issues.apache.org/jira/browse/KAFKA-15470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15470: Component/s: (was: connect) > Allow creating connectors in a stopped state > -

[jira] [Updated] (KAFKA-15339) Transient I/O error happening in appending records could lead to the halt of whole cluster

[ https://issues.apache.org/jira/browse/KAFKA-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15339: Component/s: KafkaConnect (was: connect) > Transient I/O error happening in a

[jira] [Updated] (KAFKA-15680) Partition-Count is not getting updated Correctly in the Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-15680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15680: Component/s: KafkaConnect (was: connect) > Partition-Count is not getting upd

[jira] [Updated] (KAFKA-15855) RFC 9266: Channel Bindings for TLS 1.3 support | SCRAM-SHA-*-PLUS variants

[ https://issues.apache.org/jira/browse/KAFKA-15855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15855: Component/s: KafkaConnect (was: connect) > RFC 9266: Channel Bindings for TLS

[jira] [Updated] (KAFKA-15335) Support custom SSL configuration for Kafka Connect RestServer

[ https://issues.apache.org/jira/browse/KAFKA-15335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15335: Component/s: KafkaConnect (was: connect) > Support custom SSL configuration f

[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 ] Greg Harris updated KAFKA-15310: Component/s: KafkaConnect (was: connect) > Add timezone configuration option

[jira] [Updated] (KAFKA-15208) Upgrade Jackson dependencies to version 2.16.0

[ https://issues.apache.org/jira/browse/KAFKA-15208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15208: Component/s: KafkaConnect (was: connect) > Upgrade Jackson dependencies to ve

[jira] [Updated] (KAFKA-15203) Remove dependency on Reflections

[ https://issues.apache.org/jira/browse/KAFKA-15203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15203: Component/s: KafkaConnect (was: connect) > Remove dependency on Reflections

[jira] [Updated] (KAFKA-15333) Flaky build failure throwing Connect Exception: Could not connect to server....

[ https://issues.apache.org/jira/browse/KAFKA-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15333: Component/s: KafkaConnect (was: connect) > Flaky build failure throwing Conne

[jira] [Commented] (KAFKA-16051) Deadlock on connector initialization

[ https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800522#comment-17800522 ] Greg Harris commented on KAFKA-16051: - Hi [~developster] Thanks for the report! that

[jira] [Commented] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector

[ https://issues.apache.org/jira/browse/KAFKA-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800520#comment-17800520 ] Greg Harris commented on KAFKA-16047: - It appears that the transaction timeout is us

[jira] [Resolved] (KAFKA-15111) Correction kafka examples

[ https://issues.apache.org/jira/browse/KAFKA-15111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-15111. - Resolution: Duplicate > Correction kafka examples > - > >

[jira] [Updated] (KAFKA-15111) Correction kafka examples

[ https://issues.apache.org/jira/browse/KAFKA-15111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15111: Fix Version/s: 3.6.0 (was: 3.7.0) > Correction kafka examples > ---

[jira] [Commented] (KAFKA-15372) MM2 rolling restart can drop configuration changes silently

[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795958#comment-17795958 ] Greg Harris commented on KAFKA-15372: - This is now set to release for 3.7 and 3.6, b

[jira] [Updated] (KAFKA-15372) MM2 rolling restart can drop configuration changes silently

[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15372: Fix Version/s: 3.6.2 > MM2 rolling restart can drop configuration changes silently > -

[jira] [Assigned] (KAFKA-15906) Emit offset syncs more often than offset.lag.max for low-throughput/finite partitions

[ https://issues.apache.org/jira/browse/KAFKA-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reassigned KAFKA-15906: --- Assignee: Greg Harris > Emit offset syncs more often than offset.lag.max for low-throughput

[jira] [Commented] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete

[ https://issues.apache.org/jira/browse/KAFKA-15985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794433#comment-17794433 ] Greg Harris commented on KAFKA-15985: - Hi [~Reamer] The default value of `offset.lag

[jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15816: Description: There are a few tests which leak network sockets due to small typos in the tests the

[jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15816: Description: There are a few tests which leak network sockets due to small typos in the tests the

[jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets

[ https://issues.apache.org/jira/browse/KAFKA-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15816: Description: There are a few tests which leak network sockets due to small typos in the tests the

[jira] [Commented] (KAFKA-15912) Parallelize conversion and transformation steps in Connect

[ https://issues.apache.org/jira/browse/KAFKA-15912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790672#comment-17790672 ] Greg Harris commented on KAFKA-15912: - Hey [~mimaison] thanks for the ticket. I've o

[jira] [Updated] (KAFKA-15372) MM2 rolling restart can drop configuration changes silently

[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris updated KAFKA-15372: Fix Version/s: 3.7.0 > MM2 rolling restart can drop configuration changes silently > -

<    1   2   3   4   5   6   7   8   >