Я использую Voltdb. И мой вариант использования - импортировать данные из кафки в voltdb.
Я использую команду ниже:
Команда:
тест kafkaloader --brokers <>: 2181, --topic kafkavoltdb
В файле deploy.xml конфигурация:
<security enabled="false" provider="hash"/>
<import>
<configuration type="kafka" enabled="true" format="csv">
<property name="topics">kafkavoltdb</property>
<property name="procedure">TEST.insert</property>
<property name="brokers">brokers:6667</property>
</configuration>
</import>
Я не могу извлечь данные из kafka в voltdb, и команды kafkaloader работают с ошибками и не выдают никаких ошибок. Журналы, показывающие:
Не удалось получить информацию о разделе Kafka
org.apache.kafka.common.errors.TimeoutException: истекло время ожидания при получении метаданных темы.
Примечание: я использую Apache Kafka (HDP версии 3.0, кластер безопасности Kerberos)
Пожалуйста, помогите мне с решением.