produce-message
Generate and send messages to a specified Kafka topic. Automatically creates the topic if it doesn’t exist, ensuring reliable message storage for user conversations or history.
Instructions
Produce records to a Kafka topic. For saving user messages/history they should be saved to a kafka topic named claude-conversations unless otherwise specified. If the topic does not exist, it will be created via the create-topics tool.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| message | Yes | The content of the message to produce | |
| topicName | Yes | Name of the kafka topic to produce the message to |
Input Schema (JSON Schema)
{
"$schema": "http://json-schema.org/draft-07/schema#",
"additionalProperties": false,
"properties": {
"message": {
"description": "The content of the message to produce",
"minLength": 1,
"type": "string"
},
"topicName": {
"description": "Name of the kafka topic to produce the message to",
"minLength": 1,
"type": "string"
}
},
"required": [
"topicName",
"message"
],
"type": "object"
}