preguntar acerca de apache-kafka

1
réponses

Kafka: Consumer API vs flux API

J'ai récemment commencé à apprendre Kafka et à me retrouver avec cette question. Quelle est la différence entre Consumer et Stream? Pour moi, si un outil / application consomme des messages de Kafka est un consommateur dans le monde de Kafka. Alors …
demandé sur 1970-01-01 00:33:37
4
réponses

Comment changer les répliques du sujet kafka?

Après un sujet Kafka créé par le producteur ou l'administrateur, comment changer le numéro de réplicas de ce sujet?(augmenter ou diminuer les répliques le nombre.) ... …
demandé sur 1970-01-01 00:33:36
2
réponses

Pourquoi les consommateurs de Kafka se connectent-ils à zookeeper et les producteurs obtiennent-ils des métadonnées auprès des courtiers?

Pourquoi les consommateurs se connectent - ils à zookeeper pour récupérer les emplacements de partition? Et les producteurs de kafka doivent se connecter à l'un des courtiers pour récupérer les métadonnées. Mon point est, Quelle est exactement l'uti …
demandé sur 1970-01-01 00:33:35
5
réponses

Commande pour obtenir la liste des courtiers kafka de zookeeper

J'écris un script shell pour surveiller les courtiers kafka. J'ai parcouru quelques liens et constaté que si ZooKeeper contient une liste de courtiers, et si, dans cette liste, l'adresse IP est présente, alors un courtier kafka est en cours d'exécuti …
demandé sur 1970-01-01 00:33:36
2
réponses

Quelle est la différence entre MQTT broker et Apache Kafka

je développe une application mobile de messagerie. J'ai passé en revue la technologie nécessaire et trouvé deux MQTT & Apache Kafta. Pour moi, les deux semblent faire la même chose de la même manière (en termes d'abonnement et de publication à un …
demandé sur 1970-01-01 00:33:36
2
réponses

Différence entre le traitement des flux et le traitement des messages

Quelle est la différence fondamentale entre le traitement des flux et le traitement traditionnel des messages? Comme les gens disent que kafka est un bon choix pour le traitement de flux, mais essentiellement kafka est un cadre de messagerie similair …
demandé sur 1970-01-01 00:33:37
2
réponses

Fluentd vs Kafka

Le cas d'utilisation est-ce: J'ai plusieurs applications java en cours d'exécution qui doivent toutes interagir avec des indices elasticsearch différents (chacun ayant une cible spécifique). Par exemple,une application a utilise les indices A,B, C D' …
demandé sur 1970-01-01 00:33:36
1
réponses

Apache Kafka avec Avro et Schema Repo-où va l’Id de schema dans le message?

Je veux utiliser Avro pour sérialiser les données pour mes messages Kafka et je voudrais l'utiliser avec un dépôt Avro schema donc je n'ai pas à inclure le schéma avec chaque message. utiliser Avro avec Kafka semble comme une chose populaire à fair …
demandé sur 1970-01-01 00:33:35
3
réponses

Kafka configuration du serveur — auditeurs vs. annoncés.auditeur

pour lancer Kafka, vous devez définir quelques propriétés dans config/server.properties fichier. Il y a deux paramètres que je ne comprends pas. quelqu'un Peut-il expliquer la différence entre les auditeurs et la publicité.la propriété des auditeur …
demandé sur 1970-01-01 00:33:37
2
réponses

Zokeeper & Kafka error KeeperErrorCode=NodeExists

j'ai écrit un kafkaconsumer et producer ça fonctionne très bien jusqu'à aujourd'hui. Ce matin, quand j'ai commencé zooekeeper et kafka, ma consommation n'a pas réussi à lire les messages et en Zookeeper log j'ai lu cette erreur INFO Got user-level K …
demandé sur 1970-01-01 00:33:35