最新 最热

ClickHouse 实战笔记 第01期:Kafka 数据同步到 ClickHouse

这一期首先聊聊 Kafka 数据同步到 ClickHouse 的其中一个方案:通过 Kafka 引擎方式同步,下面进入实际操作过程(环境:CentOS7.4):

2022-04-25
1

Kafka GUI客户端、可视化管理工具——Kafka Assistant

使用过kafka的小伙伴应该都知道kafka本身是没有管理界面的,所有操作都需要手动执行命令来完成。但有些命令又多又长,如果没有做笔记,别说是新手,就连老手也不一定能记得住,每次想要使用的时候都要上网搜索一下。有些崇尚ge...

2022-04-24
1

CKafka系列学习文章 - 对比RabbitMQ、RocketMQ、TDMQ-CMQ、kafka和Ckafka(二)

导语:上一章我们聊到了:什么是消息队列,为什么要用消息队列,有那些消息队列?下来我们聊聊什么样的消息队列适合我们公司。

2022-04-22
1

Flink 最佳实践:TDSQL Connector 的使用(上)

作者:姚琦,腾讯 CSIG 工程师 本文介绍了如何在 Oceanus 平台使用 tdsql-subscribe-connector [1] ,从 TDSQL-MySQL 订阅任务 [2] 创建,到 Oceanus 作业创建、最终数据验证,实现全流程的操作指导。需要注意的是,本文默认已经...

2022-04-22
1

几种 MQ 顺序消息的实现方式

•中间件 excerpt: 常见的 MQ(包括:kafka、pulsar、rocketmq 和 rabbitmq 分别是如何实现顺序消息的呢。banner_img: >- https://pic-cdn.ewhisper.cn/img/2021/07/31/f463dc14089f025621400cb73b78e44......

2022-04-22
1

Java实现Kafka生产者和消费者的示例

Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。Kafka的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。

2022-04-22
0

深入理解RocketMQ延迟消息

RocketMQ是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠、万亿级容量、灵活可伸缩的消息发布与订阅服务。

2022-04-22
1

有状态应用如何在k8s上快速扩容甚至自动扩容

概述在传统的虚机/物理机环境里, 如果我们想要对一个有状态应用扩容, 我们需要做哪些步骤?申请虚机/物理机安装依赖下载安装包按规范配置主机名, hosts配置网络: 包括域名, DNS,...

2022-04-21
1

讲讲对推荐系统特征工程的理解

为什么会有两条线。有些场景的实时数据流比较难处理。比如说电商系统中,一笔订单在发生几天之后会产生推开,这种场景的实时数据是比较难处理,需要通过离线数据进行修正。还有比如说,点击对卖家进行收费,这会产生同行之间的...

2022-04-20
1

kafka 保证分区数据顺序

Producerkafka 发送消息KafkaTemplate​// 相同的key会发送到同一分区上@Overridepublic ListenableFuture<SendResult<K, V>> send(String topic, K key, @Nullable V data) { Prod......

2022-04-19
1