APIs. This approach would give us the flexibility to
> adjust the APIs in minor releases
>
> Best,
> Chia-Ping
>
> On 2025/08/18 02:21:15 peng wrote:
> > I think making `ReplicaPlacer` configurable is a good strategy. We can
> > integrate KIP-1194: Optimize Rep
I think making `ReplicaPlacer` configurable is a good strategy. We can
integrate KIP-1194: Optimize Replica Assignment for Broker Load Balance in
Uneven Rack Configurations into it, allowing users to choose between the
current `StripedReplicaPlacer` approach or the `WeightedReplicaPlacer`
mentioned
Jialun Peng created KAFKA-19612:
---
Summary: Remove Redundant Validation in StripedReplicaPlacer
Key: KAFKA-19612
URL: https://issues.apache.org/jira/browse/KAFKA-19612
Project: Kafka
Issue Type
In most use cases, Kafka serves as a messaging middleware where messages
that have already been consumed are typically no longer needed and can be
safely deleted. Therefore, I propose enhancing the threshold strategy with
an automatic deletion feature:
When a broker's disk usage reaches 95%, it sh
Peng
Jialun Peng created KAFKA-19507:
---
Summary: Optimize Replica Assignment for Broker Load Balance in
Uneven Rack Configurations
Key: KAFKA-19507
URL: https://issues.apache.org/jira/browse/KAFKA-19507
Thank you for your reply
The proposed load balancer is designed to distribute partitions uniformly
across all brokers, assuming homogeneous hardware and similar partition
workloads (i.e., CPU, network, and disk I/O demands are consistent). Under
these conditions, it guarantees globally balanced pa
implementation and submitted the PR.
The PR also includes a comprehensive set of test cases to help verify the
correctness of the algorithm.
I would really appreciate it if anyone could take some time to review the
KIP and the PR and share your feedback or suggestions.
Best regards
Jialun Peng
在 2025年3月29日星期
Hi Kafka Community,
I would like to start a discussion on a new KIP proposal: KIP-1151: Minimal
movement replica balancing algorithm for reassignment
Motivation
Kafka clusters require rebalancing of topic replicas after horizontal
scaling to evenly distribute the load. However, the current appro
Hi Kafka community,
I'd like to contribute to Apache Kafka. My ASF accounts are:
- Wiki ID: pengjialun
- Jira ID: pengjialun
Please grant me the necessary permissions.
Thanks,
Jialun Peng
Hi Kafka Community,
I would like to start a discussion on a new KIP proposal: KIP-1151: Minimal
movement replica balancing algorithm for reassignment
Motivation
Kafka clusters require rebalancing of topic replicas after horizontal
scaling to evenly distribute the load. However, the current appro
Jialun Peng created KAFKA-19048:
---
Summary: Minimal Movement Replica Balancing algorithm
Key: KAFKA-19048
URL: https://issues.apache.org/jira/browse/KAFKA-19048
Project: Kafka
Issue Type
Hi all,
I am looking for a bit of guidance on an issue I am seeing in a Structured
Streaming (Spark Streaming) query being blocked due to a thread in
ExpiringCredentialRefreshingLogin not being able to shutdown.
The reason why the streaming query is blocked from making progress is
because the kaf
Jialun Peng created KAFKA-16102:
---
Summary: about DynamicListenerConfig, the dynamic modification of
the listener's port or IP does not take effect.
Key: KAFKA-16102
URL: https://issues.apache.org/jira/browse/
ll/9872]. I don't have
permission to configure it to work. Can you help me?
Thanks
Lei Peng
Peng Lei 于2021年1月18日周一 上午10:43写道：
> Hi Kafka
> I'm pushing kafka to support arm ci. I think this is a very
> meaningful work because of it helps kafka get better. If Kafka support
//twitter.com/ijuma>
@gchenke <https://twitter.com/gchenke> @damianguy
<https://twitter.com/damianguy> @MatthiasJSax
<https://twitter.com/MatthiasJSax> @vahidh <https://twitter.com/vahidh>
@rhauch <https://twitter.com/rhauch> @davidjacot
<https://twitter.com/davidjacot> What do you think about kafka's support
for arm ci?
Thanks
Lei Peng
fka's support for arm ci ? I can
give arm ci of Kafka my full support. Now I'm trying to submit a PR to
support this work.[https://github.com/apache/kafka/pull/9872]
Thanks
By Lei Peng
Peng Lei 于2020年12月15日周二 上午10:40写道：
> Hi Kafka:
>
> Recently we met a problem that we have
://issues.apache.org/jira/browse/KAFKA-10759?jql=project%20%3D%20KAFKA%20AND%20text%20~%20arm
Thanks
By Lei Peng
Yuancheng PENG created KAFKA-6717:
-
Summary: TopicPartition Assined twice to a consumer group for
different consumers
Key: KAFKA-6717
URL: https://issues.apache.org/jira/browse/KAFKA-6717
Project
Peyton Peng created KAFKA-6103:
--
Summary: one broker appear to dead lock after running serval hours
with a fresh cluster
Key: KAFKA-6103
URL: https://issues.apache.org/jira/browse/KAFKA-6103
Project
() function?
Thanks,
Martin
-- Forwarded message --
From: Martin Peng
Date: 2017-07-06 17:36 GMT-07:00
Subject: How to fetch offset for all the partitions of one topic through
single KafkaClient function call (0.10.x)?
To: us...@kafka.apache.org
Hi,
I am using Kafka client 0.10.2
Peyton Peng created KAFKA-4268:
--
Summary: huge server.logs during the error frequently happen
"Message format version for partition 200 not found"
Key: KAFKA-4268
URL: https://issues.apache.org/jira/br
22 matches
Mail list logo
