Kafka trigger (#530)

* feat(kafka-trigger): added kafka trigger

* feat(kafka-trigger): added kafka producers to sensor context

* feat(kafka-trigger): added kafka trigger tests

Gopkg.toml

@@ -78,7 +78,7 @@ required = [
 
 [[constraint]]
   name = "github.com/Shopify/sarama"
-  version = "v1.23.0"
+  version = "v1.26.1"
 
 [[constraint]]
   name = "github.com/stretchr/testify"
@@ -160,6 +160,10 @@ required = [
     name = "k8s.io/gengo"
     unused-packages = false
 
+  [[prune.project]]
+    name = "github.com/Shopify/sarama"
+    unused-packages = false
+
 [[constraint]]
   name = "github.com/google/go-github"
   revision = "50be09d24ee31a2b0868265e76c24b9545a6eb7a"

Makefile

@@ -17,7 +17,7 @@ override LDFLAGS += \
 #  docker image publishing options
 DOCKER_PUSH?=true
 IMAGE_NAMESPACE?=argoproj
-IMAGE_TAG?=v0.13.0-rc
+IMAGE_TAG?=v0.13.0
 BUILD_BINARY?=true
 
 ifeq (${DOCKER_PUSH},true)

api/event-source.html

@@ -722,7 +722,7 @@ <h3 id="argoproj.io/v1alpha1.EventSourceSpec">EventSourceSpec
 <td>
 <code>type</code></br>
 <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
+Argo Events common.EventSourceType
 </em>
 </td>
 <td>
@@ -1932,6 +1932,18 @@ <h3 id="argoproj.io/v1alpha1.SNSEventSource">SNSEventSource
 <p>Region is AWS region</p>
 </td>
 </tr>
+<tr>
+<td>
+<code>roleARN</code></br>
+<em>
+string
+</em>
+</td>
+<td>
+<em>(Optional)</em>
+<p>RoleARN is the Amazon Resource Name (ARN) of the role to assume.</p>
+</td>
+</tr>
 </tbody>
 </table>
 <h3 id="argoproj.io/v1alpha1.SQSEventSource">SQSEventSource
@@ -2023,6 +2035,18 @@ <h3 id="argoproj.io/v1alpha1.SQSEventSource">SQSEventSource
 <p>Namespace refers to Kubernetes namespace to read access related secret from.</p>
 </td>
 </tr>
+<tr>
+<td>
+<code>roleARN</code></br>
+<em>
+string
+</em>
+</td>
+<td>
+<em>(Optional)</em>
+<p>RoleARN is the Amazon Resource Name (ARN) of the role to assume.</p>
+</td>
+</tr>
 </tbody>
 </table>
 <h3 id="argoproj.io/v1alpha1.SlackEventSource">SlackEventSource
@@ -2272,5 +2296,5 @@ <h3 id="argoproj.io/v1alpha1.StripeEventSource">StripeEventSource
 <hr/>
 <p><em>
 Generated with <code>gen-crd-api-reference-docs</code>
-on git commit <code>95e393b</code>.
+on git commit <code>d0d11e4</code>.
 </em></p>

api/event-source.md

@@ -1397,8 +1397,7 @@ Generic event source
 
 <td>
 
-<code>type</code></br> <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
+<code>type</code></br> <em> Argo Events common.EventSourceType </em>
 
 </td>
 
@@ -3833,6 +3832,28 @@ Region is AWS region
 
 </tr>
 
+<tr>
+
+<td>
+
+<code>roleARN</code></br> <em> string </em>
+
+</td>
+
+<td>
+
+<em>(Optional)</em>
+
+<p>
+
+RoleARN is the Amazon Resource Name (ARN) of the role to assume.
+
+</p>
+
+</td>
+
+</tr>
+
 </tbody>
 
 </table>
@@ -4012,6 +4033,28 @@ from.
 
 </tr>
 
+<tr>
+
+<td>
+
+<code>roleARN</code></br> <em> string </em>
+
+</td>
+
+<td>
+
+<em>(Optional)</em>
+
+<p>
+
+RoleARN is the Amazon Resource Name (ARN) of the role to assume.
+
+</p>
+
+</td>
+
+</tr>
+
 </tbody>
 
 </table>
@@ -4527,6 +4570,6 @@ all types of events will be processed. More info at
 <p>
 
 <em> Generated with <code>gen-crd-api-reference-docs</code> on git
-commit <code>95e393b</code>. </em>
+commit <code>d0d11e4</code>. </em>
 
 </p>

api/gateway.html

@@ -136,7 +136,7 @@ <h3 id="argoproj.io/v1alpha1.Gateway">Gateway
 <td>
 <code>type</code></br>
 <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
+Argo Events common.EventSourceType
 </em>
 </td>
 <td>
@@ -186,7 +186,7 @@ <h3 id="argoproj.io/v1alpha1.Gateway">Gateway
 <td>
 <code>eventProtocol</code></br>
 <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventProtocol
+Argo Events common.EventProtocol
 </em>
 </td>
 <td>
@@ -304,7 +304,7 @@ <h3 id="argoproj.io/v1alpha1.GatewaySpec">GatewaySpec
 <td>
 <code>type</code></br>
 <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
+Argo Events common.EventSourceType
 </em>
 </td>
 <td>
@@ -354,7 +354,7 @@ <h3 id="argoproj.io/v1alpha1.GatewaySpec">GatewaySpec
 <td>
 <code>eventProtocol</code></br>
 <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventProtocol
+Argo Events common.EventProtocol
 </em>
 </td>
 <td>
@@ -671,5 +671,5 @@ <h3 id="argoproj.io/v1alpha1.Subscribers">Subscribers
 <hr/>
 <p><em>
 Generated with <code>gen-crd-api-reference-docs</code>
-on git commit <code>95e393b</code>.
+on git commit <code>d0d11e4</code>.
 </em></p>

api/gateway.md

@@ -270,8 +270,7 @@ configurations for the gateway
 
 <td>
 
-<code>type</code></br> <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
+<code>type</code></br> <em> Argo Events common.EventSourceType </em>
 
 </td>
 
@@ -358,8 +357,8 @@ Port on which the gateway event source processor is running on.
 
 <td>
 
-<code>eventProtocol</code></br> <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventProtocol </em>
+<code>eventProtocol</code></br> <em> Argo Events common.EventProtocol
+</em>
 
 </td>
 
@@ -601,8 +600,7 @@ configurations for the gateway
 
 <td>
 
-<code>type</code></br> <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
+<code>type</code></br> <em> Argo Events common.EventSourceType </em>
 
 </td>
 
@@ -689,8 +687,8 @@ Port on which the gateway event source processor is running on.
 
 <td>
 
-<code>eventProtocol</code></br> <em>
-github.com/argoproj/argo-events/pkg/apis/common.EventProtocol </em>
+<code>eventProtocol</code></br> <em> Argo Events common.EventProtocol
+</em>
 
 </td>
 
@@ -1323,6 +1321,6 @@ NATS refers to the subscribers over NATS protocol.
 <p>
 
 <em> Generated with <code>gen-crd-api-reference-docs</code> on git
-commit <code>95e393b</code>. </em>
+commit <code>d0d11e4</code>. </em>
 
 </p>