updated to also write to kafka brokers

not yet