Skip to content

Instantly share code, notes, and snippets.

@javajon

javajon/kafka-quick-testing

Created February 27, 2022 17:18
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save javajon/e2d61fb6f0630428f454679f63abb60b to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save javajon/e2d61fb6f0630428f454679f63abb60b to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. javajon created this gist Feb 27, 2022.
    117 changes: 117 additions & 0 deletions kafka-quick-testing
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,117 @@
    apiVersion: apps/v1
    kind: Deployment
    metadata:
    name: kafka-broker
    labels:
    app: kafka
    spec:
    replicas: 1
    selector:
    matchLabels:
    app: kafka
    template:
    metadata:
    labels:
    app: kafka
    id: "0"
    spec:
    containers:
    - name: kafka
    image: wurstmeister/kafka
    ports:
    - containerPort: 9092
    env:
    - name: KAFKA_ADVERTISED_PORT
    value: "9092"
    - name: KAFKA_ADVERTISED_HOST_NAME
    value: kafka-service
    - name: KAFKA_ZOOKEEPER_CONNECT
    value: zoo1:2181
    - name: KAFKA_BROKER_ID
    value: "0"
    - name: KAFKA_CREATE_TOPICS
    value: sample.topic:1:1
    ---
    apiVersion: v1
    kind: Service
    metadata:
    name: kafka-service
    labels:
    name: kafka
    spec:
    ports:
    - port: 9092
    name: kafka-port
    protocol: TCP
    selector:
    app: kafka
    id: "0"
    ---
    apiVersion: apps/v1
    kind: Deployment
    metadata:
    name: zookeeper-deployment-1
    labels:
    app: zookeeper
    spec:
    replicas: 2
    selector:
    matchLabels:
    app: zookeeper-1
    template:
    metadata:
    labels:
    app: zookeeper-1
    spec:
    containers:
    - name: zookeeper
    image: digitalwonderland/zookeeper:latest
    ports:
    - containerPort: 2181
    env:
    - name: ZOOKEEPER_ID
    value: "1"
    - name: ZOOKEEPER_SERVER_1
    value: zoo1
    ---
    apiVersion: v1
    kind: Service
    metadata:
    name: zoo1
    labels:
    app: zookeeper-1
    spec:
    ports:
    - name: client
    port: 2181
    protocol: TCP
    - name: follower
    port: 2888
    protocol: TCP
    - name: leader
    port: 3888
    protocol: TCP
    selector:
    app: zookeeper-1
    ---
    apiVersion: apps/v1
    kind: Deployment
    metadata:
    name: kafka-cat
    labels:
    app: kcat
    spec:
    replicas: 1
    selector:
    matchLabels:
    app: kcat
    template:
    metadata:
    labels:
    app: kcat
    spec:
    containers:
    - name: kcat
    image: confluentinc/cp-kafkacat:7.0.1
    command: ["/bin/sh"]
    args: ["-c", "trap : TERM INT; sleep infinity & wait"]