diff --git a/.version b/.version index e9763f6..ad22619 100644 --- a/.version +++ b/.version @@ -1 +1 @@ -2.23.0 +2.24.0 diff --git a/CHANGELOG.md b/CHANGELOG.md index c942529..fc929f0 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -23,6 +23,10 @@ Removed - for now removed features Fixed - for any bug fixes Security - in case of vulnerabilities --> +## [2.24.0] - 2023-01-10 + +### Added +- CASMSMF-7120: Added support for Cray Fabric Health Telemetry collection. ## [2.23.0] - 2022-11-07 diff --git a/cmd/hmcollector/rest.go b/cmd/hmcollector/rest.go index de2436d..9c0b92a 100644 --- a/cmd/hmcollector/rest.go +++ b/cmd/hmcollector/rest.go @@ -207,6 +207,8 @@ func parseRequest(w http.ResponseWriter, r *http.Request) { writeToKafka("cray-fabric-crit-telemetry", eventsString, &kafkaMessageKey) } else if strings.HasPrefix(event.MessageId, "CrayFabricHealth") { writeToKafka("cray-fabric-health-events", eventsString, &kafkaMessageKey) + } else if strings.HasPrefix(event.MessageId, "CrayAlerts") { + writeToKafka("cray-fabric-health-telemetry", eventsString, &kafkaMessageKey) } else { // If we get to this point then we don't have a specific topic this should go on, // dump it on the generic one.