Robert Shepherd

Hi @RichardWright this would be run as a standalone service ideally in a container and use Kafka as the source of truth. Think of these apps as microservices

Hi Filipmacek, Apologies for the late reply. The reason i choose to use kafkaJS vs the kafka-streams project is that they are two different use cases, one is a kafka...

Hi @maxgr0 Thanks! 😁 So the current workflow I have while using this library is to restart the service in order to pick up the new schema version. I know...

I think having something like a TTL for the `serialize` would make sense so that it would auto update to the latest schema without requiring intervention. I think that implementation...

Hi @maxgr0 sorry for the delay, I've pushed out this change to master, will look to get through testing this later today/tomorrow.

@maxgr0 thanks! Though to be fair the guys over at KafkaJS could use the beers more than i :)

So value can be the value itself such as the avro file otherwise its the avro schema value. This allows you to specify a different schema name for the value...

@newhouse do you have an example of how this could be done? or a way to add custom metadata. I'd like to be able to add docs such as auth...

Just added a branch to update this. 1df41058e7ad4c9917f6909c0740350773f90aee

Hey @khirr this is probably something that nestjs could help with, by default the service will fail to start if it can't connect to kafka and as such you could...