apache-kafka

0зной

1ответ

Вопросы преобразования Avro Kafka между scala и Python

Наш проект имеет как scala, так и код python, и нам нужно отправлять/потреблять avro-кодированные сообщения в kafka. Я отправляю avro кодирует сообщения в kafka, используя python и scala. У меня есть

python scala apache-kafka spark-avro 2017-02-11

---

0зной

1ответ

Как CONVER полезных данных MQTT к Кафке строкового типа

Теперь я пытаюсь соединиться от MQTT сообщений Кафок (на самом деле искра потокового в Кафке) Я использовал этот Коннектер https://github.com/evokly/kafka-connect-mqtt И Спарк-2.1. 0, Кафка - 0.10.1.1

apache-kafka mqtt apache-kafka-connect 2017-02-11

---

1зной

2ответ

Apache Kafka Avro Deserialization: невозможно десериализовать или декодировать сообщение определенного типа.

Я пытаюсь использовать Avro Serialize с Apache kafka для сериализации/десериализации сообщений. Я создаю один продюсер, который используется для сериализации сообщения определенного типа и отправки ег

java scala apache-kafka avro kafka-consumer-api 2017-02-11

---

1зной

1ответ

не может потреблять сообщение kafka через искровой поток

Я пытаюсь поглотить сообщение от производителя кафки через программу искрообразования. Вот моя программа val Array(zkQuorum, group, topics, numThreads) = args val sparkConf = new SparkConf().set

apache-spark apache-kafka spark-streaming kafka-consumer-api 2017-02-11

---

0зной

1ответ

Spring Cloud Stream Kafka - EmbeddedHeadersMessageConverter - java.lang.StringIndexOutOfBoundsException: индекс строки из диапазона в

У меня есть приложение Spring Boot (app0), которое использует Spring Cloud Stream Kafka для чтения из темы. Есть два других приложений (app1, app2), которые производят сообщения в эту тему. app1 публи

apache-kafka spring-cloud spring-cloud-stream spring-kafka 2017-02-11

---

1зной

1ответ

Apache Kafka: KafkaProducerActor выбрасывает время ожидания ASK.

Я использую раствор торта Akka client for scala and Kafka. Пока я создаю актер KafkaProducerActor и пытаюсь отправить сообщение с использованием шаблона ask и вернуться в будущее и выполнить некоторые

scala akka apache-kafka kafka-producer-api 2017-02-12

---

2зной

1ответ

Получение недопустимого начального символа: в разборке схемы

Я использую Avro 1.8.1 и пытаюсь проанализировать следующую схему_2. Не могли бы вы помочь? val schema: Schema = new Schema.Parser().parse(StrSchema) I am getting following exception. Exception in

apache-kafka avro 2017-02-13

---