Skip to content

Move sink creation into common module

Ebernhardson requested to merge work/ebernhardson/common-sink-creation into main

While the producer sink had it's custom kafka properties set, the consumer fetch failure sink did not get the same treatment. Move the sink creation code from the producer into common, and invoke it from producer and consumer so we have some consistency.

This also fixes a problem where we configured the fetch failure sink to use ssl to talk to kafka, but the config didn't make it into the sink.

Bug: T347075 Change-Id: Iff783739abf55ebaff3a3b35c286d90e80373579

Merge request reports