[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partitions stopped after got
the followin
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partitions stopped after got
the followin
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874143#comment-17874143
]
Yu Wang commented on KAFKA-17139:
-
[~ChrisEgerton] could you help to review this issue?
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang reassigned KAFKA-17139:
---
Assignee: Yu Wang
> MirrorSourceTask will stop mirroring when get BufferUnderflowException
> --
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partition stopped after got
the following
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partition stopped after got
the following
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partition stopped after got
the following
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partition stopped after got
the following
[
https://issues.apache.org/jira/browse/KAFKA-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-17139:
Description:
Recently we found the data mirroring of one of our partition stopped after got
the following
Yu Wang created KAFKA-17139:
---
Summary: MirrorSourceTask will stop mirroring when get
BufferUnderflowException
Key: KAFKA-17139
URL: https://issues.apache.org/jira/browse/KAFKA-17139
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807561#comment-17807561
]
Yu Wang commented on KAFKA-15851:
-
got similar stack trace in 2.5.1, recovered after res
[
https://issues.apache.org/jira/browse/KAFKA-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang reassigned KAFKA-15687:
---
Assignee: Yu Wang
> Update host address for the GoupMetadata when replace static members
>
[
https://issues.apache.org/jira/browse/KAFKA-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17780620#comment-17780620
]
Yu Wang commented on KAFKA-15687:
-
[~sagarrao] with *group.instance.id* the member id wi
[
https://issues.apache.org/jira/browse/KAFKA-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15687:
Description:
We are trying to use static membership protocol for our consumers in
Kubernetes. When our po
Yu Wang created KAFKA-15687:
---
Summary: Update host address for the GoupMetadata of static members
Key: KAFKA-15687
URL: https://issues.apache.org/jira/browse/KAFKA-15687
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15687:
Summary: Update host address for the GoupMetadata when replace static
members (was: Update host address f
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724518#comment-17724518
]
Yu Wang edited comment on KAFKA-15005 at 5/20/23 10:11 AM:
---
[~
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
Our MM2 is running version 2.5.1.
After a rebalance of our MM2 source tasks, we found there
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724518#comment-17724518
]
Yu Wang commented on KAFKA-15005:
-
[~sagarrao] Sorry for the confusion.
Yes, the RUNNIG
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724071#comment-17724071
]
Yu Wang edited comment on KAFKA-15005 at 5/19/23 1:48 AM:
--
[~sa
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724071#comment-17724071
]
Yu Wang commented on KAFKA-15005:
-
[~sagarrao] I check the PR in
https://issues.apache.
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724070#comment-17724070
]
Yu Wang commented on KAFKA-15005:
-
Thanks, [~sagarrao] . Yes, looks like the this ticket
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
Our MM2 is running version 2.5.1.
After a rebalance of our MM2 source tasks, we found there
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
Our MM2 is running version 2.5.1.
After a rebalance of our MM2 source tasks, we found there
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
After a rebalance of our MM2 source tasks, we found there were several tasks
always in *UNAS
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
After a rebalance of our MM2 source tasks, we found there were several tasks
always in *UNAS
Yu Wang created KAFKA-15005:
---
Summary: Status of KafkaConnect task not correct
Key: KAFKA-15005
URL: https://issues.apache.org/jira/browse/KAFKA-15005
Project: Kafka
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang closed KAFKA-14266.
---
> MirrorSourceTask will stop mirroring when get corrupt record
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang resolved KAFKA-14266.
-
Resolution: Works for Me
> MirrorSourceTask will stop mirroring when get corrupt record
> --
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615898#comment-17615898
]
Yu Wang edited comment on KAFKA-14266 at 10/11/22 3:07 PM:
---
[~
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615898#comment-17615898
]
Yu Wang commented on KAFKA-14266:
-
[~ChrisEgerton] for this issue, as the KafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611814#comment-17611814
]
Yu Wang edited comment on KAFKA-14266 at 10/1/22 3:56 AM:
--
[~Ch
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611814#comment-17611814
]
Yu Wang commented on KAFKA-14266:
-
[~ChrisEgerton] I am afraid monitoring lag now workin
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang reassigned KAFKA-14266:
---
Assignee: Yu Wang
> MirrorSourceTask will stop mirroring when get corrupt record
>
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Summary: MirrorSourceTask will stop mirroring when get corrupt record
(was: MirrorSourceTask will stop mi
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Issue Type: Bug (was: Improvement)
> MirrorSourceTask will stop mirroring when get the corrupt record
> -
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
Yu Wang created KAFKA-14266:
---
Summary: MirrorSourceTask will stop mirroring when get the corrupt
record
Key: KAFKA-14266
URL: https://issues.apache.org/jira/browse/KAFKA-14266
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221366#comment-17221366
]
Yu Wang commented on KAFKA-8124:
+1 spark2.3.2 with kafka2.0
> Beginning offset is after
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132901#comment-17132901
]
Yu Wang commented on KAFKA-9841:
Thank you for checking [~vvcephei] and thank you for yo
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang reassigned KAFKA-9841:
--
Assignee: Yu Wang (was: Konstantine Karantasis)
> Connector and Task duplicated when a worker join wi
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080168#comment-17080168
]
Yu Wang commented on KAFKA-9841:
Thank you, [~kkonstantine].
> Connector and Task duplic
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-9841:
---
Comment: was deleted
(was: [https://github.com/apache/kafka/pull/8453])
> Connector and Task duplicated when
Yu Wang created KAFKA-9841:
--
Summary: Connector and Task duplicated when a worker join with old
generation assignment
Key: KAFKA-9841
URL: https://issues.apache.org/jira/browse/KAFKA-9841
Project: Kafka
46 matches
Mail list logo
