kt

kt copied to clipboard

I might be missing something but do I really need to specify both `-topic` and `-group` in order to get reasonable results? I.e. ``` kt group -topic prod_m3_13_4.service_assignment.updates -group prod_fieldops_13_4_work_order_tx...

sdahlbac

produce messages partitioned by value

2

I want this feature because in my case, I just want every each partition of a topic could have messages without setting partition key for every message.

LucasDove

Add a default kafka version via env variables. Issue #120

zitudu

when using createTopic, is there a way to update the topic configs if the topic already exists?

ftardif

New Auth Mechanism SASL_SSL SCRAM-SHA-256

2

Hi, Is it possible to support a new auth mechanism security.protocol=SASL_SSL sasl.mechanism=SCRAM-SHA-256 ssl.endpoint.identification.algorithm= This uses, ssl.truststore.location= ssl.truststore.password= sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="" password="";

vijeyanidhi

I think it would be useful to return a non-zero exit code in case kt encountered a warning while reading data from topics either by default or only when enabled...

mibollma

KT built for Win10/11 is possibly leaking memory

3

Hi guys! **Summary**: I'm using KT extensively on macos/linux/windows and it works great for linux and mac. The issue is that the windows kt.exe build is leaking memory. **How to...

gfeyer

set security.protocol to SASL_SSL???

1

How do I set security.protocol to SASL_SSL for kt client?

36roentgen

I'd like to execute `kt admin -createtopic ...` and have it not fail if the topic already exists. This is handy in cases where `kt` is used for starting up...

torkelrogstad

add basic sasl_ssl support:

1

* add security_protocol to authConfig. a single value, SASL_SSL, is supported for now. this allows one to enable TLS support * add sasl_mechanism to authConfig. currently we check for PLAIN...

naude-r