2 个仓库
Awesome GitHub RepositoriesOffset Configurations
Configures the starting offset or timestamp position for consuming Kafka topics per partition.
Distinct from Kafka: Distinct from Kafka: this is a specific offset configuration capability, not general Kafka integration.
Explore 2 awesome GitHub repositories matching data & databases · Offset Configurations. Refine with filters or upvote what's useful.
Awesome Offset Configurations GitHub Repositories
用 AI 发现最棒的仓库。我们将通过 AI 为您搜索最匹配的仓库。
- materializeinc/materialize
MaterializeInc/materialize
6,314在 GitHub 上查看Materialize is a streaming SQL database that continuously ingests live data from sources such as Kafka, Redpanda, PostgreSQL, and MySQL, and incrementally maintains materialized views. It provides a PostgreSQL-compatible query engine that accepts standard SQL over the PostgreSQL wire protocol, enabling any existing SQL client or BI tool to query real-time data. The system also includes a Model Context Protocol (MCP) server that exposes live materialized view data to AI agents, providing fresh context without polling. Materialize distinguishes itself through its ability to offer configurable c
Configures starting offsets for Kafka topic consumption in streaming SQL sources.
Rust - edenhill/kafkacat
edenhill/kafkacat
5,761在 GitHub 上查看Kafkacat 是一套用于与 Apache Kafka 集群交互的命令行实用程序。它提供了一个非 JVM 二进制文件，用于生产和消费消息、检查集群元数据以及通过终端调试 Kafka 协议。 该工具的功能包括作为生产者和消费者，能够从文件或标准输入推送数据，并从特定主题和分区读取消息。它包括一个元数据检查器，以纯文本或 JSON 格式检索集群状态和分区配置，以及一个用于检查消息偏移量、时间戳和二进制负载的协议调试器。 该项目涵盖使用模式或原始解码器进行数据反序列化，以及基于偏移量的查询以从精确时间戳检索数据。它还提供模拟实用程序来运行短暂的内存中 Broker，用于集成测试和性能基准测试。
Allows querying specific message positions by timestamp to consume data from a precise point in time.
C
