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.
