EnalLS

Given example does not work, receives a Type related error. So, we had to add types to the dictionary constructor to avoid typing errors: `conf = Dict{String, Any}("message.max.bytes" => 364233060,...

### **producer code :** ```` using RDKafka using Random import RDKafka.produce import RDKafka.KafkaProducer KAFKA_BROKER_ADDRESS = "*********************************" KAFKA_TOPIC = "test" partition = 0 conf = Dict{String, Any}("message.max.bytes" => 364233060, "max.message.bytes" =>...

What fails to us is sending several messages in row, usually when the messages are equal to or above 1Mb size. We do get the "Producer Done!" print most of...

Yes, tried this: ``` function produce_much_stuff() while true # for i in 1:iterationsNum # println(i) # prepare_data_and_send_it(rand_string_10B,"10B String") # prepare_data_and_send_it(rand_string_100B,"100B String") # prepare_data_and_send_it(rand_string_1KB,"1KB String") # prepare_data_and_send_it(rand_string_1MB,"1MB String") # prepare_data_and_send_it(rand_string_5MB,"15MB String")...

another output: > julia> produce_much_stuff(10) > sending 20MB String > sending 20MB String > sending 20MB String > sending 20MB String > sending 20MB String > sending 20MB String >...