DHIS2 KAFKA Integration

Hello Community, I am using DHIS2 2.31 to carrying out a bulk import of tracked entities using KAFKA integration, However, I keep getting the following error in the DHIS2 logs. Kindly advise on what the issue might be. Many thanks.

>     * INFO  2021-03-13 13:08:25,020 'system-process' create org.hisp.dhis.message.MessageConversation, name: Job 'Kafka Tracker Consume' failed, uid: r86vwrps8D4 (AuditLogUtil.java [taskScheduler-20])
> * INFO  2021-03-13 13:08:25,023 no recipient (SmsMessageSender.java [taskScheduler-17])
> * ERROR 2021-03-13 13:08:25,029 Job 'Kafka Tracker Consume' failed (DefaultJobInstance.java [taskScheduler-20])
> java.lang.NullPointerException: element cannot be mapped to a null key
>         at java.util.Objects.requireNonNull(Unknown Source)
>         at java.util.stream.Collectors.lambda$groupingBy$45(Unknown Source)
>         at java.util.stream.ReduceOps$3ReducingSink.accept(Unknown Source)
>         at java.util.Iterator.forEachRemaining(Unknown Source)
>         at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Unknown Source)
>         at java.util.stream.AbstractPipeline.copyInto(Unknown Source)
>         at java.util.stream.AbstractPipeline.wrapAndCopyInto(Unknown Source)
>         at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(Unknown Source)
>         at java.util.stream.AbstractPipeline.evaluate(Unknown Source)
>         at java.util.stream.ReferencePipeline.collect(Unknown Source)
>         at org.hisp.dhis.dxf2.events.kafka.DefaultTrackerKafkaManager.consumeTrackedEntities(DefaultTrackerKafkaManager.java:393)
1 Like

@Nguza_Yikona how are you? Thank you for sharing and for your patience! Are you still facing this issue?

One question please, would you consider upgrading your instance to the latest DHIS2 versions. I am sure you will notice the difference,