producer Java security.protocol

2024-08-23 Thread Keith Brown
In CLI, in my krb-client.properties files I can do security.protocol=SASL_SSL sasl.mechanism=GSSAPI And I invoke echo "bar" | kafka-console-producer.sh --producer.config krb-client.properties it works great. I have a custom Java client but I am not sure how I can incorporate these settings. How

producer fast fail

2024-08-22 Thread Keith Brown
Sometimes out is unavailable. Our producer gives this error [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Bootstrap broker 127.0.0.1:9091 (id: -1 rack: null) disconnected [main] INFO org.apache.kafka.clients.producer.Kaf

java kafka multithreaded

2024-08-20 Thread Keith Brown
I would like to have a producer and consumer in the same binary. I want to send a message and have the consumer read the message and exit immediately. Is there an example I can follow for something like this?

Re: sending and receiving message

2024-08-20 Thread Keith Brown
t; Read it here for simple CLI consumer, e.g. > https://www.conduktor.io/kafka/kafka-consumer-cli-tutorial/ > > On 20. Aug 2024, at 14:15, Keith Brown wrote: > > I am new to kafka. I started the server and created a topic. > > Using the CLI, is it possible to send AND receive

sending and receiving message

2024-08-20 Thread Keith Brown
I am new to kafka. I started the server and created a topic. Using the CLI, is it possible to send AND receive the message and exit? Or do I need to have a separate process for it?