Added the ability to specify the patition for kafka in the parameters. This feature is necessary to set the flag for data received from different servers.
Added the ability to specify the patition for kafka in the parameters. This feature is necessary to set the flag for data received from different servers.