настройки производителя kafka-узла

Question

Я не знаю, может быть, я совершенно глуп и больше не могу читать документацию.Но я не знаю, как установить параметры для производителей.

Документация, которую вы можете найти здесь, выглядит следующим образом для производителя: https://www.npmjs.com/package/kafka-node

const options = {
    requireAcks: 1,
    ackTiimeoutMs: 100,
    partitionerType: 2
}
const producer = new HighLevelProducer(client, options);

Мне действительно не разрешено устанавливать другиеварианты для производителя?Потому что количество вариантов, которые я могу найти на https://kafka.apache.org/documentation/, очень велико.Я хотел бы установить параметры, такие как enable.idempotence: true для моего производителя.

Спасибо за помощь

Answer 1

Попробуйте это:

const kafkaConf = {  
  "bootstrap.servers" : "localhost:9092",
  "key.serializer" : "org.apache.kafka.common.serialization.StringSerializer",
  "value.serializer" : "org.apache.kafka.common.serialization.StringSerializer",
  ...
  ...
  "enable.idempotence" : true,
  ...
};

const topic = <topic-name>;
const producer = new Kafka.Producer(kafkaConf);

Примечание : три точки {...} - это просто заполнители, которые позволяют вам добавить еще какие-либо свойства в ваш производитель.Я только что выбрал некоторые из основных.

Надеюсь, это поможет!