Я использую семантику ровно один раз, предоставленную kafka. Поэтому мой продюсер пишет сообщение в...
Я пытаюсь создать верблюжий маршрут с компонентом kafka, пытаясь использовать события с io
При масштабировании вверх / вниз потребителей (добавление или удаление потребителей в группу)...
У меня есть потребитель kafka с пружинной загрузкой, который получает данные из темы, сохраняет их...
Ниже мой образец логина из темы кафки 2019-03-04T08:53:03.023Z "cd8cbe" 100.212.212.212 -...
Из приложения Node.js я пытаюсь подключиться к брокерам Apache Kafka (версия 0.11.0.3) с помощью...
У меня есть эта конфигурация: @Configuration public class KafkaTopicConfig { private final...
У меня есть oenwhisk система работает и работает.Я также являюсь брокером RabbitMQ, который...
У меня есть поток событий, который выглядит так: REMOTE_SOURCE ПРОИЗВОДИТЕЛЬ KAFKA ПОТРЕБИТЕЛЬ...
Я получаю данные JSON из темы Кафки.Мне нужно выгрузить эти данные в GCS (Google Cloud Storage) в...
Я получаю эту ошибку при попытке запустить приложение Android после успешного добавления библиотеки...
Вопрос Я пытаюсь запустить один экземпляр Kafka в докере. Я могу создавать темы, но не могу...
Я использую Kafka Connect в Kubernetes (8-16 узлов, автоматическое масштабирование). Я определил...
В настоящее время я сам внедряю реестр схем. Но может быть есть какие-то другие способы для...
Я пытаюсь найти способ копировать данные из SQL Server 2014 и 2017 каждый раз, когда в таблицу...
Весенняя кафка у меня потребительское приложение. Приложение действует как проход, через который...
В одном из моих вариантов использования я пытаюсь создать конвейер всякий раз, когда я отправлял...
Я хочу обработать тему при запуске приложения, используя Confluent dotnet client .Предположим...
Я использую пружинный каркас и кафку с 6 потребительскими нитками.После того, как 2 потока одной...
У меня есть цикл for, создающий kafka DStreams путем перебора списка названий тем. Затем я хочу...
В моем случае я создал соединитель JDBC kafka, извлек данные из таблицы оракулов и успешно отправил...
В сценарии, когда несколько типов событий в одном домене создаются в одной теме, и потребителем...
У меня есть asticsearch kafka-connect соединитель , использующий некоторые темы. Со следующей...
Согласно документации Кафки Конфигурации соединителя представляют собой простые сопоставления...
У меня есть Kafka Consumer: public void consumeKafka(Collection<String> topics) { Properties...