javascript - Kan inte skicka Kafka-meddelanden även om både ämnet och producenten existerar

Jag arbetar i TypeScript med KafkaJS-biblioteket lokalt, med en enda Kafka-broker. Jag har lyckats ansluta en producer, har verifierat att mitt ämne skapades, och genererar meddelanden med:

  const changeMessage = {
    key: id,
    value: JSON.stringify(person),
    headers: {
      changeType: status,
    },
  };

Nu när jag ska skicka meddelandet:

  try {
    const sendResponse = await producer.send({
      topic: topicName2,
      messages: [changeMessage],
    });
    log.responseFragment(
      { id, topicName2 },
      `Sending changed/added person ${id} to topic ${topicName2}`
    );
  } catch (error) {
    log.error(
    { error }, `Could not send personChangedAdded ${id} to topic ${topicName2}`
    );
  }

Här är felet som jag får tillbaka:

Could not send personChange to topic topicName2
    error: {
      "name": "KafkaJSError",
      "retriable": true
    }

Svar #1

Jag hade misslyckats med att definiera log.responseFragment(), och när jag ändrade det till en enkel log.info() löstes problemet.