disable leader election (#173) (#1663)

lionelvillard · web-flow · commit 1f575c2dcd2a · 2020-11-09T06:24:09.000-08:00
diff --git a/kafka/channel/cmd/channel_dispatcher/main.go b/kafka/channel/cmd/channel_dispatcher/main.go
@@ -35,5 +35,8 @@ func main() {
 		ctx = injection.WithNamespaceScope(ctx, ns)
 	}
 
+	// Do not run the dispatcher in leader-election mode
+	ctx = sharedmain.WithHADisabled(ctx)
+
 	sharedmain.MainWithContext(ctx, component, controller.NewController)
 }
diff --git a/kafka/channel/config/roles/dispatcher-clusterrole.yaml b/kafka/channel/config/roles/dispatcher-clusterrole.yaml
@@ -68,14 +68,3 @@ rules:
     verbs:
       - create
       - patch
-  - apiGroups:
-      - "coordination.k8s.io"
-    resources:
-      - leases
-    verbs:
-      - get
-      - list
-      - watch
-      - create
-      - patch
-      - update

Original file line number	Diff line number	Diff line change
`@@ -35,5 +35,8 @@ func main() {`
`35`	`35`	`ctx = injection.WithNamespaceScope(ctx, ns)`
`36`	`36`	`}`
`37`	`37`
	`38`	`+ // Do not run the dispatcher in leader-election mode`
	`39`	`+ ctx = sharedmain.WithHADisabled(ctx)`
	`40`	`+`
`38`	`41`	`sharedmain.MainWithContext(ctx, component, controller.NewController)`
`39`	`42`	`}`