Files
SivananthamandGitHub 6ee5c481e4 Update kafka example (#2817)
Signed-off-by: Sivanantham Chinnaiyan <[email protected]>
2023-05-19 21:59:23 -04:00

19 lines
511 B
YAML

apiVersion: sources.knative.dev/v1beta1
kind: KafkaSource
metadata:
name: kafka-source
spec:
consumerGroup: knative-group
# Broker URL. Replace this with the URLs for your kafka cluster,
# which is in the format of my-cluster-kafka-bootstrap.my-kafka-namespace:9092.
bootstrapServers:
- kafka-headless.default.svc.cluster.local:9092
topics:
- mnist
sink:
ref:
apiVersion: serving.kserve.io/v1beta1
kind: InferenceService
name: mnist
uri: /v1/models/mnist:predict