webMethods Adapter for Apache Kafka
Sample Template for Creating a Connection
Apache Kafka Connection Sample:
{
"connectionAlias": "<Connection_Alias>",
"packageName": "<Package_Name>",
"adapterTypeName": "com.wm.adapter.wmkafka.KafkaAdapter",
"connectionFactoryType": "com.wm.adapter.wmkafka.connection.kafkaConsumerConnectionFactory",
"connectionSettings": {
"serverList": "<Host_Name>:<Port_Number>",
"groupId": "<Group_ID>",
"clientID": "<Client_ID>",
"keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer",
"valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer",
"enableAutoCommit": true,
"autoCommitInterval": "",
"seesionTimeOut": "",
"autoOffsetReset": "earliest",
"kafkaVersion": "v11+",
"otherProperties": ""
},
"connectionManagerSettings": {
"poolable": "true",
"minimumPoolSize": "1",
"maximumPoolSize": "10",
"poolIncrementSize": "1",
"blockingTimeout": "1000",
"expireTimeout": "1000",
"startupRetryCount": "0",
"startupBackoffSecs": "10"
}
}
Confluent Kafka Connection Sample:
{
"connectionAlias": "<Connection_Alias>",
"packageName": "<Package_Name>",
"adapterTypeName": "com.wm.adapter.wmkafka.KafkaAdapter",
"connectionFactoryType": "com.wm.adapter.wmkafka.schema.connection.KafkaConfluentConsumerConnectionFactory",
"connectionSettings": {
"serverList": "<Host_Name>:<Port_Number>",
"schemaRegistryURL": "<Host_Name>:<Port_Number>",
"schemaPkgName": "ConfluentKafkaRegression",
"schemaRegistryCredentials": null,
"groupId": "<Group_ID>",
"clientID": "<Client_ID>",
"keyDeserializer": "io.confluent.kafka.serializers.KafkaAvroDeserializer",
"valueDeserializer": "io.confluent.kafka.serializers.KafkaAvroDeserializer",
"enableAutoCommit": true,
"autoCommitInterval": "",
"securityProtocol": "None",
"kerberosServiceName": "",
"jaasConfig": null,
"trustStoreAlias": "",
"keyStoreAlias": "",
"seesionTimeOut": "",
"autoOffsetReset": "earliest",
"kafkaVersion": "v9",
"otherProperties": ""
},
"connectionManagerSettings": {
"poolable": "true",
"minimumPoolSize": "1",
"maximumPoolSize": "10",
"poolIncrementSize": "1",
"blockingTimeout": "1000",
"expireTimeout": "1000",
"startupRetryCount": "0",
"startupBackoffSecs": "10"
}
}
Sample Template for Creating a Listener
{
"listenerName": "<Listener_Name>",
"packageName": "<Package_Name>",
"adapterTypeName": "com.wm.adapter.wmkafka.KafkaAdapter",
"listenerTemplate": "com.wm.adapter.wmkafka.connection.KafkaListener",
"connectionAlias": "<Connection_Alias>",
"listenerEnabled": "false",
"listenerSettings": {
"retryBackoffTimeout": "10",
"retryLimit": "5",
"pollInterval": 1000,
"seekOffsets": "",
"partitions": "",
"topicName": "<Topic_Name>"
}
}