public void assertNeedMoreInput(byte[] data) throws Throwable {
        ZabbixProtocolDecoder decoder = spy(new ZabbixProtocolDecoder());
        if (decoder.decodeToPayload(null, Unpooled.wrappedBuffer(data)) != null) {
            throw new IllegalStateException("Could not detect need more input error");
        }
    }
Assert need more input to server
oap-server/server-receiver-plugin/skywalking-zabbix-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/zabbix/provider/ZabbixBaseTest.java