Samza kafka to kafka indexing service not writing segments

Hey guys,

I have a process where data is getting written to Kafka consumed by Samza then written to a different Kafka cluster which is what my druid supervisor is consuming. The task runs to completion and in the Overlord console it shows that task execution is a success but it will not write any of the data to segments on azure blob store. I am not sure if this is an issue with the azure extension or an improper config on my part. Could anyone take a look what I’ve got and point me in the right direction?


AzureSettings.txt (162 Bytes)

Log.txt (1.01 MB)

supervisor.txt (1.29 KB)