Bootstrap Server List problem in Kafka asset

Products

• Service Virtualization

Issue/Introduction

When defining the Kafka assets in DevTest 10.6, the customer found the problems for defining the value with "DevTest Property Reference" style.

If the property for "Bootstrap Servers" is defined additional config file(not project.config), 
For example, create a new config file named aa.config and define the property named BOOTSTRAPSERVERS_LIST like "<Server1>:<Port1>,<server2>:<Port2>. and make active the aa.config file.

then error messages are occurred when verifying like:

STACK TRACE
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
 at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:825)
 at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:631)
 at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils$DefaultKafkaImpl.createConsumer(KafkaUtils.java:790)
 at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils.createKafkaConsumer(KafkaUtils.java:82)
 at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils.verifyConnection(KafkaUtils.java:498)
 at com.itko.lisa.messaging.providers.kafka.asset.KafkaConfigAsset.verifyInstance(KafkaConfigAsset.java:247)
 at com.itko.lisa.messaging.providers.kafka.asset.KafkaConfigAsset.verifyInstance(KafkaConfigAsset.java:45)
 at com.itko.lisa.asset.AssetUtils.verifyRuntimeAsset(AssetUtils.java:1300)
 at com.itko.lisa.asset.ui.AssetEditor$5.run(AssetEditor.java:306)
 at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:142)
 at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:100)
 at javax.swing.SwingWorker$1.call(SwingWorker.java:295)
 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 at javax.swing.SwingWorker.run(SwingWorker.java:334)
 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
 at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: {{BOOTSTRAPSERVERS_LIST}}
 at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:59)
 at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
 at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:737)
 ... 16 more

 

 

 

Environment

Release : 10.6

Component : CA Service Virtualization

Cause

This is a defect for DevTest 10.6 GA.

Resolution

Please contact Broadcom support to get a patch named patch_DE503511_10.6.0_GA.jar.