coco
11/22/2022, 2:00 AM"tableIndexConfig": {
"loadMode": "MMAP",
"nullHandlingEnabled": true,
"streamConfigs": {
"streamType": "kafka",
"stream.kafka.consumer.type": "lowLevel",
"stream.kafka.topic.name": "meetupRSVPEvents",
"stream.kafka.decoder.class.name": "org.apache.pinot.plugin.stream.kafka.KafkaJSONMessageDecoder",
"stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
"stream.kafka.broker.list": "localhost:19092",
"stream.kafka.consumer.prop.auto.offset.reset": "largest",
"realtime.segment.flush.threshold.time": "12h",
"realtime.segment.flush.threshold.size": "10K",
"stream.kafka.metadata.populate": "true"
}
},Seunghyun
11/22/2022, 2:07 AMcoco
11/24/2022, 3:16 AMSeunghyun
11/24/2022, 3:33 AM0.11.0 release. So, this probably will be available from 0.12.0coco
11/24/2022, 8:01 AM