Good afternoon everyone First of all just let me say that this is my first post and I am new to this mailing list and I am new to Apache Kafka, so please bear with me as I figure things out.
My problem is this: I am trying to upgrade a proprietary application that consumes records from Kafka. However, every time we run the application and it starts to read from Kafka It produces an error because the response coming back from Kafka is too large even though we specified fetch.message.max.bytes in the fetch request. So we increased the value of fetch.message.max.bytes to accommodate the larger responses, but every time we increase fetch.message.max.bytes the response length increases with it. The application is called KaBoom and can be found at GitHub https://github.com/blackberry/KaBoom James Williams
