kcl
kcl copied to clipboard
Your one stop shop to do anything with Kafka. Producing, consuming, transacting, administrating; 0.8.0 through 3.2+
Command: ``` /kcl --config-path config.toml admin user-scram alter --set user=user1,mechanism=scram-sha-512,iterations=8192,password=123456 ``` Error: ``` org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512 ```
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...
Fixes a panic when consuming protobuf formatted messages
Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.11.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.53.0 to 1.56.3. Release notes Sourced from google.golang.org/grpc's releases. Release 1.56.3 Security server: prohibit more than MaxConcurrentStreams handlers from running at once (CVE-2023-44487) In addition to this...
Currently, we can issue an AlterPartitionReassignments request with something like ```bash kcl admin partas alter 'foo:0->0,1;1->2,3;2->1,3' ``` The docs mention the ability to cancel a request ```bash If a replica...