wenbronk opened a new issue #3682:
URL: https://github.com/apache/incubator-doris/issues/3682
使用kafka routine load 从kafka往routine中导入数据,
新建导入任务如下
```mysql
CREATE ROUTINE LOAD access_kafka ON access_log
COLUMNS TERMINATED BY "|",
COLUMNS(
`domain_id` ,
`datetime` ,
`hour` ,
`minute` ,
...
)
PROPERTIES(
"desired_concurrent_number"="1",
"max_batch_interval"="20",
"max_batch_rows"="300000",
"max_batch_size"="209715200"
)
FROM KAFKA(
"kafka_broker_list"="10.xxx.9:9092",
"kafka_topic"="test5",
"kafka_partitions"="0,1,2",
"kafka_offsets"="0,0,0",
"property.isolation.level" = "read_committed",
"property.group.id" = "kakfa2doris01"
);
```
1. 使用kafka producer事务发送消息, 手动抛出异常
2. 命令行 consumer 消费不到消息
3. java客户端 consumer 消费不到消息
4. kafka routine load 正常消费消息并导入1条数据
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
