[kafka_actions] Bound message reads to a start-of-check snapshot (#24…

bd332d9

Select commit

Loading

Failed to load commit list.

Uh oh!

There was an error while loading. Please reload this page.

WIP

WIP

Check do-not-merge labels on: pull_request 1

Check do-not-merge labels

Validate Pinned Actions on: pull_request 1

pinact

PR Labels on: pull_request

labeler

Validate repository on: pull_request 3

Run Validations / Validate

CodeQL on: pull_request

Analyze (python)

Dependency Wheel Promotion Gate on: pull_request_target

Set dependency-wheel-promotion status

Set dependency-wheel-promotion status for merge queue

PR on: pull_request 19

test / compute-matrix / Compute matrix

test / test (linux, ubuntu-22.04, kafka_actions, Kafka Actions (py3.12), py3.12) / Kafka Actions (py3.12)-py3.12

test / test (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-ssl), py3.13-3.3-ssl) / Kafka Consumer (py3.13-3.3-ssl)-py3.13-3.3-ssl

test / test (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-kerberos), py3.13-3.3-kerbe... / Kafka Consumer (py3.13-3.3-kerberos)-py3.13-3.3-kerberos

test / test (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-noauth), py3.13-3.3-noauth) / Kafka Consumer (py3.13-3.3-noauth)-py3.13-3.3-noauth

test / test-minimum-base-package (linux, ubuntu-22.04, kafka_actions, Kafka Actions (py3.12), py3.12) / minimum-base-package-Kafka Actions (py3.12)-py3.12

test / test-minimum-base-package (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-ssl), ... / minimum-base-package-Kafka Consumer (py3.13-3.3-ssl)-py3.13-3.3-ssl

test / test-minimum-base-package (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-kerber... / minimum-base-package-Kafka Consumer (py3.13-3.3-kerberos)-py3.13-3.3-kerberos

test / test-minimum-base-package (linux, ubuntu-22.04, kafka_consumer, Kafka Consumer (py3.13-3.3-noauth... / minimum-base-package-Kafka Consumer (py3.13-3.3-noauth)-py3.13-3.3-noauth

test / save-event / Save event

test / upload-coverage

test / check

Check PR on: pull_request_target 3

run / Check PR changelog

run / Comment for PR changelog

Community PR Labels on: pull_request_target 2

labeler / apply

Backport PR on: pull_request_target

Backport PR

Check do-not-merge labels on: pull_request 1

Check do-not-merge labels

Validate repository on: pull_request 2

Run Validations / Validate

Check PR on: pull_request_target 4

run / Check PR changelog

run / Comment for PR changelog

docs on: push 1

build

publish

test build devcontainer image on: push

docker

CodeQL on: push

Analyze (python)

Validate Pinned Actions on: push 1

pinact

Verify dependency resolution pin on: push

Verify resolution hash matches pin

Measure Disk Usage (Master) on: push 1

measure-disk-usage

Validate repository on: push

Run Validations / Validate

Master Windows on: push 59

cache / Cache Python dependencies for Linux

cache / Cache Python dependencies for Windows

test / j6712d43 / ddev on Windows

test / jda96080 / Datadog Checks Base on Windows

test / j1176210 / Datadog Checks Dev on Windows

test / j8c73c41 / Datadog Checks Downloader on Windows

test / jd66e148 / Active Directory

test / j8c9f9aa / ASP.NET

test / j92e8bce / Disk on Windows

test / j301b42d / DNS on Windows

test / jc6b16d4 / .NET CLR

test / j284dfb9 / Exchange Server

test / j662406b / IBM MQ on Windows

test / j9267198 / IIS

test / j7a1dfc6 / Network on Windows

test / j4dff42c / PDH

test / j31a95c8 (py3.13-windows-SQLOLEDB-2019-single) / SQL Server on Windows-py3.13-windows-SQLOLEDB-2019-single

test / j31a95c8 (py3.13-windows-SQLOLEDB-2022-single) / SQL Server on Windows-py3.13-windows-SQLOLEDB-2022-single

test / j31a95c8 (py3.13-windows-SQLOLEDB-2025-single) / SQL Server on Windows-py3.13-windows-SQLOLEDB-2025-single

test / j31a95c8 (py3.13-windows-MSOLEDBSQL-2019-single) / SQL Server on Windows-py3.13-windows-MSOLEDBSQL-2019-single

test / j31a95c8 (py3.13-windows-MSOLEDBSQL-2022-single) / SQL Server on Windows-py3.13-windows-MSOLEDBSQL-2022-single

test / j31a95c8 (py3.13-windows-MSOLEDBSQL-2025-single) / SQL Server on Windows-py3.13-windows-MSOLEDBSQL-2025-single

test / j31a95c8 (py3.13-windows-odbc-2019-single) / SQL Server on Windows-py3.13-windows-odbc-2019-single

test / j31a95c8 (py3.13-windows-odbc-2022-single) / SQL Server on Windows-py3.13-windows-odbc-2022-single

test / j31a95c8 (py3.13-windows-odbc-2025-single) / SQL Server on Windows-py3.13-windows-odbc-2025-single

test / j87dbe3f / TCP on Windows

test / j70c9219 / Windows Event Log

test / jc1fb93c / Windows performance counters

test / j9798a89 / Windows Service

test / j25cdd56 / WMI

publish-test-results / Publish

upload-coverage

Master on: push 571

cache / Cache Python dependencies for Linux

cache / Cache Python dependencies for Windows

test / jd316aba / ddev on Linux

test / jb232c8c / Datadog Checks Base on Linux

test / j77217e9 / Datadog Checks Dev on Linux

test / j8cdb65b / Datadog Checks Downloader on Linux

test / j02a4c95 / ActiveMQ

test / jb4c5802 / ActiveMQ XML

test / jce7999e / Aerospike

test / jd58222c / Airflow

test / jaaddf5e / Amazon Kafka

test / j9c53fc8 / Ambari

test / j87ec402 / Apache

test / j89811be / Appgate SDP

test / jacbd843 / ArangoDB

test / j3650884 / Argo Rollouts

test / j14e797c / Argo Workflows

test / j92d42de / ArgoCD

test / j924327f / Avi Vantage

test / jeb3e097 / AWS Neuron

test / j8d83b0b / Azure IoT Edge

test / j5a8a3b3 / BentoML

test / jfcf4b1a / Boundary

test / j2883ff0 / Btrfs

test / j481d7ae / Cacti

test / j47ac8c7 / Calico

test / je3297e4 / Cassandra

test / jf75679d / Cassandra Nodetool

test / j17d78bd / Celery

test / jdffb064 / Ceph

test / je6bb20d / cert-manager

test / jeb29398 / Cilium

test / j3de8d1a / Cisco ACI

test / jafd4d40 / Citrix Hypervisor

test / jdee91dd (py3.13-18) / ClickHouse-py3.13-18

test / jdee91dd (py3.13-19) / ClickHouse-py3.13-19

test / jdee91dd (py3.13-20) / ClickHouse-py3.13-20

test / jdee91dd (py3.13-21.8) / ClickHouse-py3.13-21.8

test / jdee91dd (py3.13-22.7) / ClickHouse-py3.13-22.7

test / jdee91dd (py3.13-23.2) / ClickHouse-py3.13-23.2

test / jdee91dd (py3.13-23.8) / ClickHouse-py3.13-23.8

test / jdee91dd (py3.13-24.8) / ClickHouse-py3.13-24.8

test / jdee91dd (py3.13-25.3) / ClickHouse-py3.13-25.3

test / jdee91dd (py3.13-25.8) / ClickHouse-py3.13-25.8

test / j4131274 / Cloud Foundry API

test / j26f9a18 / Cloudera

test / j7faf392 / CockroachDB

test / j89ec795 / Confluent Platform

test / j13a53db / Consul

test / j7c68dcb / Control-M

test / jb67436a / CoreDNS

test / j483e815 / CouchDB

test / j1e84c35 / Couchbase

test / ja3692a6 / CRI-O

test / j2d21154 / Datadog Cluster Agent

test / j69f9754 / dcgm

test / jc346754 / Dell Powerflex

test / jc8f84c3 / Directory

test / j4b2fe2b / Disk on Linux

test / j3e27604 / DNS on Linux

test / j297b771 / DO Query Actions

test / j274814f / Druid

test / j9eb6aa6 / DuckDB

test / j562bfe5 / Amazon ECS Fargate

test / j72f26c1 / EKS Fargate

test / j31c819b / Elasticsearch

test / j93163a5 / Envoy

test / jc4fef15 / ESXi

test / jc38cbd9 / etcd

test / j1856b23 / External DNS

test / j6e7cb83 / Falco

test / j7f02532 / flink

test / j4f2c848 / Fluentd

test / j6134697 / fluxcd

test / j5018b0d / Fly.io

test / jc364450 / FoundationDB

test / j3becdbc / Gearman

test / j4ea3f09 / Gitlab

test / j563739d / Gitlab Runner

test / j16f5513 / GlusterFS

test / j3399e09 / Go Expvar

test / j0a5a061 / GuardDog

test / j1fede0e / Gunicorn

test / j5979923 / HAProxy

test / j8a8c654 / Harbor

test / j9cb9f66 / Hazelcast

test / j240a78b / HDFS Datanode

test / j00a0dd6 / HDFS Namenode

test / jaf48338 / Hive

test / je66898a / HiveMQ

test / j0be27fe / HPE Aruba EdgeConnect

test / j56d6f32 / HTTP

test / j95a2b08 / Hudi

test / jc3781e1 / Hugging Face TGI

test / j5a9585a / IBM ACE

test / j60f59ae / IBM Db2

test / j9accedb / IBM i

test / jf4d06ee / IBM MQ on Linux

test / j203c004 / IBM Spectrum LSF

test / j440815a / IBM WAS

test / j0676988 / Ignite

test / j5dc7466 / Impala

test / jf082b3f / Infiniband

test / j0c16521 / Istio

test / j46da136 / JBoss_WildFly

test / je4a5f92 / Kafka

test / jf06de9b / Kafka Actions

test / jeaad214 / Kafka Consumer

test / j77f29c1 / Karpenter

test / j2cb7ef0 / Keda

test / jaee58c5 / Kong

test / ja001417 / KrakenD

test / j92491f1 / Kubernetes API server metrics

test / j1ce0516 / Kubernetes Controller Manager

test / j19a1b27 / Kube DNS

test / jd1817b8 / Kube metrics server

test / j5a98c4e / Kube Proxy

test / jeebd4ae / Kubernetes Scheduler

test / j89c297c / Kubeflow

test / j24a5cff / Kubelet

test / j045310a / Kubernetes Cluster Autoscaler

test / jba841f0 / Kubernetes State

test / jb0447e6 / KubeVirt API

test / jc4c1032 / KubeVirt Controller

test / j4f368cf / KubeVirt Handler

test / j3c620e6 / Kueue

test / j739f9be / Kuma

test / j61e565f / Kyoto Tycoon

test / j6900ead / kyverno

test / j1c6adb2 / Lighttpd

test / j8b3b099 / Linkerd

test / j29dcd3a / Linux proc extras

test / j3d7d527 / LiteLLM

test / jefcf576 / LPARStats

test / je63e92c / Lustre

test / jc1b3d1e / Mac Audit Logs

test / ja15251c / MapR

test / j141298e / MapReduce

test / j75f52a9 / Marathon

test / j8d5404b / MarkLogic

test / j5b70138 / Memcached

test / jbdadec9 / Mesos Master

test / j062aeb0 / Milvus

test / j91231ff (py3.13-4.4-standalone) / MongoDB-py3.13-4.4-standalone

test / j91231ff (py3.13-4.4-shard) / MongoDB-py3.13-4.4-shard

test / j91231ff (py3.13-4.4-auth) / MongoDB-py3.13-4.4-auth

test / j91231ff (py3.13-4.4-tls) / MongoDB-py3.13-4.4-tls

test / j91231ff (py3.13-5.0-standalone) / MongoDB-py3.13-5.0-standalone

test / j91231ff (py3.13-5.0-shard) / MongoDB-py3.13-5.0-shard

test / j91231ff (py3.13-5.0-auth) / MongoDB-py3.13-5.0-auth

test / j91231ff (py3.13-5.0-tls) / MongoDB-py3.13-5.0-tls

test / j91231ff (py3.13-6.0-standalone) / MongoDB-py3.13-6.0-standalone

test / j91231ff (py3.13-6.0-shard) / MongoDB-py3.13-6.0-shard

test / j91231ff (py3.13-6.0-auth) / MongoDB-py3.13-6.0-auth

test / j91231ff (py3.13-6.0-tls) / MongoDB-py3.13-6.0-tls

test / j91231ff (py3.13-7.0-standalone) / MongoDB-py3.13-7.0-standalone

test / j91231ff (py3.13-7.0-shard) / MongoDB-py3.13-7.0-shard

test / j91231ff (py3.13-7.0-auth) / MongoDB-py3.13-7.0-auth

test / j91231ff (py3.13-7.0-tls) / MongoDB-py3.13-7.0-tls

test / j91231ff (py3.13-8.0-standalone) / MongoDB-py3.13-8.0-standalone

test / j91231ff (py3.13-8.0-shard) / MongoDB-py3.13-8.0-shard

test / j91231ff (py3.13-8.0-auth) / MongoDB-py3.13-8.0-auth

test / j91231ff (py3.13-8.0-tls) / MongoDB-py3.13-8.0-tls

test / j91231ff (py3.13-8.0-standalone-newyork) / MongoDB-py3.13-8.0-standalone-newyork

test / j211906c (py3.13-5.7) / MySQL-py3.13-5.7

test / j211906c (py3.13-8.0.18) / MySQL-py3.13-8.0.18

test / j211906c (py3.13-8.0.36) / MySQL-py3.13-8.0.36

test / j211906c (py3.13-8.4.0) / MySQL-py3.13-8.4.0

test / j211906c (py3.13-8.0-group) / MySQL-py3.13-8.0-group

test / j211906c (py3.13-8.0-hybrid) / MySQL-py3.13-8.0-hybrid

test / j211906c (py3.13-mariadb-10.5) / MySQL-py3.13-mariadb-10.5

test / j211906c (py3.13-mariadb-10.6) / MySQL-py3.13-mariadb-10.6

test / j211906c (py3.13-mariadb-10.11) / MySQL-py3.13-mariadb-10.11

test / j211906c (py3.13-mariadb-11.4) / MySQL-py3.13-mariadb-11.4

test / j211906c (py3.13-percona-8.0.42) / MySQL-py3.13-percona-8.0.42

test / j211906c (py3.13-percona-8.4) / MySQL-py3.13-percona-8.4

test / j636396f / n8n

test / j5df646e / Nagios

test / jfc1e031 / Network on Linux

test / j6a5b846 / NFSstat

test / j93fea02 / NGINX

test / ja114815 / NGINX Ingress Controller

test / j71c1491 / Apache NiFi

test / jcc7e1d2 / Nutanix

test / jb705691 / nvidia_nim

test / j74dc677 / Nvidia Triton

test / jc2a0c60 / Octopus Deploy

test / j2cf0a0a / OpenLDAP

test / jaaa5727 / OpenMetrics

test / j88ddb5b / OpenStack

test / j65171af / OpenStack Controller

test / j4a8166b / PGBouncer

test / jaa8b34b / PHP-FPM

test / j54fefc0 / Postfix

test / j44368ad (py3.13-9.6-UTF8) / Postgres-py3.13-9.6-UTF8

test / j44368ad (py3.13-10.0-UTF8) / Postgres-py3.13-10.0-UTF8

test / j44368ad (py3.13-11.0-UTF8) / Postgres-py3.13-11.0-UTF8

test / j44368ad (py3.13-12.17-UTF8) / Postgres-py3.13-12.17-UTF8

test / j44368ad (py3.13-13.0-UTF8) / Postgres-py3.13-13.0-UTF8

test / j44368ad (py3.13-14.0-UTF8) / Postgres-py3.13-14.0-UTF8

test / j44368ad (py3.13-15.0-UTF8) / Postgres-py3.13-15.0-UTF8

test / j44368ad (py3.13-16.0-UTF8) / Postgres-py3.13-16.0-UTF8

test / j44368ad (py3.13-17.0-UTF8) / Postgres-py3.13-17.0-UTF8

test / j44368ad (py3.13-18.0-UTF8) / Postgres-py3.13-18.0-UTF8

test / j44368ad (py3.13-10.0-C) / Postgres-py3.13-10.0-C

test / j44368ad (py3.13-11.0-C) / Postgres-py3.13-11.0-C

test / j44368ad (py3.13-12.17-C) / Postgres-py3.13-12.17-C

test / j44368ad (py3.13-13.0-C) / Postgres-py3.13-13.0-C

test / j44368ad (py3.13-14.0-C) / Postgres-py3.13-14.0-C

test / j44368ad (py3.13-15.0-C) / Postgres-py3.13-15.0-C

test / j44368ad (py3.13-16.0-C) / Postgres-py3.13-16.0-C

test / j44368ad (py3.13-17.0-C) / Postgres-py3.13-17.0-C

test / j44368ad (py3.13-18.0-C) / Postgres-py3.13-18.0-C

test / j8e38a40 / PowerDNS Recursor

test / j8f01991 / Prefect

test / jaeea6e0 / Presto

test / je083bd8 / Process

test / jbfa97cf / Prometheus

test / jf882f09 / Proxmox

test / jbb39de2 / ProxySQL

test / j5987374 / Pulsar

test / jcc156e5 / Quarkus

test / j694032b / RabbitMQ

test / jcc172a7 / Ray

test / ja7f6415 / Redis

test / j47000ee / RethinkDB

test / jdeada9f / Riak

test / j21f86cb / RiakCS

test / j111b452 / SAP HANA

test / j6a5cfa3 / Scylla

test / j6600bce / Silk

test / jdeebd5c / Silverstripe CMS

test / j02f6aa9 / SingleStore

test / j1e78283 / Slurm

test / j06ca546 / SNMP

test / j2d7c8f5 / Solr

test / j9485e6f / SonarQube

test / j3835902 / sonatype_nexus

test / j529bc3b / Spark

test / j3a8e004 (py3.13-linux-FreeTDS-2019-single) / SQL Server on Linux-py3.13-linux-FreeTDS-2019-single

test / j3a8e004 (py3.13-linux-FreeTDS-2019-ha) / SQL Server on Linux-py3.13-linux-FreeTDS-2019-ha

test / j3a8e004 (py3.13-linux-FreeTDS-2022-single) / SQL Server on Linux-py3.13-linux-FreeTDS-2022-single

test / j3a8e004 (py3.13-linux-FreeTDS-2022-ha) / SQL Server on Linux-py3.13-linux-FreeTDS-2022-ha

test / j3a8e004 (py3.13-linux-FreeTDS-2025-single) / SQL Server on Linux-py3.13-linux-FreeTDS-2025-single

test / j3a8e004 (py3.13-linux-FreeTDS-2025-ha) / SQL Server on Linux-py3.13-linux-FreeTDS-2025-ha

test / j3a8e004 (py3.13-linux-odbc-2019-single) / SQL Server on Linux-py3.13-linux-odbc-2019-single

test / j3a8e004 (py3.13-linux-odbc-2019-ha) / SQL Server on Linux-py3.13-linux-odbc-2019-ha

test / j3a8e004 (py3.13-linux-odbc-2022-single) / SQL Server on Linux-py3.13-linux-odbc-2022-single

test / j3a8e004 (py3.13-linux-odbc-2022-ha) / SQL Server on Linux-py3.13-linux-odbc-2022-ha

test / j3a8e004 (py3.13-linux-odbc-2025-single) / SQL Server on Linux-py3.13-linux-odbc-2025-single

test / j3a8e004 (py3.13-linux-odbc-2025-ha) / SQL Server on Linux-py3.13-linux-odbc-2025-ha

test / j3a8e004 (py3.13-linux-2022-newyork) / SQL Server on Linux-py3.13-linux-2022-newyork

test / j3a8e004 (py3.13-linux-2022-tokyo) / SQL Server on Linux-py3.13-linux-2022-tokyo

test / jaf4b616 / Squid

test / j01c4d3c / SSH

test / j2981dbe / StatsD

test / j6f0ded4 / Strimzi

test / jfe7ceb7 / Supabase

test / jf04a052 / Supervisord

test / jde3891f / System Core

test / j64445e6 / System Swap

test / j1eeafd2 / TCP on Linux

test / j8217a3a / TeamCity

test / jf4a7e97 / Tekton

test / je68b3b9 / Teleport

test / j840fec7 / Temporal

test / jeefbe37 / Teradata

test / jb4a6940 / tibco_ems

test / jd1c18ec / TLS

test / j9438e1d / Tomcat

test / j4baeba2 / TorchServe

test / j41a575a / Traefik Mesh

test / j8a1b5bb / Traffic Server

test / jfc2bf01 / Twemproxy

test / jd0626ef / Twistlock

test / j0c8fc90 / Varnish

test / j5d55c41 / Vault

test / jf929c3b / Velero

test / j9981b0b / Vertica

test / jeae0788 / vLLM

test / jb120af1 / VoltDB

test / j269c8a5 / vSphere

test / je95095e / Weaviate

test / j40e5c98 / WebLogic

test / ja6bc642 / Yarn

test / ja446cea / ZooKeeper

publish-test-results / Publish

upload-coverage

Backport PR on: pull_request_target 3

Backport PR

Slack emoji PR updates on: pull_request 1

run_slapr_agent_integrations (SLACK_CHANNEL_ID)

run_slapr_agent_integrations (SLACK_CHANNEL_ID_AGENT_INTEGRATIONS_REVIEWS)

Add Milestone on a Merged PR on: pull_request 3

Add Milestone on PR

Code scanning results

CodeQL

GitHub Advanced Security / CodeQL succeeded Jun 24, 2026 in 2s

No new alerts in code changed by this pull request

View all branch alerts.

Loading

Re-running checks...