We are doing a prototyping using no-kafka . Producer code based on standard examples. One producer , reading couple of messages from a file and sending data to a specific partition of a topic. Messages are successfully sent but when we print the result we see the output as if the "result" is being overwritten across multiple invocation of the global producer .
If we create a producer per message then the output shown is correct . But I assume that is not the recommended way and the producer is suppose to be global.
Here is the wrong output . Observer how the offset reported is same with the same partition . That is incorrect . The offset reported should sequentially increases
We are doing a prototyping using no-kafka . Producer code based on standard examples. One producer , reading couple of messages from a file and sending data to a specific partition of a topic. Messages are successfully sent but when we print the result we see the output as if the "result" is being overwritten across multiple invocation of the global producer . If we create a producer per message then the output shown is correct . But I assume that is not the recommended way and the producer is suppose to be global. Here is the wrong output . Observer how the offset reported is same with the same partition . That is incorrect . The offset reported should sequentially increases