Include topic & partition in UNKNOWN_TOPIC_OR_PARTITION error

[Nevon]

Currently, the unknown topic or partition error doesn't display which topic or partition has caused the failure. The log entry looks something like this:

{	
  broker: "kafka-host:9094",
  clientId: "tink-transaction-mapper",
  correlationId: 1385,
  error: "This server does not host this topic-partition",
  level: "ERROR",
  logger: "kafkajs",
  message: "[Connection] Response Metadata(key: 3, version: 2)",
  size: 1180,
  timestamp: "2018-09-17T07:37:39.265Z"
}

It would be useful to include the topic and the partition on the error and in the log entry.

[theliuk]

I might take this.

[ghost]

Has this issue been resolved yet? Everyone give me a solution for this issue...

[sujay-neglur]

I am picking this issue. Fork created at https://github.com/sujayneglur123/kafkajs

[mgirard772]

👍 to see this resolved, this error message is not very helpful without this information.

[dhananjaysa92]

looking into it.

[atiquefiroz]

has this been planned to resolve?