JR61151: JAVA.LANG.NULLPOINTEREXCEPTIONERROR WITH LOB DATA USING KAFKA.KCOPMULTIROWAVROLIVEAUDITINTEGRATED

APAR status

• Closed as program error.

Error description

• got java.lang.NullPointerExceptionerror when updating primary
  key
   columns and delete rows with LOB data using
  kafka.KcopMultiRowAvroLiveAuditIntegrated
  
  
  377    2019-05-31 16:53:52.159    <subscription> Kafka Target
  Formatter:0{283}    com.datamirror.ts.util.TsExceptionHandler
   processUnhandledException()    An uncaught exception has
  occurred: ?org.apache.kafka.common.errors.SerializationException
   Error serializing Avro message|Caused by:
  java.lang.NullPointerException null of bytes in field LMSGBODY
  of value.<table name> |    at
  org.apache.avro.generic.GenericDatumWriter.npe(GenericDatumWrite
  r.java:132)|    at
  org.apache.avro.generic.GenericDatumWriter.writeWithoutConversio
  n(GenericDatumWriter.java:126)|    at
  org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWri
  ter.java:73)|    at
  org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWri
  ter.java:60)|    at
  io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.seria
  lizeImpl(AbstractKafkaAvroSerializer.java:101)|    at
  io.confluent.kafka.serializers.KafkaAvroSerializer.serialize(Kaf
  kaAvroSerializer.java:53)
  

Local fix

Problem summary

• ****************************************************************
  * USERS AFFECTED:                                              *
  * This issue may affect you if you are replicating data using  *
  * CDC for Kafka as a target, a subscription is configured to   *
  * use KcopMultiRowAvroLiveAuditIntegrated, and a source table  *
  * containing LOBs has primary key value updates.               *
  ****************************************************************
  * PROBLEM DESCRIPTION:                                         *
  * Replication ends on error while replicating a table that has *
  * LOB columns into Kafka, using                                *
  * KcopMultiRowAvroLiveAuditIntegrated. The event log or        *
  * product trace log includes the following exception:          *
  *                                                              *
  * <subscription> Kafka Target Formatter:0{283}                 *
  * com.datamirror.ts.util.TsExceptionHandler                    *
  * processUnhandledException()    An uncaught exception has     *
  * occurred:                                                    *
  * ?org.apache.kafka.common.errors.SerializationException       *
  * Error serializing Avro message|Caused by:                    *
  * java.lang.NullPointerException null of bytes in field        *
  * LMSGBODY of value.<table name>|    at                        *
  * org.apache.avro.generic.GenericDatumWriter.npe(GenericDatumW *
  * riter.java:132)|    at                                       *
  * org.apache.avro.generic.GenericDatumWriter.writeWithoutConve *
  * rsion(GenericDatumWriter.java:126)|    at                    *
  * org.apache.avro.generic.GenericDatumWriter.write(GenericDatu *
  * mWriter.java:73)|    at                                      *
  * org.apache.avro.generic.GenericDatumWriter.write(GenericDatu *
  * mWriter.java:60)|    at                                      *
  * io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.s *
  * erializeImpl(AbstractKafkaAvroSerializer.java:101)|    at    *
  * io.confluent.kafka.serializers.KafkaAvroSerializer.serialize *
  * (KafkaAvroSerializer.java:53)|                               *
  ****************************************************************
  * RECOMMENDATION:                                              *
  ****************************************************************
  

Problem conclusion

• Upgrading to IDR 11.4.0.3-5566 or newer for Kafka resolves the
  issue.
  

Temporary fix

Comments

APAR Information

• APAR is sysrouted FROM one or more of the following:

• APAR is sysrouted TO one or more of the following:

Fix information

• Fixed component name

  IS CDC JAVA ENG

• Fixed component ID

  5725E30JE

Applicable component levels