prometheus-kafka-adapter
prometheus-kafka-adapter copied to clipboard
Use Kafka as a remote storage database for Prometheus (remote write only)
Document this new feature https://github.com/Telefonica/prometheus-kafka-adapter/pull/64
Hi. Please publish latest docker image after this changes: https://github.com/Telefonica/prometheus-kafka-adapter/commit/6a1dbf53779c4adeb6ee4e7fb2981391074966aa 1.8.0 has a critical vulnerabilities :(
I utilized docker-compose to config kafka, adapter and prometheus: [docker-compose.yml] kafka: image: wurstmeister/kafka # image: jmx_kafka container_name: kafka ports: - "9092:9092" environment: KAFKA_ADVERTISED_HOST_NAME: kafka KAFKA_ADVERTISED_PORT: 9092 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 prometheus-kafka-adapter: image:...
Hi, I have been using Telefonica for last ~10 months & I am currently upgrading to use SSL_SASL mechanism & trying to pass the ca.pem file as an input to...
Hi, I can't seem to get the adapter to produce any messages to the topic. It creates the topic ok, but it's empty. ``` prometheus-kafka-adapter | %5|1707561394.646|PARTCNT|rdkafka#producer-1| [thrd:ssl://kafka:9092/bootstrap]: Topic edge._e59e7552aee847f2876378d36a4678ea._44b4e6be1f78ffb8ee7a0225f2c23266.prometheus...
Hi, I'm writing a Prometheus Netflow exporter to monitor network flows with Grafana, I receive more than 500K flows / minute that are already stored in a Kafka topic. I...
``` [2023-02-08 19:56:35,993] WARN [SocketServer listenerType=ZK_BROKER, nodeId=0] Unexpected error from /10.138.0.12 (channelId=10.32.2.15:9092-10.138.0.12:37806-76); closing connection (org.apache.kafka.common.network.Selector) org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1347375956 larger than 104857600) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:105) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402)...
Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.11.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...
export KAFKA_ACKS=0 If set to zero then the producer will not wait for any acknowledgment from the server at all. The record will be immediately added to the socket buffer...