[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-07 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933223#comment-17933223 ] Daniel Urban commented on KAFKA-18871: -- [~showuon]  The controller logs are already

[jira] [Updated] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-07 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18871: - Attachment: zookeeper_logs.zip > KRaft migration rollback causes downtime >

[jira] [Updated] (KAFKA-18929) Log a warning when a time retention based segment has a future timestamp

2025-03-06 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18929: - Description: Time based retention can be blocked when a producer sends a future timestamp in a

[jira] [Created] (KAFKA-18929) Log a warning when a time retention based segment has a future timestamp

2025-03-06 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-18929: Summary: Log a warning when a time retention based segment has a future timestamp Key: KAFKA-18929 URL: https://issues.apache.org/jira/browse/KAFKA-18929 Project: Kaf

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932189#comment-17932189 ] Daniel Urban commented on KAFKA-18871: -- [~showuon] Thank you for the analysis! In t

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-03 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932017#comment-17932017 ] Daniel Urban commented on KAFKA-18871: -- [~showuon] Managed to reproduce with debug

[jira] [Updated] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-03 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18871: - Attachment: kraft-rollback-kafka-default-pool-0.zip > KRaft migration rollback causes downtime >

[jira] [Updated] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-03 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18871: - Attachment: controller_logs.zip kraft-rollback-kafka-default-pool-1.zip

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-03-03 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931936#comment-17931936 ] Daniel Urban commented on KAFKA-18871: -- [~showuon] Thanks for looking into it - wil

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931194#comment-17931194 ] Daniel Urban commented on KAFKA-18871: -- [~ppatierno] Oh, apologies, I attached the

[jira] [Updated] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18871: - Attachment: cluster-operator.log.zip > KRaft migration rollback causes downtime > --

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931180#comment-17931180 ] Daniel Urban commented on KAFKA-18871: -- One more correction, sorry for the confusio

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931172#comment-17931172 ] Daniel Urban commented on KAFKA-18871: -- [~ppatierno] I agree that this issue does n

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931133#comment-17931133 ] Daniel Urban commented on KAFKA-18871: -- [~ppatierno] Thanks for checking the logs.

[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931121#comment-17931121 ] Daniel Urban commented on KAFKA-18871: -- [~showuon] Thank you for checking this! I

[jira] [Updated] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-18871: - Attachment: kraft-rollback-bug.zip > KRaft migration rollback causes downtime >

[jira] [Created] (KAFKA-18871) KRaft migration rollback causes downtime

2025-02-26 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-18871: Summary: KRaft migration rollback causes downtime Key: KAFKA-18871 URL: https://issues.apache.org/jira/browse/KAFKA-18871 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2025-02-12 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926362#comment-17926362 ] Daniel Urban commented on KAFKA-17719: -- [~henkvdyk] The connector configs topic mus

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-12-19 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907051#comment-17907051 ] Daniel Urban commented on KAFKA-17719: -- I think that this fix needs some bigger cha

[jira] [Assigned] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-12-19 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-17719: Assignee: (was: Daniel Urban) > Connect may fail to start tasks when reading from a c

[jira] [Resolved] (KAFKA-17632) Custom `partitioner.class` with an even number of partitions always writes to even partitions if use RoundRobinPartitioner

2024-11-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-17632. -- Fix Version/s: 4.0.0 Resolution: Fixed [~thanhlv] The RR partitioner has been fixed, an

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-10-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893838#comment-17893838 ] Daniel Urban commented on KAFKA-17719: -- I'm still thinking about a possible solutio

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-10-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893768#comment-17893768 ] Daniel Urban commented on KAFKA-17719: -- [~cmukka20] I was thinking that allowing "d

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-10-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893765#comment-17893765 ] Daniel Urban commented on KAFKA-17719: -- I see that the fix for KAFKA-16838 was expl

[jira] [Commented] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-10-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893727#comment-17893727 ] Daniel Urban commented on KAFKA-17719: -- [~cmukka20] I think your analysis is correc

[jira] [Assigned] (KAFKA-17719) Connect may fail to start tasks when reading from a compacted config topic

2024-10-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-17719: Assignee: Daniel Urban > Connect may fail to start tasks when reading from a compacted co

[jira] [Assigned] (KAFKA-17632) Custom `partitioner.class` with an even number of partitions always writes to even partitions if use RoundRobinPartitioner

2024-10-28 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-17632: Assignee: Daniel Urban > Custom `partitioner.class` with an even number of partitions alw

[jira] [Commented] (KAFKA-17632) Custom `partitioner.class` with an even number of partitions always writes to even partitions if use RoundRobinPartitioner

2024-10-28 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893559#comment-17893559 ] Daniel Urban commented on KAFKA-17632: -- Thank you for the report and the repro code

[jira] [Created] (KAFKA-17828) Reverse Checkpointing in MirrorMaker2

2024-10-18 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-17828: Summary: Reverse Checkpointing in MirrorMaker2 Key: KAFKA-17828 URL: https://issues.apache.org/jira/browse/KAFKA-17828 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-17534) Allow disabling hearbeats topic replication in MirrorSourceConnector

2024-09-12 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-17534: - Description: Currently, MirrorSourceConnector always replicates the heartbeats topics. In some

[jira] [Created] (KAFKA-17534) Allow disabling hearbeats topic replication in MirrorSourceConnector

2024-09-12 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-17534: Summary: Allow disabling hearbeats topic replication in MirrorSourceConnector Key: KAFKA-17534 URL: https://issues.apache.org/jira/browse/KAFKA-17534 Project: Kafka

[jira] [Commented] (KAFKA-13459) MM2 should be able to add the source offset to the record header

2024-04-23 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839981#comment-17839981 ] Daniel Urban commented on KAFKA-13459: -- [~viktorsomogyi]  No plans, and it does req

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

2023-08-18 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755997#comment-17755997 ] Daniel Urban edited comment on KAFKA-15372 at 8/18/23 2:33 PM: ---

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

2023-08-18 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755997#comment-17755997 ] Daniel Urban commented on KAFKA-15372: -- [~gharris1727] I have a bit more informatio

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

2023-08-18 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755833#comment-17755833 ] Daniel Urban commented on KAFKA-15372: -- [~gharris1727]  Not sure if I follow this p

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

2023-08-17 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755643#comment-17755643 ] Daniel Urban commented on KAFKA-15372: -- Hi [~gharris1727], I don't have a determini

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

2023-08-17 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-15372: Summary: MM2 rolling restart can drop configuration changes silently Key: KAFKA-15372 URL: https://issues.apache.org/jira/browse/KAFKA-15372 Project: Kafka

[jira] [Commented] (KAFKA-15075) MM2 internal checkpoints topic should support multiple partitions

2023-06-20 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735562#comment-17735562 ] Daniel Urban commented on KAFKA-15075: -- [~elkkhan] Not in the near future, feel fre

[jira] [Created] (KAFKA-15075) MM2 internal checkpoints topic should support multiple partitions

2023-06-09 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-15075: Summary: MM2 internal checkpoints topic should support multiple partitions Key: KAFKA-15075 URL: https://issues.apache.org/jira/browse/KAFKA-15075 Project: Kafka

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

2023-06-05 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-13756: Assignee: Daniel Urban > Connect validate endpoint should return proper response for inva

[jira] [Commented] (KAFKA-14497) LastStableOffset is advanced prematurely when a log is reopened.

2023-06-02 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728723#comment-17728723 ] Daniel Urban commented on KAFKA-14497: -- AFAIU, the information about the replicated

[jira] [Assigned] (KAFKA-14034) Consistency violation: enabled idempotency doesn't prevent duplicates when a client runs into UNKNOWN_SERVER_ERROR

2023-06-02 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-14034: Assignee: Daniel Urban > Consistency violation: enabled idempotency doesn't prevent dupli

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

2023-05-08 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14978: Summary: ExactlyOnceWorkerSourceTask does not remove parent metrics Key: KAFKA-14978 URL: https://issues.apache.org/jira/browse/KAFKA-14978 Project: Kafka Is

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

2023-04-21 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14652: - Summary: Improve MM2 logging by adding the flow information to the context (KIP-916) (was: Impr

[jira] [Commented] (KAFKA-14807) MirrorMaker2 config source.consumer.auto.offset.reset=latest leading to the pause of replication of consumer groups

2023-04-19 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714097#comment-17714097 ] Daniel Urban commented on KAFKA-14807: -- [~fisher91] do you use MM2 dedicated mode,

[jira] [Created] (KAFKA-14903) MM2 Topic And Group Listener (KIP-918)

2023-04-13 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14903: Summary: MM2 Topic And Group Listener (KIP-918) Key: KAFKA-14903 URL: https://issues.apache.org/jira/browse/KAFKA-14903 Project: Kafka Issue Type: New Featur

[jira] [Created] (KAFKA-14902) KafkaBasedLog infinite retries can lead to StackOverflowError

2023-04-13 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14902: Summary: KafkaBasedLog infinite retries can lead to StackOverflowError Key: KAFKA-14902 URL: https://issues.apache.org/jira/browse/KAFKA-14902 Project: Kafka

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

2023-03-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14652: - Description: MirrorMaker2 runs multiple Connect worker instances in a single process. In Connec

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

2023-03-27 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14838: - Description: MM2 code creates a lot of Kafka clients internally. These clients generate a lot o

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

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

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

2023-03-23 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14652: - Description: MirrorMaker2 runs multiple Connect worker instances in a single process. In Connec

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

2023-03-23 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14838: Summary: MM2 Connector/Task clients should specify client ID based on ID and role Key: KAFKA-14838 URL: https://issues.apache.org/jira/browse/KAFKA-14838 Project: Kaf

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

2023-03-23 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-14652: Assignee: Daniel Urban > Improve MM2 logging by adding the flow information to the contex

[jira] [Created] (KAFKA-14721) Kafka listener uses wrong login class

2023-02-15 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14721: Summary: Kafka listener uses wrong login class Key: KAFKA-14721 URL: https://issues.apache.org/jira/browse/KAFKA-14721 Project: Kafka Issue Type: Bug Aff

[jira] [Commented] (KAFKA-14716) Connect schema does not allow struct default values

2023-02-15 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688979#comment-17688979 ] Daniel Urban commented on KAFKA-14716: -- [~ChrisEgerton] Indeed, it is, thanks for p

[jira] [Resolved] (KAFKA-14716) Connect schema does not allow struct default values

2023-02-15 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-14716. -- Resolution: Duplicate > Connect schema does not allow struct default values >

[jira] [Updated] (KAFKA-14716) Connect schema does not allow struct default values

2023-02-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14716: - Description: The ConnectSchema API should allow specifying a composite (struct) default value f

[jira] [Created] (KAFKA-14716) Connect schema does not allow struct default values

2023-02-14 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14716: Summary: Connect schema does not allow struct default values Key: KAFKA-14716 URL: https://issues.apache.org/jira/browse/KAFKA-14716 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-14667) Delayed leader election operation gets stuck in purgatory

2023-02-01 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14667: - Description: This was observed with Kafka 3.1.1, but I believe that latest versions are also af

[jira] [Created] (KAFKA-14667) Delayed leader election operation gets stuck in purgatory

2023-02-01 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14667: Summary: Delayed leader election operation gets stuck in purgatory Key: KAFKA-14667 URL: https://issues.apache.org/jira/browse/KAFKA-14667 Project: Kafka Iss

[jira] [Created] (KAFKA-14653) MM2 should delay resolving config provider references

2023-01-25 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14653: Summary: MM2 should delay resolving config provider references Key: KAFKA-14653 URL: https://issues.apache.org/jira/browse/KAFKA-14653 Project: Kafka Issue T

[jira] [Updated] (KAFKA-10586) Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

2023-01-25 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-10586: - Issue Type: Task (was: Improvement) > Full support for distributed mode in dedicated MirrorMake

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

2023-01-25 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14652: Summary: Improve MM2 logging by adding the flow information to the context Key: KAFKA-14652 URL: https://issues.apache.org/jira/browse/KAFKA-14652 Project: Kafka

[jira] [Commented] (KAFKA-14053) Transactional producer should bump the epoch when a batch encounters delivery timeout

2022-07-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566808#comment-17566808 ] Daniel Urban commented on KAFKA-14053: -- I understand that increasing the epoch on t

[jira] [Commented] (KAFKA-14053) Transactional producer should bump the epoch when a batch encounters delivery timeout

2022-07-08 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564222#comment-17564222 ] Daniel Urban commented on KAFKA-14053: -- About to submit a PR, but wanted to bring u

[jira] [Updated] (KAFKA-14053) Transactional producer should bump the epoch when a batch encounters delivery timeout

2022-07-07 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-14053: - Description: When a batch fails due to delivery timeout, it is possible that the batch is still

[jira] [Created] (KAFKA-14053) Transactional producer should bump the epoch when a batch encounters delivery timeout

2022-07-07 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-14053: Summary: Transactional producer should bump the epoch when a batch encounters delivery timeout Key: KAFKA-14053 URL: https://issues.apache.org/jira/browse/KAFKA-14053

[jira] [Commented] (KAFKA-13970) TopicAdmin topic creation should be retried on TimeoutException

2022-06-09 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552025#comment-17552025 ] Daniel Urban commented on KAFKA-13970: -- Sorry for the confusion, the Issue I report

[jira] [Created] (KAFKA-13970) TopicAdmin topic creation should be retried on TimeoutException

2022-06-08 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13970: Summary: TopicAdmin topic creation should be retried on TimeoutException Key: KAFKA-13970 URL: https://issues.apache.org/jira/browse/KAFKA-13970 Project: Kafka

[jira] [Updated] (KAFKA-13970) TopicAdmin topic creation should be retried on TimeoutException

2022-06-08 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13970: - Issue Type: Bug (was: Improvement) > TopicAdmin topic creation should be retried on TimeoutExce

[jira] [Commented] (KAFKA-12671) Out of order processing with a transactional producer can lead to a stuck LastStableOffset

2022-05-26 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542435#comment-17542435 ] Daniel Urban commented on KAFKA-12671: -- I think I encountered a different path than

[jira] [Commented] (KAFKA-12671) Out of order processing with a transactional producer can lead to a stuck LastStableOffset

2022-04-29 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530039#comment-17530039 ] Daniel Urban commented on KAFKA-12671: -- I believe I encountered this issue with the

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

2022-04-08 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-13809. -- Resolution: Won't Fix Connector configs are used for consumer/producer overrides, converter cl

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

2022-04-08 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13809: - Description: The 2 example connectors do not propagate the full connector configuration to the

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

2022-04-08 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13809: Summary: FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks Key: KAFKA-13809 URL: https://issues.apache.org/jira/browse/KAFKA-13809

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

2022-03-21 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13756: - Description: Currently, if there is an issue with  the connector class, the validate endpoint r

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

2022-03-21 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13756: - Summary: Connect validate endpoint should return proper response for invalid connector class (w

[jira] [Created] (KAFKA-13756) Connect validate endpoint should return proper response on name and connector class error

2022-03-21 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13756: Summary: Connect validate endpoint should return proper response on name and connector class error Key: KAFKA-13756 URL: https://issues.apache.org/jira/browse/KAFKA-13756

[jira] [Created] (KAFKA-13459) MM2 should be able to add the source offset to the record header

2021-11-17 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13459: Summary: MM2 should be able to add the source offset to the record header Key: KAFKA-13459 URL: https://issues.apache.org/jira/browse/KAFKA-13459 Project: Kafka

[jira] [Created] (KAFKA-13452) MM2 creates invalid checkpoint when offset mapping is not available

2021-11-12 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13452: Summary: MM2 creates invalid checkpoint when offset mapping is not available Key: KAFKA-13452 URL: https://issues.apache.org/jira/browse/KAFKA-13452 Project: Kafka

[jira] [Updated] (KAFKA-13311) MM2 should allow propagating arbitrary global configurations to the Connect worker and to the Connector config

2021-10-11 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13311: - Description: Currently, the configuration propagation logic in MM2 only allows a handful of con

[jira] [Updated] (KAFKA-13311) MM2 should allow propagating arbitrary global configurations to the Connect worker and to the Connector config

2021-10-11 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-13311: - Summary: MM2 should allow propagating arbitrary global configurations to the Connect worker and

[jira] [Created] (KAFKA-13311) MM2 should allow propagating arbitrary global configurations to the Connector config

2021-09-20 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-13311: Summary: MM2 should allow propagating arbitrary global configurations to the Connector config Key: KAFKA-13311 URL: https://issues.apache.org/jira/browse/KAFKA-13311

[jira] [Assigned] (KAFKA-13311) MM2 should allow propagating arbitrary global configurations to the Connector config

2021-09-20 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-13311: Assignee: (was: Daniel Urban) > MM2 should allow propagating arbitrary global configu

[jira] [Resolved] (KAFKA-13253) Kafka Connect losing task (re)configuration when connector name has special characters

2021-08-30 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-13253. -- Resolution: Duplicate Same issue as KAFKA-9747 - that one already has a fix under review > Ka

[jira] [Commented] (KAFKA-9747) No tasks created for a connector

2021-08-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393655#comment-17393655 ] Daniel Urban commented on KAFKA-9747: - To add more details to the issue: * When runn

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

2021-08-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393104#comment-17393104 ] Daniel Urban commented on KAFKA-10719: -- I believe that the core issue here is that

[jira] [Commented] (KAFKA-9981) Running a dedicated mm2 cluster with more than one nodes,When the configuration is updated the task is not aware and will lose the update operation.

2021-08-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393101#comment-17393101 ] Daniel Urban commented on KAFKA-9981: - This KIP aims to fix the issue by adding the R

[jira] [Commented] (KAFKA-9805) Running MirrorMaker in a Connect cluster,but the task not running

2021-08-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393080#comment-17393080 ] Daniel Urban commented on KAFKA-9805: - I believe this is the same issue as KAFKA-9747

[jira] [Commented] (KAFKA-12966) MM2 doesn't trigger replicate data on new topics

2021-06-17 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364996#comment-17364996 ] Daniel Urban commented on KAFKA-12966: -- I believe you are hitting the issue describ

[jira] [Commented] (KAFKA-12893) MM2 fails to replicate if starting two+ nodes same time

2021-06-04 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357372#comment-17357372 ] Daniel Urban commented on KAFKA-12893: -- You might be hitting the issue of MM2 not r

[jira] [Resolved] (KAFKA-12664) Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2 clusters in standalone mode

2021-04-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-12664. -- Resolution: Not A Bug > Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2

[jira] [Assigned] (KAFKA-12664) Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2 clusters in standalone mode

2021-04-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban reassigned KAFKA-12664: Assignee: Daniel Urban > Mirrormaker 2.0 infinite rebalance loop when dealing with more t

[jira] [Commented] (KAFKA-12664) Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2 clusters in standalone mode

2021-04-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321057#comment-17321057 ] Daniel Urban commented on KAFKA-12664: -- Issue is that in your setup, there are 2 co

[jira] [Commented] (KAFKA-12664) Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2 clusters in standalone mode

2021-04-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320917#comment-17320917 ] Daniel Urban commented on KAFKA-12664: -- In short, just remove those group.id config

[jira] [Commented] (KAFKA-12664) Mirrormaker 2.0 infinite rebalance loop when dealing with more than 2 clusters in standalone mode

2021-04-14 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320763#comment-17320763 ] Daniel Urban commented on KAFKA-12664: -- MM2 spins up a Connect worker *per replicat

[jira] [Updated] (KAFKA-10586) Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

2021-01-25 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-10586: - Description: KIP-382 introduced MirrorMaker 2.0. Because of scoping issues, the dedicated Mirro

[jira] [Updated] (KAFKA-10586) Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

2021-01-25 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban updated KAFKA-10586: - Summary: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters (was: MirrorMa

[jira] [Created] (KAFKA-10586) MirrorMaker 2.0 REST support

2020-10-08 Thread Daniel Urban (Jira)
Daniel Urban created KAFKA-10586: Summary: MirrorMaker 2.0 REST support Key: KAFKA-10586 URL: https://issues.apache.org/jira/browse/KAFKA-10586 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-10414) Upgrade api-util dependency - CVE-2018-1337

2020-08-24 Thread Daniel Urban (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-10414. -- Resolution: Not A Problem api-util is only a test dependency, not an issue. > Upgrade api-uti

  1   2   >