Marcos Schroh
Marcos Schroh
Hi @tvoinarovskyi Thanks for taking a look. I see 2 problems here: 1. Why do I need to always use the `Consumer.subscribe` method if I want to use a `RebalanceListener`?...
Hi, I am happy to help to maintain this project. We are using `aiokafka` on prod and we want to avoid a `fork`. Do you think it is possible?
You should use `from aiokafka.admin import AIOKafkaAdminClient`
Hi @sagungargs15, Thanks for reporting the issue. I will try to take a look asap
Hi @sagungargs15 if you register the codec in the `setup.py`, does it work? Can you confirm this?
HI @nhuber-tc , Thanks for reporting the issue. I will have to take a look but `annotations` is doing, but this library is prepared to work with `dataclasses` (`python 3.7`...
Usually I resolve this issue using the class name between quotes or `typing.Type["MyClassName"]`. I will try to take a look but seems a hard task because I have to inspect...
Cool, thanks. I found the issue. The code `from __future__ import annotations` makes `dataclasses.Field.type` return always a `string` instead of a `type`. In python 3.10 resolving this issue is really...
Hi @tritas Thanks for the proposal. What about having this option in the `Meta class`: ```python class MyAvroModel(AvroModel): ... my_date_time: datetime.datetime my_time: datetime.time class Meta: datetime_precision = "timestamp-micros" time_precision =...
I will try to solve this asap.