针对你遇到的Local: Required feature not supported by broker错误，可按以下步骤定位具体不支持的特性：

1. 强制指定Kafka协议版本 #

ClickHouse 22.1.3.7的Kafka客户端默认协议版本可能与Kafka 4.0.0不匹配。尝试在建表时强制指定旧版协议版本（与原正常集群一致的2.4.1）：

CREATE TABLE IF NOT EXISTS database.table (
    `json` String
)
ENGINE = kafka 
SETTINGS 
    kafka_broker_list = 'host1:port1,host2:port2,host3:port3', 
    kafka_topic_list = 'topic_name',
    kafka_group_name = 'group_name',
    kafka_format='JSONAsString',
    kafka_api_version = '2.4.1',
    kafka_api_version_fallback = '2.4.1';

若修改后恢复正常，说明问题源于协议版本协商失败，客户端默认请求的特性被Kafka 4.0.0拒绝。

2. 启用Kafka客户端调试日志 #

在建表时添加调试参数，获取更详细的交互日志：

kafka_debug = 'all'

查看ClickHouse日志，会输出客户端与Broker协商特性的细节，从中可直接找到被Broker拒绝的具体特性（如日志中会出现类似Failed to enable feature [XXX]: Broker does not support的条目）。

3. 检查Kafka Broker配置差异 #

对比新集群（bitnami/kafka:4.0.0）与原集群的配置，重点关注：

• inter.broker.protocol.version：Broker使用的内部协议版本是否过高
• log.message.format.version：消息格式版本是否与客户端兼容
• 安全配置：新集群是否启用了SASL/SSL等认证机制，而建表时未配置对应参数（如kafka_security_protocol、kafka_sasl_mechanism等）

4. 验证基础连通性与权限 #

在ClickHouse服务器上使用Kafka命令行工具测试消费：

kafka-console-consumer.sh --bootstrap-server host1:port1,host2:port2,host3:port3 --topic topic_name --group group_name --from-beginning

若命令行消费也报错，说明问题出在Kafka集群的网络、权限或基础配置；若能正常消费，则问题聚焦于ClickHouse Kafka引擎的参数配置。

内容的提问来源于stack exchange，提问作者Slim