У меня есть сценарий, в котором мы пересылаем журналы наших приложений в раздел Kafka с помощью агентов fluentD, поскольку команда Kafka представила аутентификацию Kerberos и версию fluentD, не поддерживающую эту аутентификацию, я не могу напрямую использовать журналы пересылки.Теперь мы ввели новый сервер Kafka без аутентификации и создали там тему. Я хочу пересылать сообщения из этой темы на новом сервере в другую тему на другом сервере с использованием коннекторов Kafka, хотите узнать, как мне этого добиться?