Travis Bischel
Travis Bischel
Currently, length 0 messages are rejected in `doPUB` for the http protocol and `PUB` in protocol_v2. nsqd's diskQueue reads/writes enforce only the message header size (not requiring body). Also, the...
`echo "package main; func (v *OffsetForLeaderEpochResponse) Throttle() (int32, bool) { return v.ThrottleMillis, v.Version >= 0 }; func (v *OffsetForLeaderEpochResponse) RequestKind() Request { return &OffsetForLeaderEpochRequest{Version: v.Version} }" | gofumpt ` output:...
kcl should support using the Kafka schema registry to pretty-print consumed records.
If some partitions cannot be requested due to metadata load failures, we currently print a log saying some things failed, and then continue on with what was successful. Instead, we...
https://github.com/apache/kafka/pull/10814 We currently abort transactions by inspecting `__transaction_state`. We can use new Kafka APIs to provide a faster way of aborting txns.
kcl can support consuming from specific timestamps. The syntax for this should be `s@` and `e@` (where `` refers to a unix microsecond timestamp), and this can be pieced into...
Similar to kafkacat, we can take all messages produced during an invocation of `kcl produce` and bundle them into a transaction. As an added bonus, we can have an optional...
`my/non/ex/is/tent/path/../../../../../../` should not be equivalent to `/`
When using a very large interpolated statement, interpolateParams returns db.ErrSkip when the interpolated statement exceeds maxPacketAllowed. Inside database/sql, if ErrSkip is returned, Exec falls back to the prepare/execute cycle and...
clocksource uses tsc which under the hood uses the amd64 instruction rdtsc. This wont work on ARM. tsc also is not available on Azure. We should look at available clocksources...