Hello, I'm implementing yahoo streaming benchmark with Kafka streaming processing. How to pass a string into Processor or ValueTransformer instance? Accordingly to yahoo benchmark logic I need to transfer an address of Redis server. https://github.com/rssdev10/streaming-benchmarks/blob/master/kafka-benchmarks/src/main/java/kafka/benchmark/AdvertisingTopology.java#L212
PS: the code above is runnable but not checked on real clusters. Best regards