[
https://issues.apache.org/jira/browse/KAFKA-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-16710:
---
Attachment: 企业微信截图_230257fe-1c11-4e77-93b3-b8b8edce2ba3.png
[
https://issues.apache.org/jira/browse/KAFKA-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-16710:
---
Description:
The scenario where this case occurs is during a reassignment of a partition:
110879, 110880
[
https://issues.apache.org/jira/browse/KAFKA-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-16710:
---
Description:
The scenario where this case occurs is during a reassignment of a partition:
110879, 110880
hudeqi created KAFKA-16710:
--
Summary: Continuously `makeFollower` may cause the replica fetcher
thread to encounter an offset mismatch exception when `processPartitionData`
Key: KAFKA-16710
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-16543:
---
Description:
In the `cleanupGroupMetadata` method, tombstone messages is written to delete
the group's
hudeqi created KAFKA-16543:
--
Summary: There may be ambiguous deletions in the
`cleanupGroupMetadata` when the generation of the group is less than or equal
to 0
Key: KAFKA-16543
URL:
[
https://issues.apache.org/jira/browse/KAFKA-15764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15764:
--
Assignee: hudeqi
> Missing tests for transactions
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781288#comment-17781288
]
hudeqi commented on KAFKA-15764:
I can pick it up.
> Missing tests for transactions
>
[
https://issues.apache.org/jira/browse/KAFKA-15313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781257#comment-17781257
]
hudeqi commented on KAFKA-15313:
Hi, [~abhijeetkumar] Are you still following this issue? If you don't
[
https://issues.apache.org/jira/browse/KAFKA-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15331:
--
Assignee: hudeqi
> Handle remote log enabled topic deletion when leader is not available
>
[
https://issues.apache.org/jira/browse/KAFKA-15432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780818#comment-17780818
]
hudeqi commented on KAFKA-15432:
I will take it over if no anyone is not following this. Thanks
[
https://issues.apache.org/jira/browse/KAFKA-15432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15432:
--
Assignee: hudeqi
> RLM Stop partitions should not be invoked for non-tiered storage topics
>
[
https://issues.apache.org/jira/browse/KAFKA-15300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780816#comment-17780816
]
hudeqi commented on KAFKA-15300:
Can I take over this issue? [~satish.duggana] Can you describe this
[
https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780815#comment-17780815
]
hudeqi commented on KAFKA-15376:
Can I take over this issue? [~satish.duggana]
> Explore options of
[
https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780814#comment-17780814
]
hudeqi commented on KAFKA-15038:
Hi, [~owen-leung] Are you still following this issue? If you don't
[
https://issues.apache.org/jira/browse/KAFKA-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780812#comment-17780812
]
hudeqi commented on KAFKA-15331:
Hi, [~_gargantua_] Are you still following this issue? If you don't
[
https://issues.apache.org/jira/browse/KAFKA-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780809#comment-17780809
]
hudeqi commented on KAFKA-12641:
Hi, [~abhijeetkumar] Are you still following this issue? If you don't
[
https://issues.apache.org/jira/browse/KAFKA-13355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780810#comment-17780810
]
hudeqi commented on KAFKA-13355:
Hi, [~abhijeetkumar] Are you still following this issue? If you don't
[
https://issues.apache.org/jira/browse/KAFKA-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15671:
--
Assignee: hudeqi
> Flaky test RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCache
>
[
https://issues.apache.org/jira/browse/KAFKA-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779022#comment-17779022
]
hudeqi commented on KAFKA-15671:
Hi, [~brian030128] , I saw that this issue needs a quick fix. I know a
[
https://issues.apache.org/jira/browse/KAFKA-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15396:
---
Affects Version/s: 3.6.0
(was: 3.5.1)
> Add a metric indicating the version of
[
https://issues.apache.org/jira/browse/KAFKA-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15607:
---
Attachment: SeaTalk_IMG_20231019_174340.png
> Possible NPE is thrown in MirrorCheckpointTask
>
[
https://issues.apache.org/jira/browse/KAFKA-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15607:
---
Affects Version/s: 3.7.0
> Possible NPE is thrown in MirrorCheckpointTask
>
[
https://issues.apache.org/jira/browse/KAFKA-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15607:
---
Affects Version/s: 3.6.0
(was: 3.7.0)
> Possible NPE is thrown in
[
https://issues.apache.org/jira/browse/KAFKA-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15607:
---
Attachment: SeaTalk_IMG_20231019_172945.png
> Possible NPE is thrown in MirrorCheckpointTask
>
[
https://issues.apache.org/jira/browse/KAFKA-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15607:
---
Description:
In the `syncGroupOffset` method, if `targetConsumerOffset.get(topicPartition)`
gets null,
hudeqi created KAFKA-15607:
--
Summary: Possible NPE is thrown in MirrorCheckpointTask
Key: KAFKA-15607
URL: https://issues.apache.org/jira/browse/KAFKA-15607
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772948#comment-17772948
]
hudeqi commented on KAFKA-15535:
Is this marked as resolved? The doc of
[
https://issues.apache.org/jira/browse/KAFKA-15536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15536:
---
Affects Version/s: 3.7.0
(was: 3.6.0)
> dynamically resize remoteIndexCache
>
[
https://issues.apache.org/jira/browse/KAFKA-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15535:
--
Assignee: hudeqi
> Add documentation of "remote.log.index.file.cache.total.size.bytes"
>
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reopened KAFKA-15397:
> Deserializing produce requests may cause memory leaks when exceptions occur
>
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763002#comment-17763002
]
hudeqi commented on KAFKA-14912:
Thanks, [~showuon] . The PR corresponding to this issue is currently
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761165#comment-17761165
]
hudeqi commented on KAFKA-15397:
yes, the analysis in the attachment is based on the heap dump.
>
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761149#comment-17761149
]
hudeqi commented on KAFKA-15397:
I applied the fix of this PR online and saw that the frequency of full
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760223#comment-17760223
]
hudeqi commented on KAFKA-15397:
[~showuon]
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi resolved KAFKA-15397.
Resolution: Resolved
> Deserializing produce requests may cause memory leaks when exceptions occur
>
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760204#comment-17760204
]
hudeqi commented on KAFKA-15397:
It seems that this commit: ”MINOR: Add more validation during KRPC
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15397:
---
Affects Version/s: 2.8.1
(was: 3.5.1)
> Deserializing produce requests may cause
[
https://issues.apache.org/jira/browse/KAFKA-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759514#comment-17759514
]
hudeqi commented on KAFKA-15396:
Hi, [~divijvaidya] [~jolshan] I have added kip-972 link in this jira,
[
https://issues.apache.org/jira/browse/KAFKA-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759492#comment-17759492
]
hudeqi commented on KAFKA-15396:
thanks, I will submit here.
> Add a metric indicating the version of
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15397:
---
Attachment: SeaTalk_IMG_1692796505.png
SeaTalk_IMG_1692796533.png
[
https://issues.apache.org/jira/browse/KAFKA-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15397:
---
Description: When the client sends a produce request in an abnormal way and
the server accepts it for
hudeqi created KAFKA-15397:
--
Summary: Deserializing produce requests may cause memory leaks
when exceptions occur
Key: KAFKA-15397
URL: https://issues.apache.org/jira/browse/KAFKA-15397
Project: Kafka
hudeqi created KAFKA-15396:
--
Summary: Add a metric indicating the version of the current
running kafka server
Key: KAFKA-15396
URL: https://issues.apache.org/jira/browse/KAFKA-15396
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756895#comment-17756895
]
hudeqi commented on KAFKA-14912:
But how to measure and get the size of the entry? [~divijvaidya]
>
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754541#comment-17754541
]
hudeqi commented on KAFKA-15172:
This KIP is seldom discussed, what should I do next? [~mimaison]
>
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754089#comment-17754089
]
hudeqi commented on KAFKA-14912:
Hi, [~divijvaidya] Caffeine does support “a max size by bytes”. If I
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752398#comment-17752398
]
hudeqi commented on KAFKA-15172:
Hi, I have initiated a kip discussion:
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-14912:
--
Assignee: hudeqi
> Introduce a configuration for remote index cache size, preferably a dynamic
>
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752229#comment-17752229
]
hudeqi commented on KAFKA-14912:
ok, i'll take a look in the last few days, thx
> Introduce a
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15172:
---
Labels: kip-965 (was: needs-kip)
> Allow exact mirroring of ACLs between clusters
>
[
https://issues.apache.org/jira/browse/KAFKA-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15129:
---
Description:
In the current kafka code, there are still many module metrics that are
forgotten to be
[
https://issues.apache.org/jira/browse/KAFKA-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744148#comment-17744148
]
hudeqi commented on KAFKA-15194:
thanks [~divijvaidya] I still don't know much about "tiered storage"
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-14467:
--
Assignee: hudeqi
> Add a test to validate the replica state after processing the
>
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744147#comment-17744147
]
hudeqi commented on KAFKA-14467:
Thanks, I took over first, I'll look at this later.
> Add a test to
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744087#comment-17744087
]
hudeqi commented on KAFKA-14467:
Isn't this issue [~showuon] in charge ?
> Add a test to validate the
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742994#comment-17742994
]
hudeqi commented on KAFKA-15172:
Hi,[~mimaison] [~ChrisEgerton] I am currently doing the work of using
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-15172:
--
Assignee: hudeqi
> Allow exact mirroring of ACLs between clusters
>
[
https://issues.apache.org/jira/browse/KAFKA-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742624#comment-17742624
]
hudeqi commented on KAFKA-14912:
Hi [~divijvaidya] [~manyanda] I am also interested, if you are busy
[
https://issues.apache.org/jira/browse/KAFKA-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi resolved KAFKA-15139.
Resolution: Fixed
> Optimize the performance of `Set.removeAll(List)` in
> `MirrorCheckpointConnector`
>
[
https://issues.apache.org/jira/browse/KAFKA-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15139:
---
Description:
This is the hint of `removeAll` method in `Set`:
_This implementation determines which is the
[
https://issues.apache.org/jira/browse/KAFKA-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15139:
---
Description:
This is the hint of `removeAll` method in `Set`:
_This implementation determines which is the
hudeqi created KAFKA-15139:
--
Summary: Optimize the performance of `Set.removeAll(List)` in
`MirrorCheckpointConnector`
Key: KAFKA-15139
URL: https://issues.apache.org/jira/browse/KAFKA-15139
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15134:
---
Attachment: WechatIMG31.jpeg
> Enrich the prompt reason in CommitFailedException
>
[
https://issues.apache.org/jira/browse/KAFKA-15134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15134:
---
Description:
Firstly, let me post the exception log of the client running:
hudeqi created KAFKA-15134:
--
Summary: Enrich the prompt reason in CommitFailedException
Key: KAFKA-15134
URL: https://issues.apache.org/jira/browse/KAFKA-15134
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15129:
---
Description:
In the current kafka code, there are still many module metrics that are
forgotten to be
hudeqi created KAFKA-15129:
--
Summary: Clean up all metrics that were forgotten to be closed
Key: KAFKA-15129
URL: https://issues.apache.org/jira/browse/KAFKA-15129
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15086:
---
Labels: kip-943 (was: )
> The unreasonable segment size setting of the internal topics in MM2 may cause
>
[
https://issues.apache.org/jira/browse/KAFKA-15119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15119:
---
Description:
In the “syncTopicAcls” thread of MirrorSourceConnector, full amount of
"TopicAclBindings"
hudeqi created KAFKA-15119:
--
Summary: Support incremental synchronization of topicAcl in
MirrorSourceConnector
Key: KAFKA-15119
URL: https://issues.apache.org/jira/browse/KAFKA-15119
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735644#comment-17735644
]
hudeqi commented on KAFKA-15110:
Leave an exception log so that others can find this problem:
[
https://issues.apache.org/jira/browse/KAFKA-15110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15110:
---
Attachment: WechatIMG29.jpeg
> Wrong version may be run, which will cause to fail to run when there are
>
[
https://issues.apache.org/jira/browse/KAFKA-15110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15110:
---
Attachment: WechatIMG28.jpeg
> Wrong version may be run, which will cause to fail to run when there are
>
[
https://issues.apache.org/jira/browse/KAFKA-15110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15110:
---
Description:
For example, when I build a jar through './gradlew jar' under a 3.5.0 branch,
and then switch
[
https://issues.apache.org/jira/browse/KAFKA-15110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15110:
---
Summary: Wrong version may be run, which will cause to fail to run when
there are multiple version jars
hudeqi created KAFKA-15110:
--
Summary: Wrong version may be run, which will cause it to fail to
run when there are multiple version jars under core/build/libs
Key: KAFKA-15110
URL:
[
https://issues.apache.org/jira/browse/KAFKA-15086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15086:
---
Description:
As the config 'segment.bytes' for topics related MM2(such as
offset.storage.topic,
[
https://issues.apache.org/jira/browse/KAFKA-15086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15086:
---
Attachment: WechatIMG366.jpeg
> The unreasonable segment size setting of the internal topics in MM2 may
[
https://issues.apache.org/jira/browse/KAFKA-15086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15086:
---
Attachment: WechatIMG365.jpeg
> The unreasonable segment size setting of the internal topics in MM2 may
[
https://issues.apache.org/jira/browse/KAFKA-15086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15086:
---
Attachment: WechatIMG364.jpeg
> The unreasonable segment size setting of the internal topics in MM2 may
hudeqi created KAFKA-15086:
--
Summary: The unreasonable segment size setting of the internal
topics in MM2 may cause the worker startup time to be too long
Key: KAFKA-15086
URL:
[
https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-9613:
--
Affects Version/s: 2.6.2
> CorruptRecordException: Found record size 0 smaller than minimum record
> overhead
[
https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-9613:
--
Component/s: core
> CorruptRecordException: Found record size 0 smaller than minimum record
> overhead
>
[
https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-9613:
-
Assignee: hudeqi
> CorruptRecordException: Found record size 0 smaller than minimum record
> overhead
[
https://issues.apache.org/jira/browse/KAFKA-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-6668:
-
Assignee: hudeqi
> Broker crashes on restart ,got a CorruptRecordException: Record size is
> smaller
[
https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731863#comment-17731863
]
hudeqi commented on KAFKA-9613:
---
I have also encountered this problem online. Based on the time point and
[
https://issues.apache.org/jira/browse/KAFKA-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731862#comment-17731862
]
hudeqi commented on KAFKA-6668:
---
I have also encountered this issue online. Based on the time point and
[
https://issues.apache.org/jira/browse/KAFKA-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730100#comment-17730100
]
hudeqi commented on KAFKA-15068:
@[~ChrisEgerton] Hello, if you have time, please take a look at this
[
https://issues.apache.org/jira/browse/KAFKA-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-15068:
---
Description:
When MM2 is used to replicate topics between Kafka clusters, if the timestamp
of the record
hudeqi created KAFKA-15068:
--
Summary: Incorrect replication Latency may be calculated when the
timestamp of the record is of type CREATE_TIME
Key: KAFKA-15068
URL: https://issues.apache.org/jira/browse/KAFKA-15068
[
https://issues.apache.org/jira/browse/KAFKA-14979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721163#comment-17721163
]
hudeqi commented on KAFKA-14979:
[GitHub Pull Request #13692|https://github.com/apache/kafka/pull/13692]
[
https://issues.apache.org/jira/browse/KAFKA-14979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14979:
---
Description:
When the partitions of ReplicaFetcherThread finished truncating, the
[
https://issues.apache.org/jira/browse/KAFKA-14979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14979:
---
Description:
When the partitions of ReplicaFetcherThread finished truncating, the
[
https://issues.apache.org/jira/browse/KAFKA-14979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-14979:
--
Assignee: hudeqi
> Incorrect lag was calculated when markPartitionsForTruncation in
>
hudeqi created KAFKA-14979:
--
Summary: Incorrect lag was calculated when
markPartitionsForTruncation in ReplicaAlterLogDirsThread
Key: KAFKA-14979
URL: https://issues.apache.org/jira/browse/KAFKA-14979
[
https://issues.apache.org/jira/browse/KAFKA-14907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14907:
---
Labels: KIP-922 (was: )
> Add the traffic metric of the partition dimension in BrokerTopicStats
>
[
https://issues.apache.org/jira/browse/KAFKA-14907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14907:
---
Description:
{color:#172b4d}Currently, there are two metrics for measuring the traffic in
topic
[
https://issues.apache.org/jira/browse/KAFKA-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712337#comment-17712337
]
hudeqi commented on KAFKA-14906:
This change will be reintroduced in version 4.x.
> Extract the
[
https://issues.apache.org/jira/browse/KAFKA-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reopened KAFKA-14906:
> Extract the coordinator service log from server log
> ---
>
1 - 100 of 165 matches
Mail list logo