J'ai un Kafka fonctionnant dans un port différent du 9092 par défaut.Comment utiliser un port différent pour confluent-kafka?
Comment puis-je dire à confluent-kafka d'utiliser ce port? Parce que ni dans le API documentation ni Github je vois une configuration de «port», juste la configuration de serveur de bootstrap, qui est seulement pour définir l'IP du point de terminaison de Kafka.
Le paramètre de serveur bootstrap ne définit pas uniquement l'adresse IP. C'est une liste de points de terminaison Kafka définis comme: séparés par une virgule. Par exemple dans votre cas si vous avez Kafka sur un port non standard, c'est-à-dire 9093 et sur localhost, le paramètre de serveur bootstrap peut être localhost: 9093.
Vous pouvez voir cette https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
il dit que le bootstrap.servers est alias pour metadata.broker.list
Et la description de metadata.broker.list est:
liste initiale des les courtiers en tant que liste CSV de l'hôte ou de l'hôte du courtier: port. L'application peut également utiliser rd_kafka_brokers_add() pour ajouter des courtiers lors de l'exécution. Type: chaîne
vous pourriez actully utiliser cette
{'bootstrap.server' : 'ip:your_host,...',
....
}
comme kwargs au producteur ou l'initiation à la consommation.