pub fn with_kafka_partition(self, kafka_partition_id: u64) -> Self {
        self.with_env(
            "INFLUXDB_IOX_WRITE_BUFFER_PARTITION_RANGE_START",
            kafka_partition_id.to_string(),
        )
        .with_env(
            "INFLUXDB_IOX_WRITE_BUFFER_PARTITION_RANGE_END",
            kafka_partition_id.to_string(),
        )
    }
/// Adds an ingester that ingests from the specified kafka partition
Adds an ingester that ingests from the specified kafka partition
Adds an ingester that ingests from the specified kafka partition
pub fn with_kafka_partition(self, kafka_partition_id: u64) -> Self {
        self.with_env(
            "INFLUXDB_IOX_WRITE_BUFFER_PARTITION_RANGE_START",
            kafka_partition_id.to_string(),
        )
        .with_env(
            "INFLUXDB_IOX_WRITE_BUFFER_PARTITION_RANGE_END",
            kafka_partition_id.to_string(),
        )
    }
pub fn with_kafka_partition ( self , kafka_partition_id : u64 ) -> Self { self . with_env ( " " , kafka_partition_id . to_string ( ) , ) . with_env ( " " , kafka_partition_id . to_string ( ) , ) }
Adds an ingester that ingests from the specified kafka partition
Adds an ingester that ingests from the specified kafka partition
self
kafka_partition_id
u64
self
kafka_partition_id
u64