Danila Smolyakov

Results 6 comments of Danila Smolyakov

> It processes each topic-partition sequentially one at a time. Nothing is mentioned about different topics in [documentation of KafkaJS](https://github.com/nestjs/nest). For sure, messages in the same partition should be processed...

> Who said you can't process two topics in parallel though? I guess there is misunderstanding because we're not talking about `parallel` computations but about `concurrent`. Guys provided valid [test-case...

## Update after debugging File: `microservices/server/server-kafka.ts` Code: ```ts public async handleEvent( pattern: string, packet: ReadPacket, context: KafkaContext, ): Promise { const handler = this.getHandlerByPattern(pattern); if (!handler) { return this.logger.error(NO_EVENT_HANDLER`${pattern}`); }...

With using Blizzard's [node-rdkafka](https://github.com/Blizzard/node-rdkafka) everything works perfect **Code:** ```javascript var Transform = require('stream').Transform; const { randomInt } = require('crypto'); var Kafka = require('node-rdkafka'); var stream = Kafka.KafkaConsumer.createReadStream({ 'metadata.broker.list': 'localhost:9092', 'group.id':...

> `_uuid = const Uuid()` > > Don't do this, the uuid should be from the server. If you don't have an server, try hard code it, the duplicate will...

> My case is not fully tested but at the first look everything work fine I've changed the way for handling incoming call intent while on full screen activity: ```kotlin...