iLogtail

1756
下载
iLogtail 是阿里云日志服务(Log Service)中的一款高性能、可扩展的日志采集工具。它被设计用于实时收集、解析和传输各类日志数据,支持多种数据源和复杂的日志处理场景,广泛应用于分布式系统、Web 服务器、应用程序等环境中的日志管理。

Kafka(Deprecated)


简介

flusher_kafka flusher插件可以实现将采集到的数据,经过处理后,发送到Kafka。

版本

Deprecated,请使用flusher_kafka_v2

配置参数

参数类型是否必选说明
TypeString插件类型
BrokersString数组Kafka Brokers
TopicStringKafka Topic
SASLUsernameStringSASL用户名
SASLPasswordStringSASL密码
PartitionerTypeStringPartitioner类型。取值:roundrobinhashrandom。默认为:random
HashKeysString数组PartitionerType为hash时,需指定HashKeys。
HashOnceBoolean
ClientIDString写入Kafka的Client ID,默认取值:LogtailPlugin

样例

采集/home/test-log/路径下的所有文件名匹配*.log规则的文件,并将采集结果发送到Kafka。

enable: true
inputs:
- Type: input_file
FilePaths:
- /home/test-log/*.log
flushers:
- Type: flusher_kafka
Brokers:
- 192.XX.XX.1:9092
- 192.XX.XX.2:9092
Topic: KafkaTestTopic

observability.cn Authors 2024 | Documentation Distributed under CC-BY-4.0
Copyright © 2017-2024, Alibaba. All rights reserved. Alibaba has registered trademarks and uses trademarks.
浙ICP备2021005855号-32