J'essaie de créer un sujet de Kafka via Admincommand en utilisant ci-dessous Code source Cependant, je suis capable de créer le sujet à l'aide de la commande shell.
3 Réponses :
Dans votre code,
Exception in thread "main" kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0 at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70) at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:155)
Dans tous les cas, l'exception est grossièrement trompeuse et devrait probablement lire: "[...] Facteur de réplication: 2 plus grand que les courtiers disponibles: 1"
Configurez votre machine locale pour avoir plusieurs courtiers en place et en cours d'exécution au cas où vous décideriez de conserver votre Vous pouvez le faire en ayant simplement plusieurs copies de la
Vous devez ensuite spécifier différents puis démarrez plusieurs instances avec les commandes suivantes < Pré> xxx pour plus de détails check Étape 6: Configuration d'un multi-courtier Cluster réplication_factor> 1 . serveur.properties fichier. par exemple serveur-1.properties & serveur-2.properties courtier.id & port dans chacun de ces fichiers pour les rendre unique ..
J'ai fait face au même problème tout en mettant en place plusieurs courtiers.
L'étape que j'ai manquante était:
lors de la modification du fichier de configuration: config / server-1.properties: courtier.id = 1 Auditeurs = Plaintext: //: 9093 log.dir = / tmp / kafka-journaux-1
besoin de mettre à jour la section de base de journal également (voir ci-dessous):
######################## BLUS BASICS