Merge branch '12-kafka-message-key-null' into 'master'

Add key to the second producer

Closes #12

See merge request histhub/wikidata-normalizer!23

src/index.ts

@@ -71,7 +71,7 @@ kafka.init().then(async () => {
       .pipe(new ReporterCounter({objectMode: true}, core.getReporter(10000, 'normalizer'), 'read'))
       .pipe(new WikiNormalizer({objectMode: true}, core.getLogger(), wikidataProperties))
       .pipe(new ReporterCounter({objectMode: true}, core.getReporter('normalizer'), 'write'))
-      .pipe(new StreamProducerPreparer({objectMode: true, topic: core.getNconf().get('producer:normalizer:topics'), partition: -1}))
+      .pipe(new StreamProducerPreparer({objectMode: true, topic: core.getNconf().get('producer:normalizer:topics'), partition: -1, key: (d) => `${d.provider}${d.id}`}))
       .pipe(new Debug({objectMode: true}, '---'))
       .pipe(new ProducerStream(normProducer, {objectMode: true, topic: core.getNconf().get('producer:normalizer:topics')}));