java kafka-client use "props.put("retries", "5")" ,why print 2 log ?

2020-04-04 Thread ????????
public class ProduceMessage { public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "192.168.1.113:9091");  / wrong ip address. props.put("acks

i how do use java kafka-client can test acks 0 and 1 and all between difference???

2020-04-04 Thread ????????
i how do use java kafka-client can test acks 0 and 1 and all between difference???

Re: Get after put in stateStore returns null

2020-04-04 Thread Jan Bols
Ok, Matthias, thanks for the clarification. This makes sense to me. Glad I learned something new about kafka-streams. Even if it was the hard way ;-) Greetings Jan On Wed, Apr 1, 2020 at 11:52 PM Matthias J. Sax wrote: > That is expected behavior. > > And yes, there is a `Transformer` instance

Re: Kafka Quota help

2020-04-04 Thread Alex Woolford
Hey Ravi, There's a KIP to add quota management to the admin API: KIP-546 My best guess (based on searching through Slack, Google, etc...) is that this will be part of Apache Kafka