agile-lab-dev/wasp

Error in Kafka multi topic writer when keyFieldName option is Some for some topics and None for others

Opened this issue · 0 comments

None.get raised from it.agilelab.bigdata.wasp.consumers.spark.plugins.kafka.KafkaWriters#keyExpression when in a multi topic model there is a mix of topics, some with keyFieldName defined and some with that field as None.

Result: streaming query doesn't start