面子

0 声望

这家伙太懒,什么都没留下

个人动态
  • 赞了 面子Kubernetes如何删除已完成的pod(completed)? 的评论!

    你可以很轻松地清理。

    可以通过以下方式列出所有已完成的pod:

    kubectl get pod --field-selector=status.phase==Succeeded
    

    并通过以下方式删除所有已完成的pod:

    kubectl delete pod --field-selector=status.phase==Succeeded
    
    2年前
  • 赞了 面子kafka分区数据量不均衡 的评论!

    你没设置key,所以kafka消息发送是轮询批量的方式发送到各个分区。

    消息的差异是日积月累产生的,平均到每天的话并不大,可以忽视。

    不平均要从生产者源头确认,举个例子,你有8个分区,生产者是轮询的发送,消息并不是立即发送,而是打包到一个批次后,一起发送到第一个分区,但是什么时候发送受2个参数batch.sizelinger.ms的影响,就是消息大小达到1M或者0.1秒了,就立即发送。

    基于以上的逻辑,推测你的客户端,产生的消息量并不是平均的,所以每次轮询推送到这些分区的消息批次,正好少那么一些。

    2年前
  • 半兽人 回复 面子kafka分区数据量不均衡 中 :

    你没设置key,所以kafka消息发送是轮询批量的方式发送到各个分区。

    消息的差异是日积月累产生的,平均到每天的话并不大,可以忽视。

    不平均要从生产者源头确认,举个例子,你有8个分区,生产者是轮询的发送,消息并不是立即发送,而是打包到一个批次后,一起发送到第一个分区,但是什么时候发送受2个参数batch.sizelinger.ms的影响,就是消息大小达到1M或者0.1秒了,就立即发送。

    基于以上的逻辑,推测你的客户端,产生的消息量并不是平均的,所以每次轮询推送到这些分区的消息批次,正好少那么一些。

    2年前
  • 2年前