跳转到主要内容
此内容尚未提供您的语言版本,正在以英文显示。

Kafka Deduplicator

命令行 已验证 活跃

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

目的

To provide reliable, partition-aware deduplication of Kafka events, ensuring data integrity and operational stability in streaming pipelines.

功能

  • Partition-aware Kafka event deduplication
  • State persistence using RocksDB
  • Checkpointing for recovery and reassignment
  • Support for multiple pipeline types (ingestion_events, clickhouse_events)
  • Configurable fail-open mode for operational bypass

使用场景

  • Ensuring unique event processing from Kafka topics
  • Recovering from consumer rebalances or failures with minimal data loss
  • Handling high-throughput event streams with deduplication requirements
  • Integrating with downstream Kafka topics or other data sinks after deduplication

非目标

  • Providing a generic Kafka consumer without deduplication logic
  • Acting as a Kafka producer or broker
  • Handling event transformations beyond deduplication

Trust

  • info:Issues AttentionThere were 544 issues opened and 163 closed in the last 90 days, indicating a closure rate below 50% and a high volume of open issues.

Compliance

  • info:GDPRThe service processes Kafka events which may contain personal data. While not submitting to a third party, the data is processed and potentially logged, with no explicit sanitization mentioned before LLM interaction.

质量评分

已验证
92 /100
7 days ago 分析

信任信号

最近提交7 days ago
星标34.5k
许可证NOASSERTION
状态
查看源代码

类似扩展

Netdata Field Encoder CLI

99

The fastest path to AI-powered full stack observability, even for lean teams.

命令行
netdata

Personhog Writer

75

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

命令行
PostHog

Personhog Leader

75

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

命令行
PostHog

Batch Import Worker

75

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

命令行
PostHog

Livestream

68

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

命令行
PostHog

Property Defs Rs

65

🦔 PostHog is an all-in-one developer platform for building successful products. We offer product analytics, web analytics, session replay, error tracking, feature flags, experimentation, surveys, data warehouse, a CDP, and an AI product assistant to help debug your code, ship features faster, and keep all your usage and customer data in one stack.

命令行
PostHog