A Kafka simulator app
data = {
type: "producer",
level: "debug",
timestamp,
broker,
clientId,
correlationId,
size,
topics: [
{
topicName,
partitions: [
partition,
errorCode,
baseOffset,
logAppendTime,
logStartOffset,
],
},
],
};
- Response Produce => producer
- Response Metadata => metadata
To run the simulator:
- first use script "npm run zookeeper" (zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties)
- then execute script "npm run kafka" (kafka-server-start /usr/local/etc/kafka/server.properties)
- finally, "npm run dev"