Skip to main content

%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
method DeleteTopic(topicName As %String) as %Status
Delete a Kafka Topic with the name
method UpdateAdminConfig(adminConfig As %String) as %Status
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.
method UpdateConsumerConfig(consumerConfig As %String) as %Status
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\"}"
method UpdateProducerConfig(producerConfig As %String) as %Status
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\"}"

Inherited Members

Inherited Properties

Inherited Methods

FeedbackOpens in a new tab