4.Configuration

Kafka Eagle configurations and defaults value are the following:

Base

Name

Default

Type

Describe

kafka.eagle.zk.cluster.alias

cluster1,cluster2

String

Multi-kafka cluser alias.

cluster1.zk.list

tdn1:2181,tdn2:2181,tdn3:2181

String

Kafka cluster1 zookeeper address.

cluster2.zk.list

xdn10:2181,xdn11:2181,xdn12:2181

String

Kafka cluster2 zookeeper address.

kafka.zk.limit.size

25

Int

Kafka Eagle maximum number of connections for the Zookeeper client.

kafka.eagle.webui.port

8048

Int

Kafka Eagle WebUI port.

cluster1.kafka.eagle.offset.storage

kafka

String

Kafka offsets stored in kafka topic.

cluster2.kafka.eagle.offset.storage

zk

String

Kafka offsets stored in zookeeper.

kafka.eagle.metrics.charts

false

Boolean

Kafka Eagle default disable metrics.

kafka.eagle.sql.fix.error

false

Boolean

Kafka Eagle default disable fixed kafka sql query error.

kafka.eagle.sql.topic.records.max

5000

Long

Kafka Eagle SQL query topic max records.

kafka.eagle.topic.token

keadmin

String

Kafka Eagle delete topic token.

Mail

Name

Default

Type

Describe

kafka.eagle.mail.enable

true

Boolean

Kafka Eagle enable alert mail.

kafka.eagle.mail.sa

alert_sa@mail.com

String

Kafka Eagle alert administrators.

kafka.eagle.mail.username

alert_sa@mail.com

String

Kafka Eagle alert server username.

kafka.eagle.mail.password

password

String

Kafka Eagle alert server password.

kafka.eagle.mail.server.host

smtp.smartloli.org

String

Kafka Eagle alert server address.

kafka.eagle.mail.server.port

25

String

Kafka Eagle alert server port.

DingDing

Name

Default

Type

Describe

kafka.eagle.im.dingding.enable

true

Boolean

Kafka Eagle enable alert dingding.

kafka.eagle.im.dingding.url

https://oapi.dingtalk.com/robot/send?access_token=

String

Kafka Eagle dingding api.

WeChat

Name

Default

Type

Describe

kafka.eagle.im.wechat.enable

true

Boolean

Kafka Eagle enable alert wechat.

kafka.eagle.im.wechat.token

https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=xxx&corpsecret=xxx

String

Kafka Eagle get wechat token.

kafka.eagle.im.wechat.url

https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=

String

Kafka Eagle wechat api.

kafka.eagle.im.wechat.touser

String

Kafka Eagle wechat touser.

kafka.eagle.im.wechat.toparty

String

Kafka Eagle wechat toparty.

kafka.eagle.im.wechat.totag

String

Kafka Eagle wechat totag.

kafka.eagle.im.wechat.agentid

String

Kafka Eagle wechat agentid.

SASL_PLAINTEXT

Name

Default

Type

Describe

cluster1.kafka.eagle.sasl.enable

false

Boolean

Kafka Eagle cluster1 disable SASL_PLAINTEXT.

cluster1.kafka.eagle.sasl.protocol

SASL_PLAINTEXT

String

Kafka Eagle cluster1 set SASL protocol.

cluster1.kafka.eagle.sasl.mechanism

PLAIN

String

Kafka Eagle cluster1 set SASL mechanism.

cluster2.kafka.eagle.sasl.enable

false

Boolean

Kafka Eagle cluster2 disable SASL_PLAINTEXT.

cluster2.kafka.eagle.sasl.protocol

SASL_PLAINTEXT

String

Kafka Eagle cluster2 set SASL protocol.

cluster2.kafka.eagle.sasl.mechanism

PLAIN

String

Kafka Eagle cluster2 set SASL mechanism.

Database property

MySQL

Name

Default

Type

Describe

kafka.eagle.driver

com.mysql.jdbc.Driver

String

Kafka Eagle store database driver.

kafka.eagle.url

jdbc:mysql://127.0.0.1:3306/ke3?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull

String

Kafka Eagle store database url.

kafka.eagle.username

root

String

Kafka Eagle store database username.

kafka.eagle.password

123456

String

Kafka Eagle store database password.

SQLite

Name

Default

Type

Describe

kafka.eagle.driver

org.sqlite.JDBC

String

Kafka Eagle store database driver.

kafka.eagle.url

jdbc:sqlite:/hadoop/kafka-eagle/db/ke.db

String

Kafka Eagle store database url.

kafka.eagle.username

root

String

Kafka Eagle store database username.

kafka.eagle.password

123456

String

Kafka Eagle store database password.