Questions marquées «apache-kafka»

Apache Kafka est une plateforme de streaming distribuée conçue pour stocker et traiter des flux de données à haut débit.

185
Purger le sujet Kafka

Existe-t-il un moyen de purger le sujet dans kafka? J'ai poussé un message trop gros dans un sujet de message kafka sur ma machine locale, maintenant j'obtiens une erreur: kafka.common.InvalidMessageSizeException: invalid message size Augmenter le fetch.sizen'est pas idéal ici, car je ne veux pas...

168
Modélisation de données avec Kafka? Sujets et partitions

Une des premières choses auxquelles je pense lorsque j'utilise un nouveau service (comme une banque de données non SGBDR ou une file d'attente de messages) est: "Comment dois-je structurer mes données?". J'ai lu et regardé quelques documents d'introduction. En particulier, prenez, par exemple,...

102
Apache Kafka contre Apache Storm

Apache Kafka: système de messagerie distribuée Apache Storm: traitement des messages en temps réel Comment pouvons-nous utiliser les deux technologies dans un pipeline de données en temps réel pour le traitement des données d'événements? En termes de pipeline de données en temps réel, les deux me...

94
Supprimer le sujet dans Kafka 0.8.1.1

Je dois supprimer le sujet testdans Apache Kafka 0.8.1.1. Comme indiqué dans la documentation ici , j'ai exécuté: bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test Cependant, cela entraîne le message suivant: Command must include exactly one action: --list, --describe, --create...

9
Kafka: obtenir continuellement FETCH_SESSION_ID_NOT_FOUND

Je reçois continuellement FETCH_SESSION_ID_NOT_FOUND. Je ne sais pas pourquoi cela se produit. Quelqu'un peut-il me plaire ici quel est le problème et quel sera l'impact sur les consommateurs et les courtiers? Journal du serveur Kafka: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][]...