From 732d848aee7e8818db13d7009bedfccb199b4f02 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Sat, 11 Nov 2017 15:40:26 +0100
Subject: [PATCH 1/9] Copies output/elasticsearch/

---
 output/kafka/fluent-bit-configmap.yaml   | 94 ++++++++++++++++++++++++
 output/kafka/fluent-bit-ds-minikube.yaml | 55 ++++++++++++++
 output/kafka/fluent-bit-ds.yaml          | 49 ++++++++++++
 3 files changed, 198 insertions(+)
 create mode 100644 output/kafka/fluent-bit-configmap.yaml
 create mode 100644 output/kafka/fluent-bit-ds-minikube.yaml
 create mode 100644 output/kafka/fluent-bit-ds.yaml

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
new file mode 100644
index 0000000..d2c2ae7
--- /dev/null
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -0,0 +1,94 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: fluent-bit-config
+  namespace: logging
+  labels:
+    k8s-app: fluent-bit
+data:
+  # Configuration files: server, input, filters and output
+  # ======================================================
+  fluent-bit.conf: |
+    [SERVICE]
+        Flush         1
+        Log_Level     info
+        Daemon        off
+        Parsers_File  parsers.conf
+
+    @INCLUDE input-kubernetes.conf
+    @INCLUDE filter-kubernetes.conf
+    @INCLUDE output-elasticsearch.conf
+
+  input-kubernetes.conf: |
+    [INPUT]
+        Name              tail
+        Tag               kube.*
+        Path              /var/log/containers/*.log
+        Parser            docker
+        DB                /var/log/flb_kube.db
+        Mem_Buf_Limit     5MB
+        Skip_Long_Lines   On
+        Refresh_Interval  10
+
+  filter-kubernetes.conf: |
+    [FILTER]
+        Name           kubernetes
+        Match          kube.*
+        Kube_URL       https://kubernetes.default.svc:443
+        Merge_JSON_Log On
+
+  output-elasticsearch.conf: |
+    [OUTPUT]
+        Name            es
+        Match           *
+        Host            ${FLUENT_ELASTICSEARCH_HOST}
+        Port            ${FLUENT_ELASTICSEARCH_PORT}
+        Logstash_Format On
+        Retry_Limit     False
+
+  parsers.conf: |
+    [PARSER]
+        Name   apache
+        Format regex
+        Regex  ^(?<host>[^ ]*) [^ ]* (?<user>[^ ]*) \[(?<time>[^\]]*)\] "(?<method>\S+)(?: +(?<path>[^\"]*?)(?: +\S*)?)?" (?<code>[^ ]*) (?<size>[^ ]*)(?: "(?<referer>[^\"]*)" "(?<agent>[^\"]*)")?$
+        Time_Key time
+        Time_Format %d/%b/%Y:%H:%M:%S %z
+
+    [PARSER]
+        Name   apache2
+        Format regex
+        Regex  ^(?<host>[^ ]*) [^ ]* (?<user>[^ ]*) \[(?<time>[^\]]*)\] "(?<method>\S+)(?: +(?<path>[^ ]*) +\S*)?" (?<code>[^ ]*) (?<size>[^ ]*)(?: "(?<referer>[^\"]*)" "(?<agent>[^\"]*)")?$
+        Time_Key time
+        Time_Format %d/%b/%Y:%H:%M:%S %z
+
+    [PARSER]
+        Name   apache_error
+        Format regex
+        Regex  ^\[[^ ]* (?<time>[^\]]*)\] \[(?<level>[^\]]*)\](?: \[pid (?<pid>[^\]]*)\])?( \[client (?<client>[^\]]*)\])? (?<message>.*)$
+
+    [PARSER]
+        Name   nginx
+        Format regex
+        Regex ^(?<remote>[^ ]*) (?<host>[^ ]*) (?<user>[^ ]*) \[(?<time>[^\]]*)\] "(?<method>\S+)(?: +(?<path>[^\"]*?)(?: +\S*)?)?" (?<code>[^ ]*) (?<size>[^ ]*)(?: "(?<referer>[^\"]*)" "(?<agent>[^\"]*)")?$
+        Time_Key time
+        Time_Format %d/%b/%Y:%H:%M:%S %z
+
+    [PARSER]
+        Name   json-test
+        Format json
+        Time_Key time
+        Time_Format %d/%b/%Y:%H:%M:%S %z
+
+    [PARSER]
+        Name        docker
+        Format      json
+        Time_Key    time
+        Time_Format %Y-%m-%dT%H:%M:%S.%L
+        Time_Keep   On
+
+    [PARSER]
+        Name        syslog
+        Format      regex
+        Regex       ^\<(?<pri>[0-9]+)\>(?<time>[^ ]* {1,2}[^ ]* [^ ]*) (?<host>[^ ]*) (?<ident>[a-zA-Z0-9_\/\.\-]*)(?:\[(?<pid>[0-9]+)\])?(?:[^\:]*\:)? *(?<message>.*)$
+        Time_Key    time
+        Time_Format %b %d %H:%M:%S
diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
new file mode 100644
index 0000000..c0ca1e5
--- /dev/null
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -0,0 +1,55 @@
+apiVersion: extensions/v1beta1
+kind: DaemonSet
+metadata:
+  name: fluent-bit
+  namespace: logging
+  labels:
+    k8s-app: fluent-bit-logging
+    version: v1
+    kubernetes.io/cluster-service: "true"
+spec:
+  template:
+    metadata:
+      labels:
+        k8s-app: fluent-bit-logging
+        version: v1
+        kubernetes.io/cluster-service: "true"
+    spec:
+      containers:
+      - name: fluent-bit
+        image: fluent/fluent-bit:0.12.7
+        env:
+        - name: FLUENT_ELASTICSEARCH_HOST
+          value: "elasticsearch"
+        - name: FLUENT_ELASTICSEARCH_PORT
+          value: "9200"
+        volumeMounts:
+        - name: varlog
+          mountPath: /var/log
+        - name: varlibdockercontainers
+          mountPath: /var/lib/docker/containers
+          readOnly: true
+        - name: fluent-bit-config
+          mountPath: /fluent-bit/etc/
+        - name: mnt
+          mountPath: /mnt
+          readOnly: true
+      terminationGracePeriodSeconds: 10
+      volumes:
+      - name: varlog
+        hostPath:
+          path: /var/log
+      - name: varlibdockercontainers
+        hostPath:
+          path: /var/lib/docker/containers
+      - name: fluent-bit-config
+        configMap:
+          name: fluent-bit-config
+      - name: mnt
+        hostPath:
+          path: /mnt
+      serviceAccountName: fluent-bit
+      tolerations:
+      - key: node-role.kubernetes.io/master
+        operator: Exists
+        effect: NoSchedule
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
new file mode 100644
index 0000000..7f0f231
--- /dev/null
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -0,0 +1,49 @@
+apiVersion: extensions/v1beta1
+kind: DaemonSet
+metadata:
+  name: fluent-bit
+  namespace: logging
+  labels:
+    k8s-app: fluent-bit-logging
+    version: v1
+    kubernetes.io/cluster-service: "true"
+spec:
+  template:
+    metadata:
+      labels:
+        k8s-app: fluent-bit-logging
+        version: v1
+        kubernetes.io/cluster-service: "true"
+    spec:
+      containers:
+      - name: fluent-bit
+        image: fluent/fluent-bit:0.12.8
+        env:
+        - name: FLUENT_ELASTICSEARCH_HOST
+          value: "elasticsearch"
+        - name: FLUENT_ELASTICSEARCH_PORT
+          value: "9200"
+        volumeMounts:
+        - name: varlog
+          mountPath: /var/log
+        - name: varlibdockercontainers
+          mountPath: /var/lib/docker/containers
+          readOnly: true
+        - name: fluent-bit-config
+          mountPath: /fluent-bit/etc/
+      terminationGracePeriodSeconds: 10
+      volumes:
+      - name: varlog
+        hostPath:
+          path: /var/log
+      - name: varlibdockercontainers
+        hostPath:
+          path: /var/lib/docker/containers
+      - name: fluent-bit-config
+        configMap:
+          name: fluent-bit-config
+      serviceAccountName: fluent-bit
+      tolerations:
+      - key: node-role.kubernetes.io/master
+        operator: Exists
+        effect: NoSchedule

From ecd371b3a89e01238f93addfd4ed6c51e1fdc481 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Sat, 11 Nov 2017 15:57:06 +0100
Subject: [PATCH 2/9] Configures current dev build of out_kafka,

with Yolean/kubernetes-kafka brokers.
---
 output/kafka/fluent-bit-configmap.yaml   | 13 ++++++-------
 output/kafka/fluent-bit-ds-minikube.yaml |  7 +------
 output/kafka/fluent-bit-ds.yaml          |  7 +------
 3 files changed, 8 insertions(+), 19 deletions(-)

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
index d2c2ae7..886f334 100644
--- a/output/kafka/fluent-bit-configmap.yaml
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -17,7 +17,7 @@ data:
 
     @INCLUDE input-kubernetes.conf
     @INCLUDE filter-kubernetes.conf
-    @INCLUDE output-elasticsearch.conf
+    @INCLUDE output-kafka.conf
 
   input-kubernetes.conf: |
     [INPUT]
@@ -37,14 +37,13 @@ data:
         Kube_URL       https://kubernetes.default.svc:443
         Merge_JSON_Log On
 
-  output-elasticsearch.conf: |
+  output-kafka.conf: |
     [OUTPUT]
-        Name            es
+        Name           kafka
         Match           *
-        Host            ${FLUENT_ELASTICSEARCH_HOST}
-        Port            ${FLUENT_ELASTICSEARCH_PORT}
-        Logstash_Format On
-        Retry_Limit     False
+        Brokers        kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
+        Topic          ops-kube-logs-fluentbit-001
+        Timestamp_Key  @timestamp
 
   parsers.conf: |
     [PARSER]
diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
index c0ca1e5..c9eb6ac 100644
--- a/output/kafka/fluent-bit-ds-minikube.yaml
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -17,12 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit:0.12.7
-        env:
-        - name: FLUENT_ELASTICSEARCH_HOST
-          value: "elasticsearch"
-        - name: FLUENT_ELASTICSEARCH_PORT
-          value: "9200"
+        image: fluent/fluent-bit-kafka-dev@sha256:35fbfb4238f6f2d384fe303d6b5c153c521a237414d423c1f8074a819b4b1170
         volumeMounts:
         - name: varlog
           mountPath: /var/log
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
index 7f0f231..e2985ff 100644
--- a/output/kafka/fluent-bit-ds.yaml
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -17,12 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit:0.12.8
-        env:
-        - name: FLUENT_ELASTICSEARCH_HOST
-          value: "elasticsearch"
-        - name: FLUENT_ELASTICSEARCH_PORT
-          value: "9200"
+        image: fluent/fluent-bit-kafka-dev@sha256:35fbfb4238f6f2d384fe303d6b5c153c521a237414d423c1f8074a819b4b1170
         volumeMounts:
         - name: varlog
           mountPath: /var/log

From 9b62ceac2b58659b63fa7f654b0c33e8d4ccdfcf Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Mon, 13 Nov 2017 14:04:35 +0100
Subject: [PATCH 3/9] Bumps to latest build, tag 0.2

---
 output/kafka/fluent-bit-configmap.yaml   | 2 +-
 output/kafka/fluent-bit-ds-minikube.yaml | 2 +-
 output/kafka/fluent-bit-ds.yaml          | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
index 886f334..5424a9b 100644
--- a/output/kafka/fluent-bit-configmap.yaml
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -42,7 +42,7 @@ data:
         Name           kafka
         Match           *
         Brokers        kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
-        Topic          ops-kube-logs-fluentbit-001
+        Topics         ops-kube-logs-fluentbit-001
         Timestamp_Key  @timestamp
 
   parsers.conf: |
diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
index c9eb6ac..91f331f 100644
--- a/output/kafka/fluent-bit-ds-minikube.yaml
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:35fbfb4238f6f2d384fe303d6b5c153c521a237414d423c1f8074a819b4b1170
+        image: fluent/fluent-bit-kafka-dev@sha256:34af750c4448876932c63967d9f5451295b0edb522a0595cd187e8286482598d
         volumeMounts:
         - name: varlog
           mountPath: /var/log
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
index e2985ff..b1538bb 100644
--- a/output/kafka/fluent-bit-ds.yaml
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:35fbfb4238f6f2d384fe303d6b5c153c521a237414d423c1f8074a819b4b1170
+        image: fluent/fluent-bit-kafka-dev@sha256:34af750c4448876932c63967d9f5451295b0edb522a0595cd187e8286482598d
         volumeMounts:
         - name: varlog
           mountPath: /var/log

From 1403cc9a74bd78d0bb67bf70df4cf50895956275 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 16 Nov 2017 07:29:03 +0100
Subject: [PATCH 4/9] Upgrades to :0.3 but keeps unencoded format

---
 output/kafka/fluent-bit-ds-minikube.yaml | 2 +-
 output/kafka/fluent-bit-ds.yaml          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
index 91f331f..943e33e 100644
--- a/output/kafka/fluent-bit-ds-minikube.yaml
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:34af750c4448876932c63967d9f5451295b0edb522a0595cd187e8286482598d
+        image: fluent/fluent-bit-kafka-dev@sha256:fffec8f663d17b0e121132f59e552e8ed88b48c801c4cec520433e6cb2f56d24
         volumeMounts:
         - name: varlog
           mountPath: /var/log
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
index b1538bb..5753353 100644
--- a/output/kafka/fluent-bit-ds.yaml
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:34af750c4448876932c63967d9f5451295b0edb522a0595cd187e8286482598d
+        image: fluent/fluent-bit-kafka-dev@sha256:fffec8f663d17b0e121132f59e552e8ed88b48c801c4cec520433e6cb2f56d24
         volumeMounts:
         - name: varlog
           mountPath: /var/log

From b988dd00ecf548fb0ca82bb1d8f38713146fcb9c Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 14 Dec 2017 06:52:50 +0100
Subject: [PATCH 5/9] New build from
 https://github.com/fluent/fluent-bit/issues/94

---
 output/kafka/fluent-bit-ds-minikube.yaml | 2 +-
 output/kafka/fluent-bit-ds.yaml          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
index 943e33e..ae9c0f9 100644
--- a/output/kafka/fluent-bit-ds-minikube.yaml
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:fffec8f663d17b0e121132f59e552e8ed88b48c801c4cec520433e6cb2f56d24
+        image: fluent/fluent-bit-kafka-dev:0.4@sha256:97621767bbe271cdda04c25702f57dc5e256ccddcf89386b1d6f539af74c46e6
         volumeMounts:
         - name: varlog
           mountPath: /var/log
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
index 5753353..664dfd5 100644
--- a/output/kafka/fluent-bit-ds.yaml
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev@sha256:fffec8f663d17b0e121132f59e552e8ed88b48c801c4cec520433e6cb2f56d24
+        image: fluent/fluent-bit-kafka-dev:0.4@sha256:97621767bbe271cdda04c25702f57dc5e256ccddcf89386b1d6f539af74c46e6
         volumeMounts:
         - name: varlog
           mountPath: /var/log

From e045ef1ef03f9fd299575a7aa9ca312e6687e441 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 14 Dec 2017 07:28:54 +0100
Subject: [PATCH 6/9] Elaborates on a naming convention

WIP in https://github.com/Yolean/kubernetes-kafka/issues/101
---
 output/kafka/fluent-bit-configmap.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
index 5424a9b..9f4f362 100644
--- a/output/kafka/fluent-bit-configmap.yaml
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -42,7 +42,7 @@ data:
         Name           kafka
         Match           *
         Brokers        kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
-        Topics         ops-kube-logs-fluentbit-001
+        Topics         ops.kube-logs-fluentbit.stream.json.001
         Timestamp_Key  @timestamp
 
   parsers.conf: |

From 15d82a557ba9a9ff3b6888e18c1ce7ddd293b224 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 14 Dec 2017 07:29:58 +0100
Subject: [PATCH 7/9] Uses the bootstrap service, to avoid error messages in
 smaller clusters

---
 output/kafka/fluent-bit-configmap.yaml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
index 9f4f362..34a2840 100644
--- a/output/kafka/fluent-bit-configmap.yaml
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -40,8 +40,8 @@ data:
   output-kafka.conf: |
     [OUTPUT]
         Name           kafka
-        Match           *
-        Brokers        kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
+        Match          *
+        Brokers        bootstrap.kafka:9092
         Topics         ops.kube-logs-fluentbit.stream.json.001
         Timestamp_Key  @timestamp
 

From 8765262eea3db1246ffe86fefb84baa24226c86c Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Tue, 19 Dec 2017 10:46:36 +0100
Subject: [PATCH 8/9] Recommends that we retry sending, forever - TODO: memory
 limits

---
 output/kafka/fluent-bit-configmap.yaml | 1 +
 1 file changed, 1 insertion(+)

diff --git a/output/kafka/fluent-bit-configmap.yaml b/output/kafka/fluent-bit-configmap.yaml
index 34a2840..3ff79c5 100644
--- a/output/kafka/fluent-bit-configmap.yaml
+++ b/output/kafka/fluent-bit-configmap.yaml
@@ -44,6 +44,7 @@ data:
         Brokers        bootstrap.kafka:9092
         Topics         ops.kube-logs-fluentbit.stream.json.001
         Timestamp_Key  @timestamp
+        Retry_Limit    false
 
   parsers.conf: |
     [PARSER]

From 7945b661cee4f6b5b8c5dcbaf84ddfcb95982a3e Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Fri, 22 Dec 2017 20:43:05 +0100
Subject: [PATCH 9/9] Upgrades to latest fluent-bit-kafka-dev image, librdkafka
 0.11.3

---
 output/kafka/fluent-bit-ds-minikube.yaml | 2 +-
 output/kafka/fluent-bit-ds.yaml          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/output/kafka/fluent-bit-ds-minikube.yaml b/output/kafka/fluent-bit-ds-minikube.yaml
index ae9c0f9..27908ab 100644
--- a/output/kafka/fluent-bit-ds-minikube.yaml
+++ b/output/kafka/fluent-bit-ds-minikube.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev:0.4@sha256:97621767bbe271cdda04c25702f57dc5e256ccddcf89386b1d6f539af74c46e6
+        image: fluent/fluent-bit-kafka-dev:0.5@sha256:8f651e4e03239bcd758bffdcc7d16eba38d5e96876757e6ccff29b4eff2e3241
         volumeMounts:
         - name: varlog
           mountPath: /var/log
diff --git a/output/kafka/fluent-bit-ds.yaml b/output/kafka/fluent-bit-ds.yaml
index 664dfd5..843c747 100644
--- a/output/kafka/fluent-bit-ds.yaml
+++ b/output/kafka/fluent-bit-ds.yaml
@@ -17,7 +17,7 @@ spec:
     spec:
       containers:
       - name: fluent-bit
-        image: fluent/fluent-bit-kafka-dev:0.4@sha256:97621767bbe271cdda04c25702f57dc5e256ccddcf89386b1d6f539af74c46e6
+        image: fluent/fluent-bit-kafka-dev:0.5@sha256:8f651e4e03239bcd758bffdcc7d16eba38d5e96876757e6ccff29b4eff2e3241
         volumeMounts:
         - name: varlog
           mountPath: /var/log