やり方は https://wyukawa.hatenablog.com/entry/20180124/1516762676 と同じで上書きアップグレードじゃなくて新旧double writeして切り替えました。 うちの環境だとfluentd→kafka→kafka-fluentd-consumer→fluentd→Elasticsearchという経路でElasticsearch…