Hi,

We want to move to the built-in kafka sink from our own custom
implementation and I have a question about the batchsize config parameter.

Looking at the code of the sink, I can tell that the batchsize is used to
construct the list of keyed messages fed to the producer.

My question is what is the difference between this variable and the kafka
batch.num.messages parameter?

Is the flume parameter necessary ?

--
Sharninder

Reply via email to