Я пытаюсь добавить конфигурацию производителя в свой проект, используя Spring Integration и Kafka...

Kafka поддерживает концепцию перехватчиков, которые находятся между Kafka и процессом, который...

Для нашей новой SOA мы рассматриваем Kafka как брокера сообщений. Я хочу спросить, каковы наши...

Я настроил ловушку кустов для атласа в hive-site.xml следующим образом: atlas.hook.hive.synchronous...

Сценарий: Я записываю данные объекта JSON данных в тему kafka во время чтения. Я хочу прочитать...

У меня есть группа потребителей logstash kafka, подписавшаяся почти на 20 тем, что неэффективно для...

Я получаю это исключение org.apache.kafka.common.protocol.types.SchemaException , пока кафка...

Я наткнулся на эту ссылку для заголовков кафки.Как обсуждается в приведенной ниже ссылке заголовок...

Я искал поддержку соединителя kafka-connect-hdfs (Confluent) для сохранения массива байтов и...

Мне нужна помощь по теме kafka, которую я хотел бы поместить в HDFS в формате паркет (с ежедневным...

когда система находится в режиме ожидания и включено автоматическое смещение фиксации, время от...

У нас есть кластер из 5 брокеров, и мы настроили server.properties, как показано ниже listeners =...

У нас ниже настройки Kafka Partition - 10 Replication - 3 fetch.max.byte at broker - 32MB Producer...

У меня есть обработчик чат-бота, который просто опубликует событие в очереди.Я хочу, чтобы...

рабочая среда : пружинный ботинок 2, data jpa, kafka, spock, gradle. Вопрос: Мне действительно...

Я пытаюсь использовать Kafka-Python для очень простого способа потоковой передачи некоторых данных,...

Я пытаюсь использовать два различных типа полезных нагрузок из темы Kafka, используя spring-kafka-2

Что произойдет, если потребитель начнет читать тему, а затем интернет-соединение прервется до того,...

Я использую flink для построения конвейера, источником которого является kafka.Для тестирования я...

Я создаю пользовательский коннектор kafka для чтения файлов каталога и помещаю записи в тему kafka

Или хотя бы один из них?Я не понимаю, когда использую kafka-topics.sh --list или --describe,...

Мне нужно отметить сообщение, указанное ключом для удаления, но единственный известный мне скрипт...

Предусмотрен ли такой заполнитель для этого или название темы является единственным атрибутом,...

1. Информация о моей версии jdk-8u191-linux-x64.tar.gz kibana-6.5.0-linux-x86_64.tar.gz...

Я работаю на платформе Windows, инструменте, в котором я очень часто буду генерировать сообщения...