Вопросы по теме 'apache-kafka'
Конфигурация Spring Integration DSL KafkaProducerContext
Я пытаюсь адаптировать следующий пример: https://github.com/joshlong/spring-and-kafka
с последними стабильными версиями следующих библиотек:
org.apache.kafka > kafka_2.10 > 0.8.2.2
org.springframework.integration >...
11.05.2024
Kafka-Connect: создание нового коннектора в распределенном режиме создает новую группу
В настоящее время я работаю с конфлюентной платформой 3.0.1. Я пытаюсь создать 2 соединителя для двух разных рабочих процессов, но при попытке создать новый соединитель создает для него новую группу.
Two connectors were created using below...
01.06.2024
Установка стратегии разделения в коннекторе Kafka
Я использую специальный коннектор Kafka (написанный на Java с использованием Java API Kafka Connect) для извлечения данных из внешнего источника и сохранения в теме. Мне нужно установить собственную стратегию разделения. Я понимаю, что установка...
12.03.2024
Потребитель Kafka тихо не может подключиться к брокеру
Сегодня у нас возникла проблема, когда потребителю Kakfa не удавалось подключиться к каким-либо брокерам, и в журналах не было сообщения об ошибке. Не удалось подключиться, поскольку он подключался через SSL и указывал на неправильное хранилище...
02.06.2024
Как обрабатывать события Debezium от Kafka с помощью Pyspark?
Я следую этой инструкции https://debezium.io/docs/tutorial-for-0-2/ . Мой CDC хорошо работает для события mysql (создание, обновление, удаление).
Я пытаюсь получить это событие kafka из pyspark, используя python, мой код все еще не может получить...
11.03.2024
Громовержец выполняет больше, чем его родитель
У меня есть топология, которая содержит KafkaSpout и 2 болта.
BoltParseJsonInput и его метод выполнения:
public void execute(Tuple input) {
// TODO Auto-generated method stub
String data = input.getString(4);
js = new...
19.05.2024
Kafka docs Producer возможна потеря сообщения
В настоящее время я узнаю больше о Kafka Producer. Меня немного озадачил следующий абзац из документации:
Сообщения, написанные лидеру раздела, не могут быть немедленно прочитаны потребителями, независимо от настроек подтверждения производителя....
02.05.2024
Новые материалы
Создание кнопочного меню с использованием HTML, CSS и JavaScript
Вы будете создавать кнопочное меню, которое имеет состояние наведения, а также позволяет вам выбирать кнопку при нажатии на нее. Финальный проект можно увидеть в этом Codepen .
Шаг 1..
Внедрите OAuth в свои веб-приложения для повышения безопасности
OAuth — это широко распространенный стандарт авторизации, который позволяет приложениям получать доступ к ресурсам от имени пользователя, не раскрывая его пароль. Это позволяет пользователям..
Классы в JavaScript
class является образцом java Script Object. Конструкция «class» позволяет определять классы на основе прототипов с чистым, красивым синтаксисом. // define class Human
class Human {..
Как свинг-трейдеры могут использовать ИИ для больших выигрышей
По мере того как все больше и больше профессиональных трейдеров и активных розничных трейдеров узнают о возможностях, которые предоставляет искусственный интеллект и машинное обучение для улучшения..
Как построить любой стол
Я разработчик программного обеспечения. Я люблю делать вещи и всегда любил. Для меня программирование всегда было способом создавать вещи, используя только компьютер и мое воображение...
Обзор: Машинное обучение: классификация
Только что закончил третий курс курса 4 часть специализации по машинному обучению . Как и второй курс, он был посвящен низкоуровневой работе алгоритмов машинного обучения. Что касается..
Разработка расширений Qlik Sense с qExt
Использование современных инструментов веб-разработки для разработки крутых расширений
Вы когда-нибудь хотели кнопку для установки переменной в приложении Qlik Sense? Когда-нибудь просили..