Skip to content

Instantly share code, notes, and snippets.

@phgSW61HS
phgSW61HS / concurrent.kafka.consumer.py
Created January 17, 2022 21:50 — forked from pvsune/concurrent.kafka.consumer.py
A multiprocess multithreaded Kafka consumer
#!/usr/bin/env python
import logging
import os
import threading
import time
from multiprocessing import Process
from queue import Queue
from confluent_kafka import Consumer
@phgSW61HS
phgSW61HS / nginx-ingress-controller.yaml
Created November 27, 2020 07:32 — forked from thilinapiy/nginx-ingress-controller.yaml
Complete nginx-ingress-controller yaml file.
---
apiVersion: v1
kind: Namespace
metadata:
name: ingress-nginx
---
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: default-http-backend