Результаты поиска по запросу "apache-kafka"
Спасибо за информацию! Прямо сейчас, поскольку я также могу определять тематические разделы, я могу быть осторожным и смотреть в будущее с точки зрения емкости. но да, я буду помнить об этом инструменте на случай, если он понадобится мне в будущем.
исал одного потребителя Kafka (используя Spring Kafka), который читает из одной темы и является частью группы потребителей. Как только сообщение будет использовано, оно выполнит все последующие операции и перейдет к следующему смещению сообщения. ...
(с параметрами). Я пытаюсь сделать несколько тестов для этого ..
аюсь представить метод Java с помощью Scala (более подробную информацию о первоначальном методе Java - он исходит ...
Спасибо, @robin за ответ на этот вопрос. Это было блокирующим для нас. Я ценю ваше время и усилия, чтобы предоставить решение. Решение работает. Еще раз спасибо :)
: Запустите производителя для создания образца данных ./bin/kafka-avro-console-producer \ --broker-list localhost:9092 --topic stream-test-topic \ --property schema.registry.url=http://localhost:8081 ...
Изменения, как показано ниже:
lastic Search Connector выбрасывается следующее исключение: [2018-05-07 11:40:38,975] ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaught and unrecoverable ...
лидер выборов происходит? Как только брокер выходит из строя, наступает периодический период, когда ни один брокер не является лидером и выборы могут быть на месте. Что происходит, чтобы производить / потреблять запросы в этот период?
рал про Кафку. Но не знаю, как добиться нулевого времени простоя и нулевых потерь.
Если вы не осколите состояние, основываясь на том же ключе, что и входные темы, вы потеряете локальность / совместное разбиение данных, и, таким образом, ваше приложение будет вычислять неверные результаты.
арственные магазины в Kafka Streams создаются внутри страны. Государственные хранилища разделены по ключам, но не позволяют обеспечить разделение, кромепо ключу (насколько мне известно). ВОПРОСОВ Какконтролировать количество разделов в ...
Могу ли я узнать, каковы значения default.replication.factor и offsets.topic.replication.factor в ваших файлах server.properties? Речь идет не о вашей собственной теме, а о внутренней теме с именем __consumer_offset, созданной Kafka для управления смещениями фиксации.
понимаю, один из брокеров выбран в качестве координатора группы, который занимается перебалансировкой потребителей. Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_groupУ меня 3 узла с коэффициентом репликации 3 и 3 ...
Ошибка жалуется на отсутствие URL - добавление протокола делает путь URL (говоря очень по существу)
аюсь настроить приложение Spring Boot с клиентом Kafka для использования SSL. Мои файлы keystore.jks и truststore.jks хранятся в файловой системе (в контейнере Docker) из-за ...
Извините - не уверен, куда это поставить - я не парень из потоков; Я просто взломал ваши материалы, чтобы исключить встроенного брокера (так как это в вашем названии вопроса). Рад попробовать для вас, если вы можете быть более откровенным с тем, что вы хотите, чтобы я сделал. Но это будет завтра; поздно.
хожу в поисках знания тайного. Во-первых, у меня есть две пары тем, по одной теме в каждой паре, которая входит в другую тему. Два KTables формируются последними темами, которые используются в KTable + KTable leftJoin. Проблема в том, что ...
Основываясь на моем анализе: несколько объединений в одном операторе в настоящее время не поддерживаются. Вы можете сделать то же самое, написав несколько операторов KSQL: CREATE STREAM промежуточный AS SELECT * FROM ammas cd LEFT JOIN appat ab ON ab.id = cd.id SELECT * FROM промежуточный cd LEFT JOIN annat aa ON aa.id = cd.id
: describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Для получения статистики времени выполнения и деталей запроса ...