Я новичок в Kafka Java API и работаю над тем, чтобы использовать записи из определенной темы Kafka....

Возникает проблема при запуске сервера Kafka на моем локальном компьютере (Windows 10) с помощью...

Я использую kafka-clients версии 2.0.0. У меня 3 потребителя kafka в одной группе потребителей с...

У меня есть программа с несколькими потоками, которые обращаются к общему ресурсу.Чтобы избежать...

Есть ли способ получить данные о происхождении для Kafka заданий. Как, например, у нас есть URL...

У меня проблема, подобная этой: Kafka Deserialize Nested Generic Types В моем производителе кафки я...

Давайте представим, что у меня есть Служба автомобиля и Служба бронирования (с использованием...

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

Я использую Google Cloud Platform.Мне нужно отправить сообщения из другого источника в тему, но это...

Я пытаюсь запустить производителя kafka с помощью API kafka-clients.У меня есть несколько...

Я использую FlinkKafka для применения правил в потоке.Ниже приведен пример кода: ObjectMapper...

Есть ли способ реализовать чистый клиент js kafka (производитель или потребитель) в веб-браузере？...

Я использую язык Lua в своем коде.Я хотел бы отправить сообщение на Кафку, используя язык Lua.Любой...

Я пытаюсь установить поток данных, при котором издатель москитов будет отправлять данные брокеру...

Ниже приведена часть моего файла YML для zookeeper и Kafka Dockers Я добавил переменную...

Я использую плагин kafka-connect -asticsearch для получения сообщения от моей kafka на...

В Java-приложении, интенсивно использующем память, наличие нескольких экземпляров KafkaProducer,...

Я хотел бы преобразовать строковый массив / список в util.Collection [String] объект в Scala.Я...

Я строю производителя Apache kafka, который потребляется потребителем flink Kafka.Мне нужно...

Я пытаюсь защитить Kafka на SASL_PLAINTEXT.Я успешно сделал это, перейдя по этой ссылке , я также...

Я занимаюсь разработкой Kafka Hbase Sink Connector.Я могу установить связь с Hbase.Но при попытке...

Таким образом, в папке конфигурации для сервера Kafka есть файл (ы), например "server.properties"....

Пытаюсь включить опцию 'idempotent' на kafka-console -roduction.Ссылка на следующие ссылки:...

Я довольно новичок в Kafka и использую API-интерфейс Confluent Kafka Python.Я планирую создавать...

Я пытаюсь использовать производителя Idempotent в кластере с поддержкой Kerberos.Можно производить...