Vincent Maurin

Try to reproduce error 41

1

### Changes The goal of this branch is to reproduce an error of not sending the create/delete topics command to the controller, and getting an error code 41, to then...

Wrong last consumed offset when using transaction

2

**Describe the bug** Here what I posted on the kafka user mailing list > I am working on an exactly once stream processors in Python, using > aiokafka client library....

[QUESTION] What are the requirements for the C extensions ?

2

It seems by default aiokafka tries to load C extensions for core/cpu intensive operations. I have seen various blocks initializing it like ```py try: from ._crecords import ( DefaultRecordBatchBuilder as...

**Describe the solution you'd like** Serializers and deserializers should receive more context about the record they are working on : * the headers * the topic It is especially useful...

processing_guarantee="exactly_once" crashes at startup

2

## Steps to reproduce Create a simple app with `processing_guarantee="exactly_once"` ```py import faust from faust.types import ProcessingGuarantee class Content(faust.Record, include_metadata=False): content_id: str content: str app = faust.App( "faust-poc", broker="aiokafka://kafka:9092", store="memory://",...

Allow optional properties to be truely optional

9

### Initial Checks - [X] I have searched Google & GitHub for similar requests and couldn't find anything - [X] I have read and followed [the docs](https://docs.pydantic.dev) and still think...