Andreas Kohn
Andreas Kohn
Oops, missed this. :/ I'm no longer using this library, so right now can not do any updates.
Record-keeping: #89 probably further complicates use in the hybrid mode.
I'm also having issues with relative paths and the rev-replace plugin, if this could be merged it would help me a lot. Can I help moving this forward?
FWIW: I think it would be "nice to have" an unsubscribe functionality, and I would assume that this basically boils down to implementing reasonable ways to change the target topics...
Remove typo-type: https://github.com/tulios/kafkajs/blob/addcd6f8bd1169b053fb633ee11c8cc3b9ae608e/types/index.d.ts#L729-L730
This looks similar to the issue we saw in #775.
> `setInterval(() => { ... resetTheConsumer(...).then(...) }, process.env.DEFAULT_MESSAGE_POLLING_TIME)` I don't see that you posted your `resetTheConsumer` function, but the name is very very suspicious: Are you really reconnecting each time?...
> Kafka version 2.2.1 (Amazon MSK) vs > "broker": "localhost:9092", This doesn't add up I think, are you sure you're looking at the right broker?
> Ditching MSK and using another Kafka implementation > We have seen some odd stuff from MSK in the past, but I can't remember if it was related. Mostly as...
Good one, also should mention this here: We ([NEXT Technologies](https://www.nextapp.co/)) are using KafkaJS to power our platform of about 40 microservices written in TypeScript (event sourcing). We use Kafka hosted...