Skip to content

Commit

Permalink
Add KafkaRest as new output for Falco Sidekick
Browse files Browse the repository at this point in the history
  • Loading branch information
Engin Diri committed Aug 5, 2021
1 parent 126c9cf commit e4bb41f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion outputs/kafkarest.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ func (c *Client) KafkaRestPost(falcopayload types.FalcoPayload) {
go c.CountMetric(Outputs, 1, []string{"output:kafkarest", "status:error"})
c.Stats.KafkaRest.Add(Error, 1)
c.PromStats.Outputs.With(map[string]string{"destination": "kafkarest", "status": Error}).Inc()
log.Printf("[ERROR] : WebHook - %v\n", err.Error())
log.Printf("[ERROR] : Kafka Rest - %v\n", err.Error())
return
}

Expand Down

0 comments on commit e4bb41f

Please sign in to comment.