Erreur Kafka standalone: ​​WARN Tentative d'envoi de réponse via un canal pour lequel il n'y a pas de connexion ouverte, ID de connexion 0 (kafka.network.Processor)

Question

J'installe kafka sur un serveur autonome et j'essaie de diffuser des données vers mongodb. lors du démarrage du service kafka, bin/kafka-server-start.sh config/server.properties J'ai reçu un avertissement: WARN Tenter d'envoyer une réponse via un canal pour lequel il n'y a pas de connexion ouverte, ID de connexion 0 (kafka.network. Processeur)

Même si, il n'y a pas de problème pour les données entrées au producteur et affichées au consommateur.

mais je pense que cela provoque l'écriture de données à mongodb. Je n'ai aucune donnée à écrire sur mongodb après le début du streaming de données.

quelqu'un peut aider avec ce problème? Merci beaucoup.

Answer 1

//processor.sendResponse 
    protected[network] def sendResponse(response: RequestChannel.Response) { 
    trace(s"Socket server received response to send, registering for write and sending data: $response") 
    val channel = selector.channel(response.responseSend.destination) 
    // `channel` can be null if the selector closed the connection because it was idle for too long 
    if (channel == null) { 
     warn(s"Attempting to send response via channel for which there is no open connection, connection id $id") 
     response.request.updateRequestMetrics() 
    } 
    else { 
     selector.send(response.responseSend) 
     inflightResponses += (response.request.connectionId -> response) 
    } 

donc, le canal a été fermé par le sélecteur parce qu'il était ralenti trop longtemps