Всем Привет, Я работаю над приложением контейнеризации, где интерфейсное приложение вызывает HTTP-запрос к шлюзу API. Запрос на данные, полученные в шлюз API является вперед к микро сервис через Кафку. Но я должен отправить ответ обратно результат как ответ обратно в API gateway и обратно в...
я через Енисей.Кафка потребляет данные, а мой код-как(c#):public static class Confluent { public static void Consume() { var conf = new ConsumerConfig { GroupId = Guid.NewGuid().ToString(), BootstrapServers = "pdkafka.test.com:9092",//"localho...
Я пытаюсь запустить образец кода Kafka в среде unity и по этой причине создал потребительский клиент (код приведен ниже).<pre>using System.Collections; using System.Collections.Generic; using UnityEngine; using Confluent.Kafka; using Confluent.Kafka.Serialization; using System.Text; ...
Я пытаюсь написать java-программу в Редакторе Eclipse. По этой причине я хочу Добавить стороннюю библиотеку kfka. Я добавляю эту строку в верхней части программыimport kafka.javaapi.producer.Producer; но это дает мне ошибку. "Импорт Кафки не может быть разрешен".. Я новичок в java и eclip...
I have install kafka on my centOS 6.5, Java 1.7.0.67 Zookeeper: 3.4.10 bin/kafka-server-start.sh config/server.properties Exception in thread "main" java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 52.0 at java.lang.ClassLoader.defineClass1(Native Meth...
Я пытаюсь запустить образец кода Kafka в среде unity и по этой причине создал потребительский клиент (код приведен ниже).<pre>using System.Collections; using System.Collections.Generic; using UnityEngine; using Confluent.Kafka; using Confluent.Kafka.Serialization; using System.Text; ...
Я пытаюсь написать java-программу в Редакторе Eclipse. По этой причине я хочу Добавить стороннюю библиотеку kfka. Я добавляю эту строку в верхней части программыimport kafka.javaapi.producer.Producer; но это дает мне ошибку. "Импорт Кафки не может быть разрешен".. Я новичок в java и eclip...
I have install kafka on my centOS 6.5, Java 1.7.0.67 Zookeeper: 3.4.10 bin/kafka-server-start.sh config/server.properties Exception in thread "main" java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 52.0 at java.lang.ClassLoader.defineClass1(Native Meth...