Remove unused ConsumerImpl.isTxnMessage
@@ -1239,10 +1239,6 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
}
}
- private boolean isTxnMessage(MessageMetadata messageMetadata) {
- return messageMetadata.hasTxnidMostBits() && messageMetadata.hasTxnidLeastBits();
- }
-
private ByteBuf processMessageChunk(ByteBuf compressedPayload, MessageMetadata msgMetadata, MessageIdImpl msgId,
MessageIdData messageId, ClientCnx cnx) {
