Re: Problems with Kafka Connector Base classes

ngliche Nachricht- > Von: Chris Egerton > Gesendet: Donnerstag, 2. März 2023 17:33 > An: dev@kafka.apache.org > Betreff: Re: Problems with Kafka Connector Base classes > > [You don't often get email from chr...@aiven.io.invalid. Learn why this > is important at https://a

AW: Problems with Kafka Connector Base classes

G_FOR_TASK_CONFIG" - that would be awesome 😉 Thanks Michael -Ursprüngliche Nachricht- Von: Chris Egerton Gesendet: Donnerstag, 2. März 2023 17:33 An: dev@kafka.apache.org Betreff: Re: Problems with Kafka Connector Base classes [You don't often get email from chr...@aiven.io

Re: Problems with Kafka Connector Base classes

Hi Michael, The purpose of the Connector::taskConfigs method is to specify (implicitly) the number of tasks that need to be run for the connector, and (explicitly) how each task should be configured. The former is provided implicitly by the size of the list returned from that method; for each elem

Problems with Kafka Connector Base classes

Hi I'm using: org.apache.kafka:connect-api:3.4.0 I have a simple connector: == public class SimpleSinkConnector extends SinkConnector { @Override public List> taskConfigs(int maxTasks) { ArrayList> configs = new ArrayList<>(); for (int i = 0; i < maxTasks; i++) {