Skip to content

Instantly share code, notes, and snippets.

View dthuering's full-sized avatar

Danny Thuering dthuering

View GitHub Profile
@dthuering
dthuering / main.py
Created November 28, 2024 08:30
Python Confluent Kafka consumer in an event loop with FastAPI
from contextlib import asynccontextmanager
from fastapi import FastAPI
import asyncio
import os
import logging
from confluent_kafka import KafkaException
from confluent_kafka.deserializing_consumer import DeserializingConsumer
from confluent_kafka.serialization import StringDeserializer
import uvicorn
import React from "react";
import "./MethodCall.css";
type MethodCallProps = {
methodSignature: string;
methodArgs: any[];
definition?: any;
};
export const MethodCall: React.FC<MethodCallProps> = ({

Keybase proof

I hereby claim:

  • I am dthuering on github.
  • I am dannyt74 (https://keybase.io/dannyt74) on keybase.
  • I have a public key ASAuddBOoX37_XgsWl63ylZVimL7bD_bQXo3vO4ymeU3TAo

To claim this, I am signing this object: