CODE EXAMPLE FOR JAVA

how to change default size kafka

## on publisher

message.max.bytes=15728640 
replica.fetch.max.bytes=15728640
max.request.size=15728640

## on consumer

fetch.message.max.bytes=15728640

read this -> https://stackoverflow.com/questions/21020347/how-can-i-send-large-messages-with-kafka-over-15mb