abstract class EnsLib.Kafka.Common
extends %RegisteredObject
• parameter SETTINGS = "Servers:Kafka Settings,Credentials:Kafka Settings:credentialsSelector,SecurityProtocol:Kafka Settings,SASLMechanism:Kafka Settings,TrustStoreLocation:Kafka Settings,TrustStoreCredentials:Kafka Settings:credentialsSelector,KeyStoreLocation:Kafka Settings,KeyStoreCredentials:Kafka Settings:credentialsSelector,KeyCredentials:Kafka Settings:credentialsSelector";
• property Credentials
as %String(MAXLEN=200);
This is the ID name of the set of credentials values (Username, Password) used to access the Kafka server.
• property KeyCredentials
as %String(MAXLEN=200);
Credentials ID containing key password
• property KeyStoreCredentials
as %String(MAXLEN=200);
Credentials ID containing key store password
• property KeyStoreLocation
as %String(MAXLEN=200);
Key store location
• property SASLMechanism
as %String(MAXLEN=50) [ InitialExpression = "PLAIN" ];
SASL mechanism
Posssible values: GSSAPI,PLAIN,SCRAM-SHA-256,SCRAM-SHA-512,OAUTHBEARER
Supported mechanism: PLAIN
• property SecurityProtocol
as %String(DISPLAYLIST=",SASL_PLAINTEXT,SASL_SSL",VALUELIST=",SASL_PLAINTEXT,SASL_SSL") [ InitialExpression = "SASL_PLAINTEXT" ];
Security protocol between Kafka client and broker
Supported protocol: SASL_PLAINTEXT, SASL_SSL
• property Servers
as %String(MAXLEN=200) [ InitialExpression = "localhost:9092" ];
Kafka server host and port.
• property TrustStoreCredentials
as %String(MAXLEN=200);
Credentials ID containing trust store password
• property TrustStoreLocation
as %String(MAXLEN=200);
Trust store location
