...
Field | Type | Description | Example | |
---|---|---|---|---|
Name |
| A user-supplied name for the endpoint | “MyKafkaEndpoint1” | |
Description |
| A user-supplied description for the endpoint | “Kafka Endpoint for consumer transactions” | |
Encoding |
| The encoding used for serialization/deserialization of the kafka messages | json | |
BootstrapServers | comma-separated list of strings | A list | The name and port of the Kafka bootstrap servers. | ["kafka1:9002","kafka2:9002"] |
Group (Consumer Group) (optional) |
| To provide a horizontally scalable solution, a Consumer Group can be used to allow load balancing of requests across multiple ModelOp runtimes. By defining a Consumer Group, ModelOp Center ensures that only one ModelOp runtime in the Consumer Group services a given message. | "fastscore-1" | |
Principal (optional) |
| An authenticated user in a secure cluster | "kafka/kafka@REALM" | |
Topic |
| The Kafka topic to consume or push to, depending on if input vs. output endpoint | "MyKafkaTopic" | |
Keyfile (optional) |
| The location of the keytab file containing pairs of Kerberos principals and encrypted keys | "/fastscore.keytab" |
...