- 1配置kubernetes UI图形化界面与谷歌浏览器访问k8s页面问题解决
- 2python中yield和协程_python sche_yield负载
- 3( “ 图 “ 之 并查集 ) 684. 冗余连接 ——【Leetcode每日一题】_树可以看成是一个连通且无环的无向图。 给定往一棵 n 个节点 (节点值 1～n) 的树
- 4【硬核】源码 + 案例分享 JDK8 新特性中的四大函数式接口_jdk8四大函数
- 5SpringBoot 整合 druid数据源_spring.datasource.druid.max-wait
- 6Scrapy和Selenium整合（一文搞定）_scrapy selenium
- 7教你如何在Windows10环境下顺利安装minepy并成功运行！_no module named 'minepy
- 8VS code 保存或新建文件没有权限的问题Unable to write file (NoPermissions (FileSystemError): Error: EACCES: permissi_unable to write file '/home/hyq1/test/cpptest/test
- 9网络安全:NMAP 高级使用技巧和NESSUS漏洞检测_nmap 验证漏洞
- 10GitHub访问速度慢_github访问太慢
kafka同步任务后台rest调用方法整理_如何实现kafka监听到消息后,同步调用外部rest接口
赞
踩
最近一直在研究kafka，没前端只有在后端操作，所以整理一些操作命令，具体可在kafka官网查看
1. 获取所有Connector的列表
```
curl -X GET -H "Content-Type:application/json" kafkacluster-connect-headless:8083/connectors|jq
```
2. 创建一个Connector
```
curl -s -X PUT -H "Content-Type:application/json" --DATE @source.json kafkacluster-connect-headless:8083/connectors/mm2name/config
mm2name为config路径下的source文件中定义的同步任务名字
3.暂停pause，恢复resume，重启restart
curl -s -X PUT -H "Content-Type:application/json" --DATE @source.json kafkacluster-connect-headless:8083/connectors/mm2name/pause
重启可用POST方法
4.查看任务状态
curl -X GET -H "Content-Type:application/json" kafkacluster-connect-headless:8083/connectors/mm2name/status | jq
去掉status可查看配置
5.删除
curl -X DELETE -H "Content-Type:application/json" kafkacluster-connect-headless:8083/connectors/mm2name
