|
名称 |
类型 |
描述 |
示例值 |
|---|---|---|---|
|
object |
kafka 导入源配置 |
||
| bootstrapServers |
string |
192.168.1.28:9092 |
|
| topics |
string |
topic1,topic2 |
|
| fromPosition |
string |
earliest,latest |
|
| consumerGroup |
string |
consumer |
|
| valueType |
string |
text,json |
|
| encoding |
string |
UTF-8 |
|
| parseArray |
boolean |
true |
|
| vpcId |
string |
||
| timeField |
string |
__time__ |
|
| timePattern |
string |
\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2} |
|
| timeFormat |
string |
epoch |
|
| timeZone |
string |
+0800 |
|
| defaultTimeSource |
string |
system,kafka |
|
| enableSlsContext |
boolean |
true |
|
| nameResolutions |
string |
{"hostname": "192.168.1.28"} |
|
| communication |
string |
{ "protocol":"SASL_PLAINTEXT", "sasl":{ "mechanism":"PLAIN", "username":"用户名", "password":"密码" } } |
|
| processorId |
string |
ingest-processor-1756802123-953901 |
该文章对您有帮助吗?