kafka
Here are 7,615 public repositories matching this topic...
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
-
Updated
Jun 13, 2022 - Java
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
-
Updated
Jun 4, 2022 - Java
Open-source IoT Platform - Device management, data collection, processing and visualization.
-
Updated
Jun 18, 2022 - Java
CMAK is a tool for managing Apache Kafka clusters
-
Updated
Apr 29, 2022 - Scala
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
-
Updated
Jun 18, 2022 - Java
Python Stream Processing
-
Updated
Jun 7, 2022 - Python
The Apache Kafka C/C++ library
-
Updated
Jun 17, 2022 - C
Is your feature request related to a problem? Please describe.
A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
Currently, ksqlDB causes a full topic scan whenever performing a pull query over a stream. This is inefficient when looking up specific sets of data, but necessary due to how pull queries are implemented over streams.
**Describe the
Kafka library in Go
-
Updated
Jun 15, 2022 - Go
-
Updated
Jun 17, 2022 - JavaScript
This comment says that the message ID is optional,
but for SQL transport it is a mandatory attribute,
in turn it causes misunderstanding?
Is it possible to fix it or did I get something wrong?
https://github.com/ThreeDotsLabs/watermill/blob/b9928e750ba673cf93d442db88efc04706f67388/message/message.go#L20
https://github.com/ThreeDotsLabs/watermill/blob/b9928e750ba673cf93d442db88efc04706f6
Fancy stream processing made operationally mundane
-
Updated
Jun 19, 2022 - Go
【咕泡学院实战项目】-基于SpringBoot+Dubbo构建的电商平台-微服务架构、商城、电商、微服务、高并发、kafka、Elasticsearch
-
Updated
Jun 17, 2022 - Java
Por Sentry Kafka client (arroyo) tests to Redpanda ducktape tests suite.
PipelineAI Kubeflow Distribution
-
Updated
Apr 24, 2020 - Jsonnet
一站式Apache Kafka集群指标监控与运维管控平台
-
Updated
Mar 17, 2022 - Java
The Fastest Way to Build the Fastest Data Products. Build data-intensive applications and services in SQL — without pipelines or caches — using materialized views that are always up-to-date.
-
Updated
Jun 19, 2022 - Rust
Kafka Web UI
-
Updated
Jun 19, 2022 - Java
API traffic viewer for Kubernetes enabling you to view all API communication between microservices. Think TCPDump and Wireshark re-invented for Kubernetes
-
Updated
Jun 19, 2022 - Go
Improve this page
Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."
I have noticed when ingesting backlog(older timestamped data) that the "Messages per minute" line graph and "sources" data do not line up.
The Messages per minute appear to be correct for the ingest rate, but the sources breakdown below it only show messages for each type from within the time window via timestamp. This means in the last hour if you've ingested logs from 2 days ago, the data is