ToB企服应用市场:ToB评测及商务社交产业平台

标题: Strimzi Kafka Bridge(桥接)实战之三：自制sdk(golang版本) [打印本页]

---

作者: 悠扬随风    时间: 2023-10-16 04:42
标题: Strimzi Kafka Bridge(桥接)实战之三：自制sdk(golang版本)
欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos

本篇概览

• 本文是《Strimzi Kafka Bridge(桥接)实战》的第三篇，前文咱们掌握了Strimzi Kafka Bridge的基本功能：基于http提供各种kafka消息的服务
  
• 此刻，如果想通过http接口调用bridge的服务，势必要写不少代码（请求数据的生成、响应数据的解析），好在Strimzi已经提供了标准OpenApi的配置文件，咱们可以根据这个配置文件生成与http接口相关的代码，省去不少工作
  

为什么是golang版本

• 熟悉欣宸的读者都知道欣宸是个正宗的java程序员，那么，本篇应该实战java版本的SDK吧，怎么就研究起了golang版本呢？
  
• 因为Strimzi Kafka Bridge提供的OpenApi配置，用来生成客户端sdk之后，是无法正常使用的！！！，没错，您没看错，用工具生成的sdk，不论是golang版还是java版，都用不了！
  
• 相比之下，golang版的sdk，虽然不能用，但是经过抢救还是可以正常工作的，这也是本篇的主要内容
  
• 而java版的就没那么幸运了，涉及到jar库的依赖，就算是改代码也救不活，于是只能放弃，具体的原因本文末尾会给出，当然了，也许是欣宸水平太差，换成其他高手说不定就给救活了
  
• 闲话少说，接下来的内容由以下这几个步骤组成
  

• 介绍一下我这边的环境信息
  
• 下载OpenApi的配置文件
  
• 下载swagger工具
  
• 用swagger工具生成客户端sdk代码
  
• 创建一个golang的demo程序，使用刚刚生成的客户端sdk代码
  
• 客户端sdk代码存在诸多问题，但是可以逐个修复，这里咱们就来修复它们
  
• 运行一个demo程序，调用sdk代码中的API，验证基本功能
  

环境信息

• 以下是我这边的环境信息，您可以作为参考
  

• JDK：11.0.14.1
  
• Maven：3.8.5
  
• strimzi-kafka-bridge：0.22.3
  
• swagger-codegen-cli：2.4.9
  

• 需要注意的是，swagger工具是jar格式的，因此需要当前环境准备好JDK
  

下载OpenApi的配置文件

• Strimzi Kafka Bridge的master分支处于活跃状态，因此不适合拿来实战，咱们选择一个发布版本吧
  
• 下载strimzi-kafka-bridge源码，地址是：https://codeload.github.com/strimzi/strimzi-kafka-bridge/zip/refs/tags/0.22.3 ，下载后解压得到名为strimzi-kafka-bridge-0.22.3的文件夹
  
• 这个文件就是OpenApi的配置文件，可以用来生成客户端sdk源码：strimzi-kafka-bridge-0.22.3/src/main/resources/openapiv2.json ，稍后会用到
  

下载swagger工具

• swagger工具的下载地址是：https://repo1.maven.org/maven2/io/swagger/swagger-codegen-cli/2.4.9/swagger-codegen-cli-2.4.9.jar
  
• 现在新建一个目录，我这里新建了一个名为001的目录，将openapiv2.json和swagger-codegen-cli-2.4.9.jar这两个刚下载的文件放在这个目录下
  
• 在001的目录下新增一个名为swagger的目录
  

用swagger工具生成客户端sdk代码

• 使用默认参数来生成客户端sdk代码的操作十分简单
  

1. java -jar swagger-codegen-cli-2.4.9.jar generate \
2. -i ./openapiv2.json \
3. -l go \
4. -o swagger

复制代码

• 执行完命令后，控制台输出如下
  
  
• 查看swagger目录，发现已经生成了大量文件
  

1. ➜  001 tree swagger
2. swagger
3. ├── README.md
4. ├── api
5. │   └── swagger.yaml
6. ├── api_consumers.go
7. ├── api_default.go
8. ├── api_producer.go
9. ├── api_seek.go
10. ├── api_topics.go
11. ├── client.go
12. ├── configuration.go
13. ├── docs
14. │   ├── AssignedTopicPartitions.md
15. │   ├── BridgeInfo.md
16. │   ├── Consumer.md
17. │   ├── ConsumerRecord.md
18. │   ├── ConsumerRecordList.md
19. │   ├── ConsumersApi.md
20. │   ├── CreatedConsumer.md
21. │   ├── DefaultApi.md
22. │   ├── KafkaHeader.md
23. │   ├── KafkaHeaderList.md
24. │   ├── ModelError.md
25. │   ├── OffsetCommitSeek.md
26. │   ├── OffsetCommitSeekList.md
27. │   ├── OffsetRecordSent.md
28. │   ├── OffsetRecordSentList.md
29. │   ├── OffsetsSummary.md
30. │   ├── Partition.md
31. │   ├── PartitionMetadata.md
32. │   ├── Partitions.md
33. │   ├── ProducerApi.md
34. │   ├── ProducerRecord.md
35. │   ├── ProducerRecordList.md
36. │   ├── ProducerRecordToPartition.md
37. │   ├── ProducerRecordToPartitionList.md
38. │   ├── Replica.md
39. │   ├── SeekApi.md
40. │   ├── SubscribedTopicList.md
41. │   ├── TopicMetadata.md
42. │   ├── Topics.md
43. │   └── TopicsApi.md
44. ├── git_push.sh
45. ├── model_assigned_topic_partitions.go
46. ├── model_bridge_info.go
47. ├── model_consumer.go
48. ├── model_consumer_record.go
49. ├── model_consumer_record_list.go
50. ├── model_created_consumer.go
51. ├── model_error.go
52. ├── model_kafka_header.go
53. ├── model_kafka_header_list.go
54. ├── model_offset_commit_seek.go
55. ├── model_offset_commit_seek_list.go
56. ├── model_offset_record_sent.go
57. ├── model_offset_record_sent_list.go
58. ├── model_offsets_summary.go
59. ├── model_partition.go
60. ├── model_partition_metadata.go
61. ├── model_partitions.go
62. ├── model_producer_record.go
63. ├── model_producer_record_list.go
64. ├── model_producer_record_to_partition.go
65. ├── model_producer_record_to_partition_list.go
66. ├── model_replica.go
67. ├── model_subscribed_topic_list.go
68. ├── model_topic_metadata.go
69. ├── model_topics.go
70. └── response.go
72. 2 directories, 66 files

复制代码

创建一个golang的demo程序，使用刚刚生成的客户端sdk代码

• 新建名为sdkdemo的文件夹
  
• 在sdkdemo的文件夹下面执行以下命令，新建一个go工程
  

1. go mod init sdkdemo

复制代码

• 需要引入两个包，执行以下命令
  

1. go get golang.org/x/oauth2
2. go get github.com/antihax/optional

复制代码

• 将前面生成代码的swagger文件夹复制到sdkdemo的文件夹下面
  
• 现在sdkdemo的文件夹下面有这些东西
  
  
• 为了方便开发，接下来用IDE工具进行开发，我这里用的是goland，打开项目后新增名为main.go的文件
  
  
• 接下来咱们要面对的是一堆破绽百出的sdk代码，不过还好，可以拯救，咱们一起啦拯救吧
  

修复有问题的sdk源码，第一个问题

• 一共有6个问题，咱们逐一修复
  
• 第一个问题如下图，SeekToEndOpts这个数据结构在api_seek.go和api_consumer.go中都有，显然是重复定义了，将左侧api_seek.go中的SeekToEndOpts定义删除掉
  
  

第二个问题

• 第二个问题如下图，SendOpts这个数据结构在api_topics.go和api_producer.go中都有，显然是重复定义了，将左侧api_topics.go中的SeekToEndOpts定义删除掉
  
  

第三个问题

• 第三个问题最让人痛苦（因为java版也被此问题折磨，且不好处理），bridge的请求和响应的contentType，与咱们平时常用的application/json不同，在bridge这里用的是这两种：application/vnd.kafka.v2+json和application/vnd.kafka.json.v2+json，其实这个也好理解：生产和发送的消息内容不一定只有json格式，可能还会嵌入其他格式的消息，这就要有kafka自己的协议来支持了，于是contentType就变得比较特殊
  
• 话虽这么说，但是swagger不认识application/vnd.kafka.v2+json和application/vnd.kafka.json.v2+json这两种格式，于是生成的代码自然也就不支持了
  
• 来看看具体问题吧，打开文件client.go，当前decode方法源码如下，可见是不会处理application/vnd.kafka.v2+json和application/vnd.kafka.json.v2+json这两种的
  

1. func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err error) {
2.         if strings.Contains(contentType, "application/xml") {
3.                 if err = xml.Unmarshal(b, v); err != nil {
4.                         return err
5.                 }
6.                 return nil
7.         } else if strings.Contains(contentType, "application/json") {
8.                 if err = json.Unmarshal(b, v); err != nil {
9.                         return err
10.                 }
11.                 return nil
12.         }
13.         return errors.New("undefined response type")
14. }

复制代码

• 把代码改成下面这样，对application/vnd.kafka.v2+json和application/vnd.kafka.json.v2+json这两种类型的数据，处理方法都等同于json
  

1. func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err error) {
2.         if strings.Contains(contentType, "application/xml") {
3.                 if err = xml.Unmarshal(b, v); err != nil {
4.                         return err
5.                 }
6.                 return nil
7.         } else if strings.Contains(contentType, "application/json") ||
8.                 strings.Contains(contentType, "application/vnd.kafka.v2+json") ||
9.                 strings.Contains(contentType, "application/vnd.kafka.json.v2+json") {
10.                 if err = json.Unmarshal(b, v); err != nil {
11.                         return err
12.                 }
13.                 return nil
14.         }
15.         return errors.New("undefined response type")
16. }

复制代码

• 当然了这样做的弊端也很明显：只支持json格式的内容，kakfa原本支持的多种格式都不能处理了
  

第四个问题

• 第四个问题也和contentType有关，前面第三个问题发生在请求阶段，而第四个问题发生在处理响应数据的阶段
  
• 还是client.go文件，这次是setBody方法，先看看原始内容
  

1. // Set request body from an interface{}
2. func setBody(body interface{}, contentType string) (bodyBuf *bytes.Buffer, err error) {
3.         if bodyBuf == nil {
4.                 bodyBuf = &bytes.Buffer{}
5.         }
7.         if reader, ok := body.(io.Reader); ok {
8.                 _, err = bodyBuf.ReadFrom(reader)
9.         } else if b, ok := body.([]byte); ok {
10.                 _, err = bodyBuf.Write(b)
11.         } else if s, ok := body.(string); ok {
12.                 _, err = bodyBuf.WriteString(s)
13.         } else if s, ok := body.(*string); ok {
14.                 _, err = bodyBuf.WriteString(*s)
15.         } else if jsonCheck.MatchString(contentType) {
16.                 err = json.NewEncoder(bodyBuf).Encode(body)
17.         } else if xmlCheck.MatchString(contentType) {
18.                 xml.NewEncoder(bodyBuf).Encode(body)
19.         }
21.         if err != nil {
22.                 return nil, err
23.         }
25.         if bodyBuf.Len() == 0 {
26.                 err = fmt.Errorf("Invalid body type %s\n", contentType)
27.                 return nil, err
28.         }
29.         return bodyBuf, nil
30. }

复制代码

• 修改后的内容如下图，红色箭头所指为新增内容
  
  

第五个问题

• 第五个问题，简直是strimzi拿来恶心开发者的，在拉取消息的时候，bridge的server端只支持application/vnd.kafka.json.v2+json，结果在OpenApi中却定义了多种类型，结果拉去消息的时候，bridge会提示多出的类型不支持
  
• 这个问题可以用postman等工具复现，如下图
  
  
• 代码的改动如下图，修改api_consumers.go
  
  

第六个问题

• 最后一个问题是数据结构定义问题，打开model_consumer_record_list.go，看到内容如下，真够坏的，挖这么大的坑...
  

1. package swagger
3. type ConsumerRecordList struct {
4. }

复制代码

• 改成这样就好了
  

1. package swagger
3. type ConsumerRecordList []ConsumerRecord

复制代码

第七个问题

• 第七个问题，也是挖了个坑让我跳，打开文件model_producer_record.go，内容如下，根据前一篇的请求内容，可知这里缺少两个字段：Key和Value
  

1. package swagger
3. type ProducerRecord struct {
4.         Partition int32 `json:"partition,omitempty"`
5.         Headers *KafkaHeaderList `json:"headers,omitempty"`
6. }

复制代码

• 修改后如下
  

1. package swagger
3. type ProducerRecord struct {
4.         Partition int32 `json:"partition,omitempty"`
5.         Value string `json:"value"`
6.         Key string `json:"key,omitempty"`
7.         Headers *KafkaHeaderList `json:"headers,omitempty"`
8. }

复制代码

第八个问题

• 最后一个问题，是在提交offset的时候，bridge后台不接受contentType，所以请打开文件api_consumers.go，修改如下，注释掉一行代码
  
  
• 坑已经填完了，开始验证SDK能不能用吧
  

编写代码验证功能：查看topic列表

• 打开main.go文件，增加以下内容，都是要用到的常量，以及sdk配置的初始化
  

1. // 测试用的topic
2. const TEST_TOPIC = "bridge-quickstart-topic"
4. const TEST_GROUP = "client-sdk-group"
6. const CONSUMER_NAME = "client-sdk-consumer-002"
8. // strimzi bridge地址
9. const BASE_PATH = "http://127.0.0.1:31331"
11. var client *swagger.APIClient
13. func init() {
14.         configuration := swagger.NewConfiguration()
15.         configuration.BasePath = BASE_PATH
16.         client = swagger.NewAPIClient(configuration)
17. }

复制代码

• 调用SDK来查看kafka的topic列表的代码如下
  

1. func getAllTopics() ([]string, error) {
2.         array, response, err := client.TopicsApi.ListTopics(context.Background())
4.         if err != nil {
5.                 log.Printf("getAllTopics err: %v\n", err)
6.                 return nil, err
7.         }
9.         log.Printf("response: %v", response)
11.         return array, nil
12. }

复制代码

• 在main方法中调用getAllTopics
  

1. func main() {
2.         topics, err := getAllTopics()
3.         if err != nil {
4.                 return
5.         }
7.         fmt.Printf("topics: %v\n", topics)
8. }

复制代码

• 运行main方法，结果如下，可见成功获取到topic列表，sdk能用
  

1. 2022/12/18 21:26:33 response: &{200 OK 200 HTTP/1.1 1 1 map[Content-Length:[109] Content-Type:[application/vnd.kafka.v2+json]] 0x140000e0300 109 [] false false map[] 0x14000118100 <nil>}
2. topics: [__strimzi_store_topic bridge-quickstart-topic __strimzi-topic-operator-kstreams-topic-store-changelog]
4. Process finished with the exit code 0

复制代码

编写代码验证功能：发送消息

• 发送消息的代码如下
  

1. // 发送消息(异步模式，不会收到offset返回)
2. func sendAsync(info string) error {
3.         log.Print("send [" + info + "]")
4.         _, response, err := client.ProducerApi.Send(context.Background(),
5.                 TEST_TOPIC,
6.                 swagger.ProducerRecordList{
7.                         Records: []swagger.ProducerRecord{
8.                                 {Value: "message from go swagger SDK"},
9.                         },
10.                 },
11.                 &swagger.SendOpts{Async: optional.NewBool(true)},
12.         )
14.         if err != nil {
15.                 log.Printf("send err: %v\n", err)
16.                 return err
17.         }
19.         log.Printf("response: %v", response.StatusCode)
21.         return nil
22. }

复制代码

• 把main方法改成下面这样，连续调用发送消息的请求
  

1. func main() {
2.         for i := 0; i < 10; i++ {
3.                 sendAsync("message from go client " + strconv.Itoa(i))
4.         }
5. }

复制代码

• 控制台输出如下，可见发送消息成功，稍后咱们还会写消费的代码来消费这些消息
  

1. /private/var/folders/5v/p3bj9bzx2nd99y5l21nb1c080000gn/T/GoLand/___go_build_sdkdemo
2. 2022/12/18 21:35:47 send [message from go client 0]
3. 2022/12/18 21:35:47 response: 204
4. 2022/12/18 21:35:47 send [message from go client 1]
5. 2022/12/18 21:35:47 response: 204
6. 2022/12/18 21:35:47 send [message from go client 2]
7. 2022/12/18 21:35:47 response: 204
8. 2022/12/18 21:35:47 send [message from go client 3]
9. 2022/12/18 21:35:47 response: 204
10. 2022/12/18 21:35:47 send [message from go client 4]
11. 2022/12/18 21:35:47 response: 204
12. 2022/12/18 21:35:47 send [message from go client 5]
13. 2022/12/18 21:35:47 response: 204
14. 2022/12/18 21:35:47 send [message from go client 6]
15. 2022/12/18 21:35:47 response: 204
16. 2022/12/18 21:35:47 send [message from go client 7]
17. 2022/12/18 21:35:47 response: 204
18. 2022/12/18 21:35:47 send [message from go client 8]
19. 2022/12/18 21:35:47 response: 204
20. 2022/12/18 21:35:47 send [message from go client 9]
21. 2022/12/18 21:35:47 response: 204
23. Process finished with the exit code 0

复制代码

编写代码验证功能：创建consumer

• 先增加两个辅助方法，用来处理特别的包体和错误信息
  

1. // 取出swagger特有的error类型，从中提取中有效的错误信息
2. func getErrorMessage(err error) string {
3.         e := err.(swagger.GenericSwaggerError)
4.         return string(e.Body())
5. }
7. func getBodyStr(body io.ReadCloser) string {
8.         buf := new(bytes.Buffer)
9.         buf.ReadFrom(body)
10.         return buf.String()
11. }

复制代码

• 创建consumer的代码如下
  

1. // 创建consumer
2. func CreateConsumer(group string, consumerName string) (*swagger.CreatedConsumer, error) {
4.         consumer, response, err := client.ConsumersApi.CreateConsumer(context.Background(),
5.                 group,
6.                 swagger.Consumer{
7.                         Name:                     consumerName,
8.                         AutoOffsetReset:          "latest",
9.                         FetchMinBytes:            16,
10.                         ConsumerRequestTimeoutMs: 300 * 1000,
11.                         EnableAutoCommit:         false,
12.                         Format:                   "json",
13.                 })
15.         if err != nil {
16.                 log.Printf("CreateConsumer error : %v", getErrorMessage(err))
17.                 return nil, err
18.         }
20.         log.Printf("CreateConsumer response : %v, body [%v]", response, getBodyStr(response.Body))
21.         log.Printf("consumer : %v", consumer)
22.         return &consumer, nil
23. }

复制代码

• 在main方法中调用，即可创建consumer
  

1. func main() {
2.         // 创建consumer
3.         CreateConsumer(TEST_GROUP, CONSUMER_NAME)
4. }

复制代码

编写代码验证功能：订阅

• 订阅代码如下
  

1. // 订阅
2. func Subsciribe(topic string, consumerGroup string, consumerName string) error {
4.         response, err := client.ConsumersApi.Subscribe(context.Background(),
5.                 swagger.Topics{Topics: []string{topic}},
6.                 consumerGroup,
7.                 consumerName,
8.         )
10.         if err != nil {
11.                 log.Printf("Subscribe error : %v", err)
12.                 return err
13.         }
15.         log.Printf("Subscribe response : %v", response)
16.         return nil
17. }

复制代码

• 在main方法中这样调用
  

1. func main() {
2.         err := Subsciribe(TEST_TOPIC, TEST_GROUP, CONSUMER_NAME)
3.         if err != nil {
4.                 fmt.Printf("err : %v\n", err)
5.         }
6. }

复制代码

编写代码验证功能：拉取消息

• 以下是拉取消息的代码
  

1. // 拉取消息
2. func Poll(consumerGroup string, consumerName string) error {
3.         // ctx context.Context, groupid string, name string, localVarOptionals *PollOpts
4.         recordList, response, err := client.ConsumersApi.Poll(context.Background(), consumerGroup, consumerName, nil)
5.         if err != nil {
6.                 log.Printf("Poll error : %v", err)
7.                 return err
8.         }
10.         log.Printf("Poll response : %v", response)
11.         fmt.Printf("recordList: %v\n", recordList)
12.         return nil
13. }

复制代码

• main方法如下
  

1. func main() {
2.         Poll(TEST_GROUP, CONSUMER_NAME)
3. }

复制代码

• 执行main方法，第一次拉取不到消息，别担心，这是正常的现象，按照官方的说法，拉取到的第一条消息就是空的，这是因为拉取操作出触发了rebalancing逻辑（rebalancing是kafka的概览，是处理多个partition消费的操作），再次执行main方法，这下正常了，控制台输出如下
  

1. /private/var/folders/5v/p3bj9bzx2nd99y5l21nb1c080000gn/T/GoLand/___go_build_sdkdemo
2. 2022/12/18 21:43:16 Poll response : &{200 OK 200 HTTP/1.1 1 1 map[Content-Length:[2301] Content-Type:[application/vnd.kafka.json.v2+json]] 0x140000e0340 2301 [] false false map[] 0x1400011a100 <nil>}
3. recordList: [{ 163468 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 163469 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 163470 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 163471 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 163472 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 163473 0 bridge-quickstart-topic message from go swagger SDK <nil>} { 162246 2 bridge-quickstart-topic message from go swagger SDK <nil>} { 162247 2 bridge-quickstart-topic message from go swagger SDK <nil>} { 162248 2 bridge-quickstart-topic message from go swagger SDK <nil>} { 162249 2 bridge-quickstart-topic message from go swagger SDK <nil>} { 162250 2 bridge-quickstart-topic message from go swagger SDK <nil>} { 163669 1 bridge-quickstart-topic message from go swagger SDK <nil>} { 163670 1 bridge-quickstart-topic message from go swagger SDK <nil>} { 163671 1 bridge-quickstart-topic message from go swagger SDK <nil>} { 163672 1 bridge-quickstart-topic message from go swagger SDK <nil>} { 163146 3 bridge-quickstart-topic message from go swagger SDK <nil>} { 163147 3 bridge-quickstart-topic message from go swagger SDK <nil>} { 163148 3 bridge-quickstart-topic message from go swagger SDK <nil>} { 163149 3 bridge-quickstart-topic message from go swagger SDK <nil>} { 163150 3 bridge-quickstart-topic message from go swagger SDK <nil>}]
5. Process finished with the exit code 0

复制代码

编写代码验证功能：提交offset

• 最后是提交offset的功能，这样从消息的发送再到接收的整个流程都实现了api覆盖，增加Offset方法
  

1. // 提交offset
2. func Offset(consumerGroup string, consumerName string) error {
3.         response, err := client.ConsumersApi.Commit(context.Background(),
4.                 consumerGroup,
5.                 consumerName, nil)
7.         if err != nil {
8.                 log.Printf("Poll error : %v", err)
9.                 return err
10.         }
12.         log.Printf("Offset response : %v", response)
13.         return nil
14. }

复制代码

• 调用很简单
  

1. func main() {
2.         err := Offset(TEST_GROUP, CONSUMER_NAME)
3.         if err != nil {
4.                 print(err)
5.         }
6. }

复制代码

• 执行结果如下，返回204，提交成功
  

1. /private/var/folders/5v/p3bj9bzx2nd99y5l21nb1c080000gn/T/GoLand/___go_build_sdkdemo
2. 2022/12/18 22:07:38 Offset response : &{204 No Content 204 HTTP/1.1 1 1 map[] {} 0 [] false false map[] 0x1400011a100 <nil>}
4. Process finished with the exit code 0

复制代码

java的问题

• 从go版本的修改程度可以发现，基于openapiv2.json生成的sdk代码真的很难用，在go环境尚且如此，换成java环境就更难改了，虽然我也尝试过将其改好，但是面对很多jar的时候还是无能为力，下图是一个很难处理的地方，ApiClient并不支持application/vnd.kafka.v2+json和application/vnd.kafka.json.v2+json，contentType改不成正常的，bridge后台就会返回错误，所以最终我只能骂骂咧咧的放弃了
  
  

有收获吗？

• 面对这么烂的SDK源码，一般人都不会在生产环境使用，但是个人觉得也不是一无是处，这里小结一下收获
  

• 了解了go版本swagger sdk源码的基本结构，和请求响应逻辑
  
• 知道了大众工具也有出问题的时候
  
• strimzi到底测试过吗，这个做CICD自动化应该可以做到吧，能进CNCF的项目，也是会出问题的...
  

欢迎关注博客园：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴...

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4