Я запускаю Kafka на GCP и отправляю сообщение в тему из Spring Boot App.В окне потребителя GCP...
Я создаю приложение Java Spring с использованием Storm 1.1.2 и Kafka 0.11 для запуска в контейнере...
Я запускаю Кафку и зоопарка в докере. CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES...
Я использую сливной коннектор hdfs-приемника, я вставляю данные в формате avro. Я хочу сжать данные...
Я хочу создать некоторые общие данные в теме kafka, используя apache nifi, и я хочу, чтобы эти...
Я вижу ниже ошибку в логах сервера kafka при работе с RD Kafka Client.Но когда я вижу мое дисковое...
У меня есть конкретный класс, который я сериализирую в байтовом массиве для отправки в тему Кафки
У меня есть 10 миллионов документов в базе данных Mongo, которые я хотел бы отправить в Kafka в...
Мы создаем систему для перемещения данных из одной точки в другую в нашей экосистеме с...
Этот вопрос относится к Кафке для S3. Требование: Одна из интересующих нас тем Кафки содержит...
У меня есть вопрос об обработке ошибок в Logstash.В моем случае у меня есть следующий кластер:...
Наш брокер получает большое количество сообщений (около 15-30 МБ / с), и мы хотели бы принять эти...
Я знаю, что мы можем получить список групп потребителей и затем передать любую из групп...
В документации Kafka четко указано, что сообщения / записи немедленно записываются в файловую...
В моей схеме Avro у меня есть поле с именем myenum типа enum: { "name":...
У меня запущен экземпляр Kafka (локально, в Docker), и я создал продюсер в Go, используя пакет...
У меня вопрос: при каких условиях потребитель кафки получит непоследовательные данные?
Можно ли добиться этого в балерине Для создания новой темы кафки в балерине Для просмотра списка...
Я пытаюсь запустить Apache Samza 0.14.0 с включенным P plain SASL (not GSSAPI) Kafka 0.10.1.1. Мне...
У меня есть поток данных, поступающий из разъема mongo CDC, но проблема в том, что ключ потока...
Возникла проблема с отставанием потребителя кафки.Теперь мы перезапускаем потребителя кафки, чтобы...
Я пытаюсь подключить потоки kafka на одном из типов аутентификации хост-провайдеров kafka, это...
У нас есть приложение Hyperledger.Основное приложение размещено на виртуальных машинах AWS, а DR -...
Я тестирую соединитель JDBC Sink для вывода записей из Kafka в PostgreSQL.Вот конфигурация...
Под ubuntu desktop 16.04 я установил confluent с открытым исходным кодом, используя apt. Я запускаю...