Currently trying to tap into a Kafka Broker to stream data into BigQuery.

Problem: the message value received from the Broker is encrypted with a customized function. As such, the encrypted received value is most of the time discarded, and sometimes transferred to BigQuery in it's encrypted form.

It would make sense to let the user select their own value-deserializer function/class and if needed, be able to load their own class as a jar file.