Я пытаюсь загрузить данные в Kafka, используя logstash, так называемым образом.Для этого необходимо правильно настроить несколько конфигов в соответствии с this , включая enable.idempotence
, transaction.timeout.ms
и transactional.id
.Однако эти конфиги недоступны в logstash .Итак, я хочу знать, поддерживается ли он или нет.