|
@@ -32,8 +32,8 @@ KAFKA_BROKER := '127.0.0.1';
|
|
|
KAFKA_TEST_TOPIC := Std.System.Job.WUID() : INDEPENDENT;
|
|
|
KAFKA_CONSUMER_GROUP := 'regress';
|
|
|
|
|
|
-p := kafka.Publisher(KAFKA_TEST_TOPIC, KAFKA_BROKER);
|
|
|
-c := kafka.Consumer(KAFKA_TEST_TOPIC, KAFKA_BROKER, KAFKA_CONSUMER_GROUP);
|
|
|
+p := kafka.KafkaPublisher(KAFKA_TEST_TOPIC, KAFKA_BROKER);
|
|
|
+c := kafka.KafkaConsumer(KAFKA_TEST_TOPIC, KAFKA_BROKER, KAFKA_CONSUMER_GROUP);
|
|
|
|
|
|
SEQUENTIAL
|
|
|
(
|