Re: sending and receiving message

2024-08-22 Thread Matthias J. Sax
What do you mean by "timeout a consumer"? Given that a consumer calls `poll()` and `poll()` might also return with no data, the consumer code is in full control anyway... I want to make sure a certain message gets pushed if not then exit. This sounds like writing. How it it related to a co

Re: sending and receiving message

2024-08-20 Thread Keith Brown
Thankyou. Is there a way to timeout a consumer after 60secs? I want to make sure a certain message gets pushed if not then exit. On Tue, Aug 20, 2024 at 8:29 AM Tiansu Yu wrote: > > You need to run on a separate process for producer and consumer (on the same > machine is fine). > > Read it here

Re: sending and receiving message

2024-08-20 Thread Tiansu Yu
You need to run on a separate process for producer and consumer (on the same machine is fine). 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 a