Daniel Ferstay dferstay

dferstay / concurrent.kafka.consumer.py

Created November 2, 2024 03:08 — 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