This is stars and forks stats for /zhangchuangiie/SimpleKafka repository. As of 09 May, 2024 this repository has 290 stars and 22 forks.
SimpleKafka（Kafka客户端封装工具类） 一个基于Kafka客户端封装的工具，Kafka开发效率神器 特点： 封装了常用的Kafka客户端操作，无需维护配置，无需初始化客户端，真正实现了一行代码调用 将连接池的维护封装在工具类里面，多线程使用也无需维护客户端集合 使用方式： 只需要集成1个KafkaUtil.java文件即可，修改里面的kafka服务地址即可 典型示例： 同步生产: LinkedHashMap<String, Object> recordMeta = KafkaUtil.sendToKafka("RULEa93304e6d844000","222","aaaa"); 异步生产: KafkaUtil.sendToKafkaAsync("RULEa93304e6d844000", "222", "aaaa"); 消费数据: ArrayList<LinkedHashMap<String, Object>> buffer = KafkaUtil.recvFromKafka("RULEa93304e6d844000", "group1"); 重置偏移:...
SimpleKafka（Kafka客户端封装工具类） 一个基于Kafka客户端封装的工具，Kafka开发效率神器 特点： 封装了常用的Kafka客户端操作，无需维护配置，无需初始化客户端，真正实现了一行代码调用 将连接池的维护封装在工具类里面，多线程使用也无需维护客户端集合 使用方式： 只需要集成1个KafkaUtil.java文件即可，修改里面的kafka服务地址即可 典型示例： 同步生产: LinkedHashMap<String, Object> recordMeta = KafkaUtil.sendToKafka("RULEa93304e6d844000","222","aaaa"); 异步生产: KafkaUtil.sendToKafkaAsync("RULEa93304e6d844000", "222", "aaaa"); 消费数据: ArrayList<LinkedHashMap<String, Object>> buffer = KafkaUtil.recvFromKafka("RULEa93304e6d844000", "group1"); 重置偏移:...
| repo | techs | stars | weekly | forks | weekly |
|---|---|---|---|---|---|
| openziti/goroutine-analyzer | Java | 125 | 0 | 1 | 0 |
| webtorrent/webtorrent | JavaScriptShell | 28.3k | +22 | 2.7k | +2 |
| 5t3ph/11ty-sass-skeleton | NunjucksJavaScriptSCSS | 235 | 0 | 17 | 0 |
| apache/cordova-plugin-statusbar | Objective-CJavaScriptJava | 612 | 0 | 483 | 0 |
| laravel/bootcamp.laravel.com | PHPBladeJavaScript | 87 | 0 | 50 | 0 |
| amritanand-py/cps02 | CC++Java | 10 | 0 | 29 | 0 |
| e-maxx-eng/e-maxx-eng | C++HTMLC | 5.5k | 0 | 1.3k | 0 |
| azampagl/express-boilerplate | CoffeeScriptJavaScriptShell | 1 | 0 | 1 | 0 |
| christianselig/OpenInApolloExtension | CSSJavaScriptSwift | 233 | 0 | 15 | 0 |
| aditya14-7/git-finder | CSSJavaScriptHTML | 0 | 0 | 12 | 0 |