别再闭眼堆技术栈！企业大数据开源工具选型清单，看懂这张表少走3年弯路

大家好，我是 Echo_Wish。

做大数据这么多年，经常遇到一个问题：

“我们公司要建设数据平台，Kafka、Flink、Spark、Hive、ClickHouse、ES、Hadoop……到底该怎么选？”

然后项目经理打开 PPT：

• 数据采集：Kafka
• 数据计算：Spark
• 实时计算：Flink
• 数据仓库：Hive
• 数据湖：Iceberg
• 数据查询：Presto
• 数据可视化：Superset

一套“大数据全家桶”直接安排上。

结果半年以后：

• Kafka 集群没人维护；
• Flink 作业没人敢改；
• Hive 跑 SQL 要等半小时；
• Hadoop 集群磁盘报警天天响；
• 运维人员开始怀疑人生。

其实很多企业的大数据项目失败，不是因为技术不先进，而是因为：

选了不适合自己的技术。

开源工具没有绝对最好，只有最适合。

今天 Echo_Wish 整理一份企业常见大数据技术栈选型清单，结合实际生产场景，对比主流方案和替代方案。

一、数据采集：Kafka 不是唯一答案

企业常见方案

很多公司第一反应：

“数据量大，上 Kafka。”

但是 Kafka 真的是万能的吗？

不一定。

1. Kafka

Apache Kafka 目前依然是企业消息流平台的主流选择。

典型架构：

业务系统
   |
   |
 Kafka
   |
 +-------+
 |       |
Flink   Spark
 |
数据仓库

生产环境：

例如订单系统：

{
 "orderId":"10001",
 "userId":"9527",
 "amount":299
}

进入 Kafka：

producer.send(
 new ProducerRecord<>(
 "order_topic",
 orderJson
 )
);

消费者：

consumer.subscribe(
 Arrays.asList("order_topic")
);

优势：

• 吞吐量高；
• 生态成熟；
• 大厂验证。

但是问题也明显：

• 运维复杂；
• Partition 设计困难；
• 消息堆积排查麻烦。

替代方案：Pulsar

如果企业：

• 多租户；
• 云原生；
• 消息量巨大；

可以考虑：

Apache Pulsar

Pulsar 架构：

Producer

   |
 Pulsar Broker

   |
BookKeeper存储

相比 Kafka：

我的观点：

普通制造、零售企业，Kafka 足够；互联网超大规模、多业务隔离，可以考虑 Pulsar。

二、实时计算：Spark Streaming 和 Flink 怎么选？

这是企业最容易纠结的位置。

Spark Streaming

传统架构：

Kafka

 ↓

Spark Streaming

 ↓

Hive

Spark Streaming 本质：

微批处理。

例如：

每5秒处理一次：

00:00:00
00:00:05
00:00:10

代码：

from pyspark.streaming import StreamingContext

ssc = StreamingContext(
    sparkContext,
    5
)

stream = kafkaStream.map(
    lambda x:x.value
)

stream.foreachRDD(
    lambda rdd:
        rdd.count()
)

优点：

• 和 Spark 生态结合好；
• 离线实时统一。

缺点：

• 延迟较高。

Flink

Apache Flink 当前实时计算领域非常热门。

架构：

Kafka

 ↓

Flink

 ↓

Redis
 ↓
ClickHouse

代码：

DataStream<Order> stream =
env
.fromSource(source);


stream
.filter(
 order -> order.amount > 1000
)
.print();

优势：

• 毫秒级延迟；
• 状态管理强；
• Window机制优秀。

例如：

统计最近一分钟交易金额：

stream
.keyBy(Order::getUserId)
.window(
 SlidingEventTimeWindows
.of(
 Time.minutes(1),
 Time.seconds(10)
 )
)
.sum("amount");

选型建议：

一句话：

Spark 更像数据计算平台，Flink 更像实时数据操作系统。

三、数据仓库：Hive 还能不能用？

很多新人觉得：

“Hive 太老了。”

其实不是。

Hive 在企业里面依然大量存在。

经典架构：

MySQL

 ↓

Sqoop/DataX

 ↓

Hive

 ↓

BI

Hive SQL：

select
 department,
 sum(amount)
from
 orders
group by
 department;

优势：

• 稳定；
• 成熟；
• 大数据生态完整。

但是：

查询速度慢。

于是出现替代方案。

四、OLAP分析：Hive 的替代者越来越多

ClickHouse

ClickHouse

适合：

• 实时报表；
• 用户行为分析；
• 经营分析。

例如：

查询百万订单：

SELECT
 product,
 sum(price)
FROM orders
GROUP BY product;

速度：

Hive：

几十秒甚至分钟。

ClickHouse：

秒级。

Elasticsearch

Elasticsearch

适合：

日志搜索：

用户登录失败

↓

ES

↓

Kibana查询

优势：

全文搜索能力强。

但是：

不要拿 ES 当数据库。

很多公司：

MySQL数据

全部同步ES

ES永久保存

最后：

磁盘爆炸。

五、数据湖：HDFS 不是唯一选择

传统：

HDFS

+
Hive

+
Spark

但是现在：

越来越多企业使用：

Iceberg

Apache Iceberg

架构：

对象存储

(S3/OSS/MinIO)

       |

    Iceberg

       |

 Spark/Flink

优势：

• 支持事务；
• 支持数据版本；
• 支持更新删除。

适合：

企业级数据湖。

六、数据可视化：别只盯着商业BI

常见：

Superset

Apache Superset

简单示例：

连接数据库：

DATABASES={
 "clickhouse":{
 "host":"localhost",
 "port":8123
 }
}

创建：

销售趋势分析

     |
 ClickHouse

     |
 Superset Dashboard

适合：

预算有限的小团队。

七、企业大数据推荐技术组合

方案1：传统企业（制造、供应链）

推荐：

Kafka

 ↓

Flink

 ↓

Hive

 ↓

ClickHouse

 ↓

Superset

特点：

稳定优先。

方案2：互联网业务

推荐：

Kafka

 ↓

Flink

 ↓

Iceberg

 ↓

Trino

 ↓

BI

特点：

实时+湖仓一体。

方案3：中小企业

不要搞复杂。

可以：

MySQL

 ↓

DataX

 ↓

ClickHouse

 ↓

Superset

很多企业80%的分析需求，这套已经够用。

八、最后聊聊我的选型心得

这些年看过不少企业技术方案。

最大的误区就是：

“别人用了，所以我们也要用。”

阿里用了 Flink，不代表你的公司必须 Flink。

字节用了 ClickHouse，不代表你的业务必须 ClickHouse。

技术选型应该先问三个问题：

1. 数据规模是多少？

10亿数据：

和100万数据：

完全不是一个问题。

2. 实时要求是多少？

要求：

5秒内看到结果？

还是：

每天凌晨跑一次报表？

3. 运维能力怎么样？

一个只有3个人的数据团队：

不要轻易挑战几十个组件的大数据平台。

写在最后

大数据技术发展很快。

从 Hadoop：

到 Spark：

再到 Flink：

再到 LakeHouse：

工具越来越多。

但是企业真正需要的，不是“最先进架构”。

而是：

用最低成本，把数据稳定变成业务价值。

所以：

Kafka 不一定比 Pulsar 好；

Flink 不一定比 Spark 好；

Iceberg 不一定比 Hive 好。

适合业务的技术，才是真正好的技术。

这也是企业大数据架构设计中，最容易被忽略的一点。

我是 Echo_Wish，持续分享大数据、AI、云原生、企业数字化实践。

下一篇，我们聊聊：

《从 Hadoop 到 LakeHouse：企业数据架构演进路线图》。