Поддерживает ли разъем приемника kafka jdbc запись того, что он потребляет, в другую тему.Я ищу...
Я использую Spring Boot 1.5.6.RELEASE приложение для отправки сообщений на Kafka 0.11 с...
Мой сервер работает на Flask, у которого есть некоторые конечные точки API.Используя эти конечные...
Я бродил по Интернету для некоторых объяснений, и, поскольку я новичок в этом, я могу быть сбит с...
Я запускаю потоковое приложение java kafka с включенным JMX.Я пытаюсь получить потребительские лаги...
Я пытаюсь использовать плагин Kafka Producer во Fluentd (версия 0.7.9), прежде всего я хотел бы...
Что произойдет, когда я разделю данные по ключу, а затем добавлю новый раздел к теме в Kafka? Будут...
По ошибке журналы Кафки были удалены и теперь лидер не доступен.Мы удалили тему и перезапустили...
Согласно документации Kafka структура данных, используемая в Kafka для хранения сообщений,...
Я новичок в Kafka и PyKafka. Я знаю, что производитель и потребитель сделаны в PyKafka с помощью...
Я хотел бы использовать все сообщения, начиная с начала, каждый раз, когда я запускаю потребителя в...
Я пытаюсь опубликовать данные в kafka, читая данные из TeradataDB, используя Kafka-Connect...
Я создал тему с 5 разделами с 3 коэффициентами репликации. У меня запущены два потребительских...
У меня есть такой случай: пользователи собирают заказы как строки заказа.Я реализовал это с темой...
Я не могу перейти на Spring 5, поэтому я застрял с spring-kafka 1.3 и его ограниченной обработкой...
Я пытаюсь программно (Java) получить и установить время хранения некоторого набора тем в кластере...
Я использую Spring Boot 1.5.6.RELEASE для подключения к Kafka 0.11 с использованием аутентификации...
Я пытаюсь подключить свою базу данных SQL Server к kafka на windows, я скачал файлы jar Debezium,...
Мы используем Kafka stream KTable, поэтому я хочу понять, как мы можем контролировать фиксацию...
Я пишу приложение на Python.Он читает тему кафки с помощью потребителя.С каждым сообщением он...
При использовании метода listTopics () из KafkaConsumer для каждой темы в кластере, где у...
У меня есть тема с partitions = 1 и replication factor = 5.Я начал публиковать сообщения на эту...
Я увеличил существующий концентратор событий с уровня Basic до уровня Standard, но не могу найти...
Я пытался увидеть поведение потребителя kafka в случае сбоя обработки сообщения, поэтому я...
Я прошел документацию ConsumeKafka_2_0 .Однако не ясно, как настроить потребителя Kafka с JAAS SASL...