Add a key to the kafka message

src/index.ts

@@ -80,7 +80,7 @@ kafka.init().then(async () => {
       .pipe(new ReporterCounter({objectMode: true}, core.getReporter(10000, 'analyser'), 'read'))
       .pipe(new AnalyserTransformable({objectMode: true}, core.getUriBuilder(), core.getNconf()))
       .pipe(new ReporterCounter({objectMode: true}, core.getReporter(10000, 'analyser'), 'write'))
-      .pipe(new StreamProducerPreparer({objectMode: true, topic: core.getNconf().get('producer:analyser:topics'), partition: -1}))
+      .pipe(new StreamProducerPreparer({objectMode: true, topic: core.getNconf().get('producer:analyser:topics'), partition: -1, key: (d) => d.id}))
       .pipe(new ProducerStream(analyseProducer, {objectMode: true, topic: core.getNconf().get('producer:analyser:topics')}));
     core.getLogger().info('Pipes are registered');
   } catch (error) {