Skip to content
#

kafka

Star

Here are 6,334 public repositories matching this topic...

Language: All
Filter by language
All 6,334 Java 2,190 Python 676 Go 587 Scala 503 JavaScript 364 Shell 324 C# 156 TypeScript 143 Kotlin 136 HTML 104
Sort: Best match
Sort options
Best match Most stars Fewest stars Most forks Fewest forks Recently updated Least recently updated
flink-learning

zhisheng17 / flink-learning

Star

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

mysql redis elasticsearch streaming kafka spark influxdb rabbitmq clickhouse hbase stream-processing opentsdb loki flink rocketmq
  • Updated Aug 14, 2021
  • Java
signoz

SigNoz / signoz

Star
Find more good first issues →

confluentinc / ksql

Star
Find more good first issues →
watermill

ThreeDotsLabs / watermill

Star
Open

Issue with topic and consumer group names in test suite

1
breml
breml commented Mar 10, 2021

For an implementation of #126 (PostgreSQL driver with SKIP LOCKED), I create a SQL table for each consumer group containing the offsets ready to be consumed. The name for these tables is build by concatenating some prefix, the name of the topic and the name of the consumer group. In some of the test cases in the test suite, UUID are used for both, the topic and the consumer group. Each UUID has

Read more
enhancement help wanted good first issue S
Find more good first issues →

fanliang11 / surging

Star

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM

redis microservices kafka apollo rabbitmq consul json-serialization swagger grpc apigateway zookeeper messagepack nlog log4net dns-server kestrel skywalking memorycache protobuffer surging
  • Updated Jun 7, 2021
  • C#

Improve this page

Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."

Learn more