ok

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## v0.0.29 (2021-06-02)
+
+ * [6156b57](https://github.com/argoproj/argo-workflows/commit/6156b57f71d829df6eb8717d4a34de52a49d9511) fix: bug where we were not getting kafka secret
+
+### Contributors
+
+ * Alex Collins
+
 ## v0.0.28 (2021-05-27)
 
  * [57567e3](https://github.com/argoproj/argo-workflows/commit/57567e3cfae15ebcbd2b3801a2b3db3b3c4b68e9) fix!: change rate to resource.Quantity

config/ci.yaml

@@ -4332,6 +4332,13 @@ metadata:
 
       The secret must be named `dataflow-kafka-${name}`.
 
+      # Brokers as a comma-separated list
+      brokers: broker.a,broker.b
+      # Enable TLS
+      net.tls: ""
+      # Kafka version
+      version: "2.0.0"
+
       [Learn about configuration](../docs/CONFIGURATION.md)
     dataflow.argoproj.io/name: Default Kafka config
   name: dataflow-kafka-default

config/dev.yaml

@@ -4332,6 +4332,13 @@ metadata:
 
       The secret must be named `dataflow-kafka-${name}`.
 
+      # Brokers as a comma-separated list
+      brokers: broker.a,broker.b
+      # Enable TLS
+      net.tls: ""
+      # Kafka version
+      version: "2.0.0"
+
       [Learn about configuration](../docs/CONFIGURATION.md)
     dataflow.argoproj.io/name: Default Kafka config
   name: dataflow-kafka-default

docs/EXAMPLES.md

@@ -311,6 +311,13 @@ This is an example of providing a namespace named Kafka configuration.
 
 The secret must be named `dataflow-kafka-${name}`.
 
+# Brokers as a comma-separated list
+brokers: broker.a,broker.b
+# Enable TLS
+net.tls: ""
+# Kafka version
+version: "2.0.0"
+
 [Learn about configuration](../docs/CONFIGURATION.md)
 
 

shared/util/cpu.go

@@ -0,0 +1,9 @@
+package util
+
+import (
+	"runtime"
+)
+
+func init() {
+	logger.Info("cpu", "numCPU", runtime.NumCPU())
+}