Я недавно обновился с версии 4.0.1 до версии 5.0.1.Версия bootstrap.server - Kafka 1.0.В моем коннекторе HBaseSink я настроил новую функцию "" errors.deadletterqueue.topic.name "следующим образом:
{" name ":" kafka-hbase4 "," config ": {"соединитель.класс ":" com.xxxx.hbase.sink.HBaseSinkConnector ", ...." zookeeper.quorum ":" xxxx: 2181 "," themes ":" oplog_demo.hbase_test1 "," errors.deadletterqueue.topic.name ":" error-topic-1 "}}
программа обычно работает нормально. Однако, когда я отправляю сообщения об ошибках в тему HBase Sink Connector, как некоторые слова китайцев" 哈哈哈", программа закрывается, выдает исключение SerializationException, и сообщение" error-topic-1 "не использует никаких сообщений.
Означает ли это, что конфигурация" errors.deadletterqueue.topic.name "не работает? Какможет ли это быть и как я могу заставить эту конфигурацию работать?