Re: Achiving at least once Delivery on top of Kafka

2019-09-30 Thread Isuru Boyagane
Hi, This is not the complete requirements set we need. Sorry for any inconvenience occurred. Thank you. Regards. On Sun, 29 Sep 2019 at 18:25, Isuru Boyagane wrote: > Hi, > > We are implementing a use case that needs tight at least once delivery. > Even in the case of failures of nodes, no mes

Is restart necessary when adding users in SASL/PLAIN ?

2019-09-30 Thread 张祥
Hi everyone ! Our Kafka (Ambari distribution) is under SASL/PLAIN authentication mechanism. I am adding new users and it seems a restart is required to enable the new users. So I want to know whether brokers must restart in this situation. If yes, is there a workaround to avoid this, otherwise

Re: One Partition missing a node in ISR

2019-09-30 Thread Sebastian Schmitz
I deleted the topic now and with topic-auto-create enabled it was immediately recreated and all is in sync again. Will keep and eye on this to see if it happens again On 30-Sep-19 3:12 PM, Sebastian Schmitz wrote: Hello again, after like 15 minutes I have now this result: root@kafka_nod

Re: Kafka Streams can't run normally after restart/redeployment

2019-09-30 Thread Alex Brekken
You could try increasing retries and see if that helps as well as adjusting the producer batch size to a lower value. (I think the retries default is Integer.MAX when you're on kafka streams version 2.1 or higher so you can definitely increase it beyond 5). Additionally you could look at the " de