Hi All,
I'm in the process of writing a producer which reads a binary file, decodes
it according to a predefined structure (message length followed by the
message). There are 7 different message types in the file, example
message1, message2.... message7.
In the producer code I have created 7 topics for each message. I also
created a partition class, which uses round robin technique to select the
partition based on their size. Below is the partition code.
/*************/
public int partition(Object key, int a_numPartitions){
int
