risingwave_connector::source::pulsar::source::reader

Constant META_COLUMN_PARTITION

source
const META_COLUMN_PARTITION: &str = "__partition";