apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: kafka-channel-display0
spec:
  template:
    spec:
      containers:
      - image: docker.io/cds19/event-display

---

apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: kafka-channel-display1
spec:
  template:
    spec:
      containers:
      - image: docker.io/cds19/event-display
---
apiVersion: messaging.knative.dev/v1alpha1
kind: KafkaChannel
metadata:
  name: kafka-demo-channel
spec:
    numPartitions: 3
    replicationFactor: 1
---
apiVersion: sources.eventing.knative.dev/v1alpha1
kind: KafkaSource
metadata:
  name: kafka-channel-source
  namespace: default
spec:
  consumerGroup: knative-group
  bootstrapServers: my-cluster-kafka-bootstrap.kafka:9092 #note the kafka namespace
  topics: knative-demo-kafka-channel-topic #note the different topic
  sink:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: KafkaChannel
    name: kafka-demo-channel #note the different channel name
---
apiVersion: eventing.knative.dev/v1alpha1
kind: Subscription
metadata:
  name: kafka-channel-sub0
spec:
  channel:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: kafkaChannel
    name: kafka-demo-channel
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1alpha1
      kind: Service
      name: kafka-channel-display0
  # reply:
  #   channel:
  #     apiVersion: eventing.knative.dev/v1alpha1
  #     kind: Channel
  #     name: replychannel
---
apiVersion: eventing.knative.dev/v1alpha1
kind: Subscription
metadata:
  name: kafka-channel-sub1
spec:
  channel:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: kafkaChannel
    name: kafka-demo-channel
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1alpha1
      kind: Service
      name: kafka-channel-display1
  # reply:
  #   channel:
  #     apiVersion: eventing.knative.dev/v1alpha1
  #     kind: Channel
  #     name: replychannel
---
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaTopic
metadata:
  name: knative-demo-kafka-channel-topic
  namespace: kafka
  labels:
    strimzi.io/cluster: my-cluster
spec:
  partitions: 3
  replicas: 1
  config:
    retention.ms: 7200000
    segment.bytes: 1073741824
---
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaTopic
metadata:
  name: knative-demo-channel
  labels:
    strimzi.io/cluster: my-cluster
spec:
  partitions: 3
  replicas: 1
  config:
    retention.ms: 7200000
    segment.bytes: 1073741824