apache-kafka

6зной

2ответ

Как реализовать микросервисную архитектуру Event Driven с Spring Cloud Stream Kafka и Database for service

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

apache-kafka spring-cloud microservices spring-cloud-stream spring-kafka 2017-02-09

---

0зной

1ответ

Кафка Спарк поток бросает исключение: Нет текущее назначение для раздела

Ниже не мой Scala код для создания искры Кафка поток: val kafkaParams = Map[String, Object]( "bootstrap.servers" -> "server110:2181,server110:9092", "zookeeper" -> "server110:2181", "key.deserialize

apache-kafka spark-streaming rdd 2017-02-10

---

2зной

1ответ

Kafka Avro Сериализатор: org.apache.avro.AvroRuntimeException: не открыт

Я использую Apache Kafka с Avro Serializer, используя определенный формат. Я пытаюсь создать свой собственный пользовательский класс и использовать его как значение сообщения kafka. Но когда я пытаюсь

java scala apache-kafka avro kafka-producer-api 2017-02-10

---

0зной

2ответ

как изменить сообщение одной темы kafka и отправить другую тему кафки с помощью java?

Я создал производителя, который производит MSG для одной темы. А мне нужно, чтобы я делал изменения в этой MSG и хочу отправить ее в другую тему B, я пытаюсь сделать это потоками Kafka, но не уверен,

java apache-kafka apache-kafka-streams 2017-02-10

---