断翅绝尘

声明：Activiti版本5.22.0。Activiti在初始化时会生成act_id_*系列与用户、用户组相关的表，但在实际业务中，我们系统可能初期并没有接入工作流，后期接入...

737833890

使用flink 自带的datagen作为数据源，测试StarRocks 的 主键模型（primary key）的更新性能。 环境准备 StarRocks 版本：2.0.1St...

风南子

1.创建并使用图空间 ： nebula> CREATE SPACE nba (partition_num=10, replica_factor=1); //partition...

森林和海洋

相对于Kafka的生产者API，消费者的API略显繁杂，本文总结了0.11.0版本的kafka消费者的几种消费模式，供大家参考，该版本的所有消费方法均在KafkaConsum...

CoderJed

1. 以时间戳查询消息 (1) Kafka 新版消费者基于时间戳索引消费消息 kafka 在 0.10.1.1 版本增加了时间索引文件，因此我们可以根据时间戳来访问消息。如以...

代码足迹

配置参数 代码中的poll(timeout) 这个timeout表示的意思是，如果Kafak中没有消息，会隔timeout这个值读一次。比如上面代码设置了2秒，也是就2秒后会...