Я реализовал связанный список как таблицу базы данных самоссылки: CREATE TABLE LinkedList (Идентификатор bigint NOT NULL, ПУСТОЙ УКАЗАТЕЛЬ ParentId bigint, SomeData nvarchar (50) NOT NULL), где идентификатор...
Я пытаюсь создать верблюжий маршрут с компонентом kafka, пытаясь использовать события с io.confluent.kafka.serializers.KafkaAvroDeserializer и schemaRegistry url вместе с другими параметрами компонента. ...
Я пытался развернуть Kafka с реестром схемы локально, используя Kubernetes. Тем не менее, журналы модуля реестра схемы показывают это сообщение об ошибке: ОШИБКА Сервер неожиданно умер:
Я определил конфигурацию реестра схем Kafka и Kafka с использованием развертываний и сервисов Kubernetes. Я использовал эту ссылку в качестве ссылки для настройки переменных среды. Тем не менее, когда я пытаюсь бежать ...
У меня есть соединитель приемника со следующей конфигурацией {"name": "sink-test-mariadb-MY_TOPIC", "config": {"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", ...
Я написал некоторые avro-данные в тему «test-avro», используя Kafka-avro-console-продюсер Затем я записал некоторые текстовые данные в ту же тему «test-avro», используя Kafka-console -roduction. После ...