KafkaStreamer and IgniteDataStreamer dynamic cache name

[kcheng.mvp]

Seems KafkaStreamer and IgniteDataStreamer has one to one mapping.

that's to say a KafkaStreamer can only persistent to one cache.

right now my case is a bit complicated.

KafkaStreamer<String, &lt;b>GenericEntity*> kafkaStreamer = new
KafkaStreamer<>();

during persist phrase, I need to save a *GenericEntity* to a cache which
depends on one property of

*GenericEntity*

as 
IgniteDataStreamer<String, Comment> stmr = ignite.dataStreamer("cache_name")
just accept a single cache name as parameter.

so seems there is no way to dynamic choose a cache.

 






--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/