Я пытаюсь получить доступ к экземпляру концентратора сообщений с помощью API-интерфейса kafka rest. когда я отправляю почтовый запрос через Postman Client и указываю Content-Type как application/vnd.kafka.json.v1+json , он дает мне следующий ответ...

Я пытаюсь подключиться к IBM Message Hub из Apache Spark 2.2.1 Structured Streaming. Код подключения довольно простой: import org.apache.spark.sql.functions._ import org.apache.spark.sql.SparkSession val spark =...

Я пытаюсь создать приложения производителя и потребителя, используя концентратор сообщений IBM. Для производителя я использую следующий код: var config = new Dictionary<string, object> { { "bootstrap.servers", brokerList },...

Я создаю приложение с помощью Node.js, и меня интересует клиент или библиотека концентратора сообщений. Существует ли официальный клиент Node.js для Message Hub?

Мы пытаемся реализовать Kafka в качестве нашего решения для брокера сообщений. Мы развертываем наши микросервисы Spring Boot в IBM BLuemix, внутренняя реализация брокера сообщений которого - Kafka версии 0.10. Поскольку мой опыт больше связан с JMS,...

На странице «Начало работы с концентратором сообщений (БЕТА)» на сайте bluemix.net указано, что для производителя Java «... сообщение должно быть в следующей форме: [{ "значение" : строка }, ...]". Я не могу найти ссылку в документации Kafka на...

Ранее поднимался вопрос, можем ли мы использовать Python для доступа к Message Hub. Как правило, ответ был отрицательным, пока реализация SASL не была написана на Python. Теперь есть чистый Python SASL под названием pure-sasl !, теперь можно...

Я следовал этому руководству, чтобы использовать службу потоковой аналитики в Bluemix для взаимодействия с концентратором сообщений:...

Я пытаюсь подключиться к концентратору сообщений IBM Bluemix и создать сообщение с использованием java, следуя примеру https://github.com/ibm-messaging/message-hub-samples/tree/master/java/message-hub-kafka-ssl producer.properties...

Я новичок в разработке коннекторов LoopBack. может ли кто-нибудь помочь мне с входящей поддержкой, исходящей поддержкой и API опроса.

Когда я пытаюсь использовать Bluemix Message Hub с Python, я продолжаю получать сообщения об ошибках и сбоях. Любые идеи, почему, учитывая ниже? Ошибки: «Не удалось инициализировать аутентификацию SASL: рукопожатие SASL не поддерживается брокером...

Это фрагмент кода того, что я запускаю: err := godotenv.Load() if err != nil { log.Fatal("Error loading .env file") } broker := os.Getenv("BROKER") topic := os.Getenv("TOPIC") username := os.Getenv("USERNAME") password :=...

У меня есть ветка, которая время от времени будет перечислять темы в Message Hub. Но время от времени я получаю сообщение: Не удалось отправить сообщение SSL Close. Любые идеи? KafkaConsumer<String, String> consumer = new...

Я безуспешно пытаюсь подключить свой MirroMaker Kafka 0.9 к Kafka Brokers 0.10 (IBM Message Hub). Ссылки, по которым я перешел, следующие, но в основном они предназначены для клиентов Kafka 0.10:...

Клиент kafka-python поддерживает Kafka 0.9, но явно не включает новые функции аутентификации и шифрования, поэтому я предполагаю, что он работает только с открытыми серверами (как и в предыдущих выпусках). В любом случае, даже Java-клиенту для...