digitalocean / firebolt

Golang framework for streaming ETL, observability data pipeline, and event processing apps
Other
702 stars 50 forks source link

Add message metrics #38

Closed jnadler closed 2 years ago

jnadler commented 2 years ago

An elauneind application was observed to be using significant bandwidth across its 'messages' kafka topic. Without metrics that break down the utilization by message type, it's quite difficult to know what action to take.

This change adds message send/receive metrics and byte count metrics labelled by message type.

Some linter updates and fixes were required to get everything cleanly building against go 1.18.