YYChildren

kcp->buffer 的size为什么是 (kcp->mtu + IKCP_OVERHEAD) * 3 ?

2

对比下代码，应该1倍就够了，3倍应该是浪费 ```c kcp->buffer = (char*)ikcp_malloc((kcp->mtu + IKCP_OVERHEAD) * 3); if (kcp->buffer == NULL) { ikcp_free(kcp); return NULL; } -------------- if (size + (int)IKCP_OVERHEAD > (int)kcp->mtu) { ikcp_output(kcp, buffer, size); ptr...

tint:type dict/0 is deprecated and will be removed in OTP 18.0; use use dict:dict/0 or preferably dict:dict/2 -spec as_dict(Result) -> Dict when Result :: #result_packet{}, Dict :: dict(). modified as...

## 你确定我们的[常见问题](https://goproxy.cn/faq)页面中没有你想要询问的问题吗？ ## 当你执行 `go version` 命令后的输出结果是什么？ $ go version go version go1.20.14 linux/amd64 ## 当你执行 `go env` 命令后的输出结果是什么？ go env 的输出结果 $ go env GO111MODULE="on" GOARCH="amd64" GOBIN="" GOCACHE="/root/.cache/go-build" GOENV="/root/.config/go/env"...

Seatunel 使用kafka source(canal_json) 如何实现 自动schema 映射？

11

## 需求描述 1. Seatunel 使用kafka source，格式为 canal_json。每一条消息都带有对应的database 、table 和 sqlType，sqlType 记录了所有的列定义，所以其实 canal_json 自身就已经有完整的 schema 定义。 2. 我的某个topic里会有不同的表，每个表的字段定义都不一样，用一个schema 定义我这个topic 的所有表，显然不合适。 3. 如果我想达到我的目的，应该怎样实现？ ## 参考文档 1. [Schema 特性简介 ](https://seatunnel.apache.org/zh-CN/docs/2.3.11/concept/schema-feature) 2. [Canal 格式](https://seatunnel.apache.org/zh-CN/docs/2.3.11/connector-v2/formats/canal-json)

Bug: When appRebalanceEnable == true and rebalanceCb == nil and channel == nil, it shound return ev

1

When `appRebalanceEnable == true and rebalanceCb == nil and channel == nil`, we want handle the event by `poll` , so the rebalance event should return by `poll` but not...

fix: When appRebalanceEnable == true and rebalanceCb == nil and channel== nil, it shound return ev issue: https://github.com/confluentinc/confluent-kafka-go/issues/1457