Erik Forsberg

Results 43 comments of Erik Forsberg

The registry does have something it calls schema references, which may or may not be what you're after: https://docs.confluent.io/current/schema-registry/serdes-develop/index.html#referenced-schemas

It seems codecov is installed in the virtualenv `venv`, but I'm using virtualenvwrapper to create and switch between virtualenvs, and this seems unsupported by the install script.

Inspecting code, [line 692](https://github.com/faust-streaming/faust/blob/master/faust/tables/recovery.py#L692) seems very suspicious. I guess it tries to compensate for [line 644](https://github.com/faust-streaming/faust/blob/master/faust/tables/recovery.py#L644) In [_seek_offsets](https://github.com/faust-streaming/faust/blob/master/faust/tables/recovery.py#L729) we see that the code handles the case when earliest_offset was 0,...

I hit a side-effect of this today in a rather annoying way. Consider the following example schema: ``` {'type': 'record', 'name': 'ID', 'namespace': 'com.example', 'fields': [{'doc': 'ID', 'name': 'id', 'type':...

I see this a lot when in catchup mode. I.e, under normal operations, I can have a couple of instances of the Kafka Connect cluster running with a normal amount...

I tried running master through travis and [got the same error](https://travis-ci.org/github/forsberg/faust/jobs/737302314). The job succeeded on exactly the same source code [11 days ago](https://travis-ci.org/github/robinhood/faust/jobs/734281804), so indeed it seems unrelated. One difference...

Opened #672 for this.

Note that setup.py for [robinhood-aiokafka](https://github.com/robinhood/aiokafka), the fork of aiokafka used by Faust, will happily build itself into a wheel even if it failed to compile some of the C extensions....

@jheinnic - no, that will work without `sink=[]`, in this case sink_topic is created outside the funciton `app.topic()` or `app.channel()` See for example https://github.com/marcosschroh/faust-docker-compose-example/blob/master/faust-project/example/users/agents.py#L23

Noteworthy is that `app.test_context()` won't work, it expects the code to `yield`, but there's probably some workaround for that.