小编sil*_*sil的帖子

删除主题级别配置

为了删除主题中的所有数据,我将其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 的删除选项实际上会删除整个主题,所以我不会尝试使用它。

问题:如何完全删除主题级别配置,以便主题恢复为使用服务器默认设置?

apache-kafka

4
推荐指数
1
解决办法
4826
查看次数

要终止哪个进程才能停止 Kafka Connect Worker?

我想杀死我的 Kafka Connect 分布式工作程序,但我无法(或者我不知道如何)确定在 Linux 中运行的哪个进程是该工作程序。

跑步时

ps aux | grep worker
Run Code Online (Sandbox Code Playgroud)

我确实看到很多工作进程,但不确定哪个是连接工作进程,哪些是标准非连接工作进程

确实,昨天只启动了其中一个进程,我怀疑就是这个,但这显然不是所有情况下的充分条件,例如,如果 Kafka 集群昨天上线。那么,一般来说,我如何确定哪个进程是 Kafka Connect Worker?

这里的万无一失的方法是什么?

apache-kafka apache-kafka-connect

2
推荐指数
1
解决办法
3652
查看次数

标签 统计

apache-kafka ×2

apache-kafka-connect ×1