reactive-kafka

0La chaleur

1Répondre

Comment intégrer les flux akka kafka (réactif-kafka) dans l'application akka http?

J'ai une application de base scala akka http CRUD. Voir ci-dessous pour les classes pertinentes. J'aimerais simplement écrire un identifiant d'entité et des données (comme json) dans un sujet Kafka ch

scala apache-kafka akka akka-stream reactive-kafka 2017-09-07

---

0La chaleur

1Répondre

Utilisation d'Akka Streams Kafka Producer en parallèle

Je voudrais paralléliser l'écriture à kafka, c'est-à-dire que plusieurs producteurs envoient des données à kafka, bien que ce soit dans un flux akka. Dans d'autres mon flux aurait plusieurs étapes ini

akka-stream reactive-kafka 2017-09-13

---

0La chaleur

1Répondre

Kafka - modèles pour le traitement des consommateurs incapables de traiter les messages

J'essaie d'implémenter un service simple qui tire les messages de kafka les enveloppe dans certaines données et les envoie au service externe. Quel est le modèle commun pour gérer l'indisponibilité du

scala apache-kafka reactive-kafka 2016-10-01

---

0La chaleur

2Répondre

Trouvé java.util.concurrent.Future requis scala.concurrent.Future

connexes: scala.concurrent.Future wrapper for java.util.concurrent.Future Cela est arrivé de mon autre question: How to integrate akka streams kafka (reactive-kafka) into akka http application? J'ai u

scala apache-kafka akka akka-http reactive-kafka 2017-09-18

---

2La chaleur

1Répondre

Akka Streams Kafka réactif - OutOfMemoryError sous forte charge

Je cours une application Akaf Streams Reactive Kafka qui devrait être fonctionnelle sous forte charge. Après avoir exécuté l'application pendant environ 10 minutes, l'application descend avec un . J'a

scala akka akka-stream reactive-kafka akka-dispatcher 2017-09-27

---

2La chaleur

1Répondre

Réactif-Kafka Stream Consommateur: lettres mortes ont eu lieu

J'essaye de consommer des messages de Kafka en utilisant la bibliothèque kafka réactive d'Akka. Je reçois un message imprimé et après que je suis arrivé [INFO] [01/24/2017 10:36:52.934] [CommittableSo

scala apache-kafka akka-stream reactive-kafka akka-kafka 2017-01-24

---

0La chaleur

1Répondre

équivalent de kafkaConsumer.partitionsFor utilisant kafka réactifs (flux) akka kafka

J'utilise-kafka réactif (flux akka kafka): https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html Quel est l'équivalent du code ci-dessous à l'aide réactive kafka ? import org.apache.kafka.c

scala apache-kafka akka akka-stream reactive-kafka 2017-10-02

---

0La chaleur

1Répondre

connecter le flux du producteur au graphique

Je suis nouveau en utilisant les flux kakka akka (et les flux akka en général). J'essaie de construire un graphique afin de publier un message sur différents sujets. Comment puis-je connecter le produ

akka-stream reactive-kafka 2017-08-14

---

0La chaleur

1Répondre

Réactif Kafka: Pas d'erreur lors de la création d'un flux pour un sujet inexistant

Nous avons récemment passé à Reactive Kafka. Il semble que kafka ne jette aucune erreur si le sujet existe lors de la création du flux pour le sujet. Pourquoi est-ce vrai? Je sais que l'existence d'un

apache-kafka reactive-kafka 2017-05-11

---

2La chaleur

2Répondre

Reactive-Kafka: Comment faire une pause sur le consommateur sur l'exception et réessayer à la demande

J'ai déjà demandé this déjà une question sur Google Groupes, mais je n'ai pas encore reçu de réponse. Donc, poster ceci ici pour un public différent. Nous utilisons Reactive-Kafka pour notre applicati

scala akka-stream reactive-kafka 2017-02-03

---