%External.Messaging.KafkaClient
class %External.Messaging.KafkaClient extends %External.Messaging.Client
Method Inventory
Methods
method CreateTopic(topicName As %String, numberOfPartitions As %Integer, replicationFactor As %TinyInt) as %Status
Applicable to Kafka.
Create a Kafka Topic with the name
Create a Kafka Topic with the name
Delete a Kafka Topic with the name
Applicable to Kafka.
Updates the Admin Client Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka's Admin Client. For possilbe admin client configuration properties, please refer to https://kafka.apache.org/documentation/#adminclientconfigs.
Updates the Admin Client Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka's Admin Client. For possilbe admin client configuration properties, please refer to https://kafka.apache.org/documentation/#adminclientconfigs.
Applicable to Kafka.
Updates the Consumer Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka Consumer. For possible consumer configuration properties, please refer to https://kafka.apache.org/documentation/#consumerconfigs. Sample settings: "{\"key.deserializer\":\"org.apache.kafka.common.serialization.StringDeserializer\"}"
Updates the Consumer Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka Consumer. For possible consumer configuration properties, please refer to https://kafka.apache.org/documentation/#consumerconfigs. Sample settings: "{\"key.deserializer\":\"org.apache.kafka.common.serialization.StringDeserializer\"}"
Applicable to Kafka.
Updates the Producer Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka Producer. For possible producer configuration properties, please refer to https://kafka.apache.org/documentation/#producerconfigs. Sample settings: "{\"key.serializer\":\"org.apache.kafka.common.serialization.StringSerializer\"}"
Updates the Producer Configurations using the passed in JSON string.
Only pass in configuratiton properties that are applicable to the Kafka Producer. For possible producer configuration properties, please refer to https://kafka.apache.org/documentation/#producerconfigs. Sample settings: "{\"key.serializer\":\"org.apache.kafka.common.serialization.StringSerializer\"}"
Inherited Members
Inherited Properties
Inherited Methods
- %AddToSaveSet()
- %ClassIsLatestVersion()
- %ClassName()
- %ConstructClone()
- %DispatchClassMethod()
- %DispatchGetModified()
- %DispatchGetProperty()
- %DispatchMethod()
- %DispatchSetModified()
- %DispatchSetMultidimProperty()
- %DispatchSetProperty()
- %Extends()
- %GetParameter()
- %IsA()
- %IsModified()
- %New()
- %NormalizeObject()
- %ObjectModified()
- %OriginalNamespace()
- %PackageName()
- %RemoveFromSaveSet()
- %SerializeObject()
- %SetModified()
- %ValidateObject()
- Close()
- Connect()
- CreateClient()
- CreateJMSClient()
- CreateKafkaClient()
- CreateQueueOrTopic()
- CreateRabbitMQClient()
- CreateSNSClient()
- CreateSQSClient()
- DeleteQueueOrTopic()
- ReceiveMessage()
- SendMessage()