Nickel Fang
10/29/2022, 11:00 AM{
"code": 500,
"error": "org.apache.pinot.spi.stream.TransientConsumerException: org.apache.pinot.shaded.org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata"
}
the streamConfig is as below
"streamConfigs": {
"streamType": "kafka",
"stream.kafka.consumer.type": "lowlevel",
"stream.kafka.topic.name": "test",
"stream.kafka.decoder.class.name": "org.apache.pinot.plugin.inputformat.json.JSONMessageDecoder",
"stream.kafka.decoder.prop.projectId": "1",
"stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
"stream.kafka.broker.list": "localhost:9092",
"stream.kafka.consumer.prop.auto.offset.reset": "smallest",
"realtime.segment.flush.threshold.time": "2h",
"realtime.segment.flush.threshold.rows": "0",
"realtime.segment.flush.threshold.segment.size": "300M",
"realtime.segment.flush.autotune.initialRows": "10000"
}Mayank
Xiang Fu
Nickel Fang
10/30/2022, 2:51 AMNickel Fang
10/30/2022, 2:53 AMXiang Fu
Xiang Fu
Xiang Fu
Xiang Fu
org.apache.pinot.tools.RealtimeQuickStart class to remove Server partXiang Fu
Xiang Fu
Nickel Fang
10/31/2022, 1:15 AM