connect gearpump with Kafka

We need add a config called BatchSize,
At a time, we should emit no more than BatchSize, it is important. For example, we may iterate at most 100 message at a time.