SLS的Kafka兼容能力支持写入和消费两种操作,可以使用Kafka官方SDK直接对接SLS的Kafka兼容接口。在写入场景中,可以使用Filebeat、Fluentd等开源Agent以Kafka协议方式将日志写入SLS,无需安装iLogtail。在消费场景中,支持使用Kafka Consumer SDK消费SLS中的数据,也支持Flink、Spark等流计算框架消费。SLS的Kafka兼容本质上是协议层面的转换,通过Kafka协议写入的数据可以立即用Elasticsearch协议查询,反之亦然,实现了一份数据多协议共享。相比传统Kafka+ELK架构需要较多机器做数据同步(如LogStash、HangOut),使用SLS完全不需要数据同步组件。SLS的Kafka兼容相当于拥有一个Serverless的Kafka,按量付费无需购买实例,大幅降低了架构复杂度和运维成本。
加载中...