tweak broker config

test/versioned/kafkajs/kafka.tap.js

@@ -7,16 +7,19 @@
 
 const tap = require('tap')
 const helper = require('../../lib/agent_helper')
+const params = require('../../lib/params')
 const { removeModules } = require('../../lib/cache-buster')
 
+const broker = `${params.kafka_host}:${params.kafka_port}`
+
 tap.beforeEach(async (t) => {
   t.context.agent = helper.instrumentMockedAgent()
 
   const { Kafka } = require('kafkajs')
   t.context.Kafka = Kafka
   const kafka = new Kafka({
     clientId: 'kafka-test',
-    brokers: ['127.0.0.1:9092']
+    brokers: [broker]
   })
 
   const producer = kafka.producer()