为了删除主题中的所有数据,我将其retention.ms配置设置为1000。
./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=1000
Run Code Online (Sandbox Code Playgroud)
这很好用。经过很短的等待后,所有数据都被删除。
在更改配置之前,未在主题上设置retention.ms,因此服务器默认属性log.retention.hours=168是之前的保留策略。(log.retention.mines 和 log.retention.ms 尚未在服务器属性中设置)。
现在我想从本主题中完全删除retention.ms 配置并返回使用服务器级别配置。
命令如
./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=
Run Code Online (Sandbox Code Playgroud)
或者
./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=null
Run Code Online (Sandbox Code Playgroud)
抛出一个错误。
我知道 kafka-topics.sh 的删除选项实际上会删除整个主题,所以我不会尝试使用它。
问题:如何完全删除主题级别配置,以便主题恢复为使用服务器默认设置?
我想杀死我的 Kafka Connect 分布式工作程序,但我无法(或者我不知道如何)确定在 Linux 中运行的哪个进程是该工作程序。
跑步时
ps aux | grep worker
Run Code Online (Sandbox Code Playgroud)
我确实看到很多工作进程,但不确定哪个是连接工作进程,哪些是标准非连接工作进程
确实,昨天只启动了其中一个进程,我怀疑就是这个,但这显然不是所有情况下的充分条件,例如,如果 Kafka 集群昨天上线。那么,一般来说,我如何确定哪个进程是 Kafka Connect Worker?
这里的万无一失的方法是什么?