Hi,all:

I found that when I create a pipeline with a Kafka adapter, 

 

It will first consume data from Kafka, write a new randomly generated topic, 
and then consume data from this new topic. I think this will cause data 
redundancy. I want to know why to do this?

 

Is there any relevant design document about the streampipes project?

 

Thanks.

Reply via email to