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

Reply via email to