17:04:29.721 [anon.legion.us.gy.join-review-product-foreign-keys-1f4c9c49-424f-4430-a206-fb630c7a6b0d-StreamThread-1] ERROR o.a.k.s.p.i.AssignedStreamsTasks - stream-thread [anon.legion.us.gy.join-review-product-foreign-keys-1f4c9c49-424f-4430-a206-fb630c7a6b0d-StreamThread-1] Failed to process stream task 1_6 due to the following error:
java.lang.NullPointerException: null
	at com.bazaarvoice.legion.ProductSummarySerde$$anon$3.serialize(JoinReviewProductForeignKeys.scala:174)
	at com.bazaarvoice.legion.ProductSummarySerde$$anon$3.serialize(JoinReviewProductForeignKeys.scala:171)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionResponseWrapperSerde$SubscriptionResponseWrapperSerializer.serialize(SubscriptionResponseWrapperSerde.java:55)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionResponseWrapperSerde$SubscriptionResponseWrapperSerializer.serialize(SubscriptionResponseWrapperSerde.java:44)
	at org.apache.kafka.common.serialization.Serializer.serialize(Serializer.java:62)
	at org.apache.kafka.streams.processor.internals.RecordCollectorImpl.send(RecordCollectorImpl.java:164)
	at org.apache.kafka.streams.processor.internals.RecordCollectorImpl.send(RecordCollectorImpl.java:104)
	at org.apache.kafka.streams.processor.internals.SinkNode.process(SinkNode.java:89)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:201)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:180)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionJoinForeignProcessorSupplier$1.process(SubscriptionJoinForeignProcessorSupplier.java:92)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionJoinForeignProcessorSupplier$1.process(SubscriptionJoinForeignProcessorSupplier.java:45)
	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:116)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:201)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:180)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionStoreReceiveProcessorSupplier$1.process(SubscriptionStoreReceiveProcessorSupplier.java:104)
	at org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionStoreReceiveProcessorSupplier$1.process(SubscriptionStoreReceiveProcessorSupplier.java:56)
	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:116)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:201)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:180)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:133)
	at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:87)
	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:345)
	at org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.process(AssignedStreamsTasks.java:199)
	at org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:420)
	at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:886)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:793)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:762)