fn new(pid: i32, partition_queue: PartitionQueue<GlueConsumerContext>) -> Self {
        PartitionConsumer {
            pid,
            partition_queue,
        }
    }
/// Creates a new partition consumer from underlying Kafka consumer
Creates a new partition consumer from underlying Kafka consumer
Creates a new partition consumer from underlying Kafka consumer
fn new(pid: i32, partition_queue: PartitionQueue<GlueConsumerContext>) -> Self {
        PartitionConsumer {
            pid,
            partition_queue,
        }
    }
fn new ( pid : i32 , partition_queue : PartitionQueue < GlueConsumerContext > ) -> Self { PartitionConsumer { pid , partition_queue , } }
Creates a new partition consumer from underlying Kafka consumer
Creates a new partition consumer from underlying Kafka consumer
pid
i32
partition_queue
PartitionQueue<GlueConsumerContext>
pid
i32
partition_queue
PartitionQueue<GlueConsumerContext>