risingwave_connector::parser::protobuf::parser

Function decode_varint_zigzag

source 
fn decode_varint_zigzag(buffer: &[u8]) -> ConnectorResult<(i32, usize)>
Expand description

A port from the implementation of confluent’s Varint Zig-zag deserialization. See ReadVarint in https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java