vvivekiyer opened a new pull request, #9544: URL: https://github.com/apache/pinot/pull/9544
With PR #9224, `StreamMessage` can only accept `bytes[]` datatype for kafka values. However, `MessageBatch` interface is generic and let's users implement a class with a custom type. Keeping `StreamMessage` generic will avoid unnecessary type conversion (which could involve serializing and deserializing) for such users. Added tests to `StreamMessageTest.java` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org
