If I serialize an object manually as a byte array before producing it in kafka will it be serialized internally by kafka again or the kafka’s serialization will be skipped on receiving a byte array.

In kafka 2.6.1, there is a topic called test with two copies and 30 partitions. Now the partitions are expanded to 40. However, it is found that the disk capacity changes during the expansion process. After looking at the topic, it is found that there are the original 30 partitions. From two copies to three copies, why is this? What is the mechanism?
enter image description here

I am planning to write a blog around searching message(s) based on criteria. I feel there is a lack of tooling / framework in this space, while it’s a routine activity for any Kafka operation team / Development team.

I’m experiencing issues when setting ACLs for my users in Kafka 2.7.0. Specifically, the kafka-acls.sh command fails when using operations that contain underscores. However, similar commands for operations without underscores seem to work correctly.

I’m experiencing issues when setting ACLs for my users in Kafka 2.7.0. Specifically, the kafka-acls.sh command fails when using operations that contain underscores. However, similar commands for operations without underscores seem to work correctly.

I’m experiencing issues when setting ACLs for my users in Kafka 2.7.0. Specifically, the kafka-acls.sh command fails when using operations that contain underscores. However, similar commands for operations without underscores seem to work correctly.