The driver will silently fail when a messages is sent to kafka that is larger than the max buffer size. The driver needs to throw a buffer under run exception and then handle this exception by increasing the max buffer size until a message is returned.
The driver will silently fail when a messages is sent to kafka that is larger than the max buffer size. The driver needs to throw a buffer under run exception and then handle this exception by increasing the max buffer size until a message is returned.