Re: kafka connect 409 with connect-distributed

ur? Thank you very much Best, Javier arias El jue., 8 ago. 2019 a las 14:47, Javier Arias Losada (< javier.ari...@gmail.com>) escribió: > Hello there, > we were suffering some problems on our connect-distributed setup, when > posting a new Connector config, the response was always

kafka connect 409 with connect-distributed

Hello there, we were suffering some problems on our connect-distributed setup, when posting a new Connector config, the response was always a 409 Conflict mentioning a rebalance as the underlying reason. It was fixed after setting up a different CONNECT_REST_ADVERTISED_HOST_NAME on each worker, ess

kafka-streams disconnection errors

able to manage the kafka-connection management internals and being disconnected... but can someone explain the reason why? Thank you! Best, Javier arias losada

Re: KafkaConnect not consuming from SSL/SASL cluster

r." prefixed on each of the > configuration items: > consumer.security.protocol=SASL_SSL > consumer.ssl.protocol=TLSv1.2 > consumer.sasl.mechanism=PLAIN > consumer.sasl.jaas.config=.. > > Hope this helps. > > Andrew Schofield > > From: Javier Arias Losada > Reply-To: &qu

KafkaConnect not consuming from SSL/SASL cluster

Hello there, we are trying to use KafkaConnect, but it isn't consuming any messages after changing to a SSL and authenticated Kafka cluster. With a cluster without SSL or authentication it's working perfectly fine with the same configuration except for the sasl/ssl settings. I think probably is

Re: Kafka streams application unaware of connection to broker lost

> It's a known issue: https://issues.apache.org/jira/browse/KAFKA-6520 > > > > > > On 2/20/19 3:25 AM, Javier Arias Losada wrote: > > > Hello Kafka users, > > > > > > working on a Kafka-Streams stateless application; we want to implement > &

Kafka streams application unaware of connection to broker lost

Hello Kafka users, working on a Kafka-Streams stateless application; we want to implement some healthchecks so that whenever connection to Kafka is lost for more than a threshold, marke the instance as unhealthy, so that our cluster manager (could be K8S or AWS-ECS) kills that instance and starts

Re: Lag checking from producer

Hi, could you please be more specific on your use case? One of the theoretical advantages of a system like kafka is that you can decouple producers and consumers, so you don't need to to do backpressure. A different topic is how to handle lagging consumers, in that scenario you could scale up your

long time between consumer gracefully stopping and rebalance

rebalance being triggered? what are the tradeoffs? more unneeded rebalances? For more context, our Kafka version is 1.1.0, after looking at libs found for example kafka/kafka_2.11-1.1.0-cp1.jar, we installed Confluent platform 4.1.0. On the consumer side, we are using Kafka-streams 2.1.0. Thank you very much. Javier Arias Losada.

rebalancing latency spikes on high throughput kafka-streams services

de, we are using Kafka-streams 2.1.0. Thank you for reading my question and your responses. Best, Javier Arias Losada

Subscribe me, please