Falcosidekick outout KAFKA with TLS support

[victorrodriguez1984]

Motivation

Feature

Alternatives

[Issif]

Have you tested this config?

kafka:
  hostport: "ssl://<address>:9092"

Technically, it should work.

[Issif]

@victorrodriguez1984 can you try my proposal to check if it's ok please?

[ibice]

Hi @Issif, @victorrodriguez1984 and me have tested your proposal, but it seems it doesn't like it. It tries to resolve ssl://<address>:<port>. Here's the error message:

dial tcp: lookup ssl://server:9092: no such host

To see the error, I had to modify the code to handle this returned err:

falcosidekick/outputs/kafka.go

Lines 142 to 143 in 4d11678

	// Errors are logged/captured via handleKafkaCompletion function, ignore here
	_ = c.KafkaProducer.WriteMessages(context.Background(), kafkaMsg)

It might be worth handling it, it seems handleKafkaCompletion captures errors during async writes and WriteMessages returns synchronous errors. What do you think?

[Issif]

Everything is available with release 2.28.0 👍