diff --git a/pkg/network/protocols/kafka/protocol.go b/pkg/network/protocols/kafka/protocol.go index bc319714b3e29..54bcb67ff5fdf 100644 --- a/pkg/network/protocols/kafka/protocol.go +++ b/pkg/network/protocols/kafka/protocol.go @@ -51,7 +51,6 @@ const ( kafkaHeapMap = "kafka_heap" inFlightMap = "kafka_in_flight" responseMap = "kafka_response" - telemetryMap = "kafka_telemetry" tlsFilterTailCall = "uprobe__kafka_tls_filter" @@ -88,7 +87,7 @@ var Spec = &protocols.ProtocolSpec{ Name: "kafka_topic_name", }, { - Name: telemetryMap, + Name: eBPFTelemetryMap, }, { Name: "kafka_batch_events", @@ -312,7 +311,7 @@ func (p *protocol) DumpMaps(w io.Writer, mapName string, currentMap *ebpf.Map) { for iter.Next(unsafe.Pointer(&key), unsafe.Pointer(&value)) { spew.Fdump(w, key, value) } - case telemetryMap: + case eBPFTelemetryMap: var zeroKey uint32 var value RawKernelTelemetry