faust

faust copied to clipboard

Sentry initialisation uses outdated raven packages resulting in constant warnings and inability to set environments

5

## Checklist - [x] I have included information about relevant versions - [x] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

karlokr-p

## Checklist - [-] I have included information about relevant versions - [-] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

cleomart

Question: how to enable JSON logging in Faust?

7

Hi, I would like to ask, how can I jsonify the output of Faust? I have tried to set logHandler of Faust with json-formatted log handler from `pythonjsonlogger`: ``` from...

GlorianY

Add features to support ssl_context for producer if broker_producer is used.

4

## Checklist - [X] I have included information about relevant versions - [X] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

youngsol

Storing commits on a database

1

Hi, This is more of a general question than an issue to reproduce, so please pardon me not following the template. Is it possible to store the offset of a...

jamesellis1999

how to create one polymorphic model

2

I want to be able to process 1 event that can have multiple schemas based on type. for example ```python class Event(faust.Record, serializer="json"): track_id: str class InsertDataEvent(Event): file_path: str type:...

KallieLev

Auto-commit in the processing thread?

3

## Checklist - [x] I have included information about relevant versions - [x] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

jamesellis1999

Question: Delayed retry queue implementation in Faust?

1

Hi, I'm trying to implement a delayed retry queue using Kafka and Faust. The idea is that after failing to process a message it gets forwarded to an RQ topic....

somnam

Need to handle Multi Threading for Manual Instrumentation in Faust Application and How to enable opentracing in Faust

3

Hi Team, Need help on below problem/implementation for Manual Instrumentation in python for faust streaming application. Currently on the streaming process we use async to manage concurrency on streaming part...

Chiraguthra

I am in the process of converting a legacy system that was using an in-house streaming package to Faust. We had our own "polymorphic typing" implementation that made messages look...

gpkc