richardstartin commented on a change in pull request #7927:
URL: https://github.com/apache/pinot/pull/7927#discussion_r771822223
##########
File path: pinot-spi/src/main/java/org/apache/pinot/spi/stream/MessageBatch.java
##########
@@ -31,11 +31,17 @@
@InterfaceStability.Stable
public interface MessageBatch<T> {
/**
- *
- * @return number of messages returned from the stream
+ * @return number of available messages
*/
int getMessageCount();
+ /**
+ * @return number of messages returned from the stream
+ */
+ default int getUnfilteredMessageCount() {
+ return getMessageCount();
Review comment:
Implemented for Kafka 2.0 only.
--
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
