James Cheng

Results 7 comments of James Cheng

Changes to let this code work with Kafka Connect 2.11-1.0.0

What testing did you do on this? Does it work properly when run with the latest kafka connect?

Changes to let this code work with Kafka Connect 2.11-1.0.0

Can you update the README.md to use 1.0.0, and verify that the instructions work?

When increasing replication-factor on a topic, does it maintain rack awareness?

Thanks @d-rk ! I also don't have time to make the change myself, but I will leave this issue open for tracking purposes, in case someone else has a similar...

How to know if binlog file and position info is too old?

ngocdaothanh, My solution was to turn off turn off automatic reconnect, and detect the situation using a LifecycleListener: ``` public class ConnectionLifecycleListener implements LifecycleListener { public enum Reason { BINLOG_NOT_AVAILABLE...

Update Kafka Version to 3.8.0 to address CVE-2024-31141

https://github.com/linkedin/cruise-control/pull/2180 has now been merged

KAFKA-4893: Fix conflict between async topic deletion and max topic length

Does this PR handle the case where a kafka cluster already has a topic called `delete`? And, does it prevent a topic from being created that is called `delete`?

KAFKA-4893: Fix conflict between async topic deletion and max topic length

Ah, right. All the other directories are `topic-partitionnum`. Thanks.