webMethods Adapter for Apache Kafka
Sample Connection Properties
Connection properties follow this pattern:
artConnection.<packageName>.<connectionName>.propertyGroup.property=value
For example:
artConnection.ConfluentKafkaRegression.connections.ConfluentKafkaAvroProducer.
connectionEnabled=true
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.blockingTimeout=1000
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.expireTimeout=1000
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.maximumPoolSize=10
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.minimumPoolSize=1
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.poolIncrementSize=1
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.poolable=true
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.startupBackoffSecs=10
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionManagerSettings.startupRetryCount=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.ackIndicator=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.batchSize=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.clientID=democon123
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.compressionType=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.kafkaVersion=v9
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.kerberosServiceName=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.keySerializerClass=
io.confluent.kafka.serializers.KafkaAvroSerializer
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.keyStoreAlias=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.maxRetry=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.otherProperties=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.partitionerClass=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.requestTimeOut=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.schemaPkgName=ConfluentKafkaRegression
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.schemaRegistryURL=http\://vmriti02\:8081
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.securityProtocol=None
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.sendBufferSize=0
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.serverList=vmriti02\:9092
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.trustStoreAlias=
artConnection.TestPkg_Kafka.connections.ConfKafkaAvroProducerConn.
connectionSettings.valueSerializerClass=
io.confluent.kafka.serializers.KafkaAvroSerializer
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.connectionEnabled=true
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.blockingTimeout=1000
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.expireTimeout=1000
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.maximumPoolSize=10
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.minimumPoolSize=1
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.poolIncrementSize=1
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.poolable=true
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.startupBackoffSecs=10
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionManagerSettings.startupRetryCount=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.ackIndicator=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.batchSize=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.clientID=democon123
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.compressionType=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.jaasConfig={AES}kSoTK3xdu2nyV1SDA+W43g==
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.kafkaVersion=v9
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.kerberosServiceName=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.keySerializerClass=
org.apache.kafka.common.serialization.StringSerializer
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.keyStoreAlias=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.maxRetry=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.otherProperties=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.partitionerClass=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.requestTimeOut=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.schemaPkgName=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.schemaRegistryCredentials={AES}kSoTK3xdu2nyV1SDA+W43g==
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.schemaRegistryURL=http\://vmriti02\:8081
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.securityProtocol=None
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.sendBufferSize=0
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.serverList=vmriti02\:9092
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.trustStoreAlias=
artConnection.TestPkg_Kafka.connections.ConfKafkaProducerConn.
connectionSettings.valueSerializerClass=
org.apache.kafka.common.serialization.StringSerializer
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.connectionEnabled=true
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.blockingTimeout=1000
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.expireTimeout=1000
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.maximumPoolSize=10
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.minimumPoolSize=1
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.poolIncrementSize=1
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.poolable=true
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.startupBackoffSecs=10
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionManagerSettings.startupRetryCount=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.ackIndicator=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.batchSize=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.clientID=democon123
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.compressionType=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.jaasConfig={AES}kSoTK3xdu2nyV1SDA+W43g==
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.kafkaVersion=v9
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.kerberosServiceName=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.keySerializerClass=
org.apache.kafka.common.serialization.StringSerializer
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.keyStoreAlias=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.maxRetry=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.otherProperties=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.partitionerClass=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.requestTimeOut=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.schemaPkgName=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.schemaRegistryCredentials={AES}kSoTK3xdu2nyV1SDA+W43g==
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.schemaRegistryURL=http\://vmriti02\:8081
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.securityProtocol=None
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.sendBufferSize=0
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.serverList=vmriti02\:9092
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.trustStoreAlias=
artConnection.TestPkg_Kafka.connections.KafkaConnSanp.
connectionSettings.valueSerializerClass=
org.apache.kafka.common.serialization.StringSerializer
Sample Listener Properties
Listener properties follow this pattern:
artListener.<packageName>.<listenerName>.propertyGroup.property=value
For example:
artListener.TestPkg_Kafka.listeners.ConfListener1.connectionAlias=Connection\:ConfluentKafkaConsumer
artListener.TestPkg_Kafka.listeners.ConfListener1.
listenerEnabled=false
artListener.TestPkg_Kafka.listeners.ConfListener1.
listenerSettings.partitions=
artListener.TestPkg_Kafka.listeners.ConfListener1.
listenerSettings.pollInterval=1000
artListener.TestPkg_Kafka.listeners.ConfListener1.
listenerSettings.seekOffsets=
artListener.TestPkg_Kafka.listeners.ConfListener1.
listenerSettings.topicName=kafkatopicnew
artListener.TestPkg_Kafka.listeners.ConfListener1.
retryBackoffTimeout=10
artListener.TestPkg_Kafka.listeners.ConfListener1.
retryLimit=5
artListener.TestPkg_Kafka.listeners.ConfListener2.
connectionAlias=Connection\:ConfluentKafkaConsumer
artListener.TestPkg_Kafka.listeners.ConfListener2.
listenerEnabled=false
artListener.TestPkg_Kafka.listeners.ConfListener2.
listenerSettings.partitions=
artListener.TestPkg_Kafka.listeners.ConfListener2.
listenerSettings.pollInterval=1000
artListener.TestPkg_Kafka.listeners.ConfListener2.
listenerSettings.seekOffsets=
artListener.TestPkg_Kafka.listeners.ConfListener2.
listenerSettings.topicName=kafkatopicnew
artListener.TestPkg_Kafka.listeners.ConfListener2.
retryBackoffTimeout=10
artListener.TestPkg_Kafka.listeners.ConfListener2.
retryLimit=5
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
connectionAlias=Connection\:ConfluentKafkaConsumer
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
listenerEnabled=false
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
listenerSettings.partitions=
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
listenerSettings.pollInterval=1000
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
listenerSettings.seekOffsets=
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
listenerSettings.topicName=kafkatopicnew
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
retryBackoffTimeout=10
artListener.TestPkg_Kafka.listeners.ConfListenerSanp.
retryLimit=5
Sample Polling Notification Properties
Polling Notification properties follow this pattern:
artNotification.<packageName>.<notificationName>.propertyGroup.property=value
For example:
artNotification.TestPkg_Kafka.Notifications.ConfluentAsyncNotif.
listenerName=Listener\:ConfluentListener
artNotification.TestPkg_Kafka.Notifications.ConfluentAsyncNotif.
notificationEnabled=false
artNotification.TestPkg_Kafka.Notifications.ConfluentSyncNotif.
listenerName=Listener\:ConfluentListener
artNotification.TestPkg_Kafka.Notifications.ConfluentSyncNotif.
notificationEnabled=false