asglab/sflow-go-consumer repository overview

This app consumes sflow messages from kafka and writes to clickhouse

https://github.com/ISS-Peak/flowzen⁠

https://github.com/ISS-Peak/sflow-go⁠

Certainly, here are the descriptions of the environment variables and flags:

"KAFKA_TOPIC"

Description: Specifies the topic for Kafka communications. Usage: This flag or environment variable determines the Kafka topic to which the application will produce or consume messages.

"KAFKA_BROKERS"

Description: Specifies the broker address in the Kafka cluster. Usage: This flag or environment variable specifies the address of the Kafka brokers in the cluster. It is used for establishing connections with the Kafka cluster.

"KAFKA_CONSUMER_GROUP_ID"

Description: Specifies the Consumer Group ID for consuming data from partitions. Usage: This flag or environment variable sets the Consumer Group ID that the Kafka consumer will use when consuming messages from Kafka partitions.

"DB_NAME"

Description: Specifies the name of the database. Usage: This flag or environment variable determines the name of the database to which the application will connect for database operations.("clickhouse","postgresql" etc.)

"DB_HOST"

Description: Specifies the host address of the database. Usage: This flag or environment variable specifies the host address (IP or hostname) of the database server to which the application will connect.

"DB_PORT"

Description: Specifies the port number of the database server. Usage: This flag or environment variable specifies the port number of the database server to which the application will connect.

"DB_DATABASE"

Description: Specifies the name of the database to be used. Usage: This flag or environment variable specifies the database on which the application will operate. It is used during database operations.

"DB_USERNAME"

Description: Specifies the username for connecting to the database. Usage: This flag or environment variable specifies the username used to authenticate and connect to the database.

"DB_PASSWORD"

Description: Specifies the password for the database user. Usage: This flag or environment variable specifies the password used to authenticate and connect to the database. These flags and environment variables provide essential configuration options for the application, enabling it to communicate with Kafka clusters and databases effectively.

• TLS_ENABLE: Enable TLS for database connection.