From 5982129a0d3321a029965c93398568ce485d2e6d Mon Sep 17 00:00:00 2001 From: bmaidics Date: Fri, 17 May 2024 15:45:46 +0200 Subject: [PATCH] change tests --- .../internal/stream/MqttKafkaSubscribeFactory.java | 2 +- .../streams/kafka/publish.mixture.qos/client.rpt | 12 ++++++------ .../streams/kafka/publish.mixture.qos/server.rpt | 12 ++++++------ .../publish.qos2.init.producer.abort/client.rpt | 8 ++++---- .../publish.qos2.init.producer.abort/server.rpt | 8 ++++---- .../streams/kafka/publish.qos2.meta.abort/client.rpt | 4 ++-- .../streams/kafka/publish.qos2.meta.abort/server.rpt | 4 ++-- .../client.rpt | 12 ++++++------ .../server.rpt | 12 ++++++------ .../client.rpt | 10 +++++----- .../server.rpt | 10 +++++----- .../kafka/publish.qos2.offset.fetch.abort/client.rpt | 6 +++--- .../kafka/publish.qos2.offset.fetch.abort/server.rpt | 6 +++--- .../streams/kafka/publish.qos2.recovery/client.rpt | 10 +++++----- .../streams/kafka/publish.qos2.recovery/server.rpt | 10 +++++----- .../streams/kafka/publish.qos2.retained/client.rpt | 12 ++++++------ .../streams/kafka/publish.qos2.retained/server.rpt | 12 ++++++------ .../mqtt/kafka/streams/kafka/publish.qos2/client.rpt | 12 ++++++------ .../mqtt/kafka/streams/kafka/publish.qos2/server.rpt | 12 ++++++------ .../streams/kafka/publish.reject.qos2/client.rpt | 2 +- .../streams/kafka/publish.reject.qos2/server.rpt | 2 +- .../session.abort.expire.session.state/client.rpt | 2 +- .../session.abort.expire.session.state/server.rpt | 2 +- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../kafka/session.client.sent.reset/client.rpt | 2 +- .../kafka/session.client.sent.reset/server.rpt | 2 +- .../streams/kafka/session.client.takeover/client.rpt | 4 ++-- .../streams/kafka/session.client.takeover/server.rpt | 4 ++-- .../session.close.expire.session.state/client.rpt | 2 +- .../session.close.expire.session.state/server.rpt | 2 +- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../kafka/session.exists.clean.start/client.rpt | 4 ++-- .../kafka/session.exists.clean.start/server.rpt | 4 ++-- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../session.group.reset.not.authorized/client.rpt | 2 +- .../session.group.reset.not.authorized/server.rpt | 2 +- .../kafka/session.group.server.sent.reset/client.rpt | 2 +- .../kafka/session.group.server.sent.reset/server.rpt | 2 +- .../kafka/streams/kafka/session.redirect/client.rpt | 2 +- .../kafka/streams/kafka/session.redirect/server.rpt | 2 +- .../kafka/session.server.sent.reset/client.rpt | 2 +- .../kafka/session.server.sent.reset/server.rpt | 2 +- .../session.subscribe.via.session.state/client.rpt | 2 +- .../session.subscribe.via.session.state/server.rpt | 2 +- .../kafka/streams/kafka/session.subscribe/client.rpt | 2 +- .../kafka/streams/kafka/session.subscribe/server.rpt | 2 +- .../session.unsubscribe.after.subscribe/client.rpt | 2 +- .../session.unsubscribe.after.subscribe/server.rpt | 2 +- .../session.unsubscribe.via.session.state/client.rpt | 2 +- .../session.unsubscribe.via.session.state/server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../session.will.message.clean.start/client.rpt | 2 +- .../session.will.message.clean.start/server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 2 +- .../server.rpt | 2 +- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../client.rpt | 2 +- .../server.rpt | 2 +- .../kafka/subscribe.receive.message.qos1/client.rpt | 2 +- .../kafka/subscribe.receive.message.qos1/server.rpt | 2 +- .../kafka/subscribe.receive.message.qos2/client.rpt | 4 ++-- .../kafka/subscribe.receive.message.qos2/server.rpt | 4 ++-- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../client.rpt | 8 ++++---- .../server.rpt | 8 ++++---- .../client.rpt | 8 ++++---- .../server.rpt | 8 ++++---- .../client.rpt | 4 ++-- .../server.rpt | 4 ++-- .../client.rpt | 8 ++++---- .../server.rpt | 8 ++++---- 91 files changed, 197 insertions(+), 197 deletions(-) diff --git a/runtime/binding-mqtt-kafka/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/kafka/internal/stream/MqttKafkaSubscribeFactory.java b/runtime/binding-mqtt-kafka/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/kafka/internal/stream/MqttKafkaSubscribeFactory.java index ceb49042e9..ce9bd2afa2 100644 --- a/runtime/binding-mqtt-kafka/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/kafka/internal/stream/MqttKafkaSubscribeFactory.java +++ b/runtime/binding-mqtt-kafka/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/kafka/internal/stream/MqttKafkaSubscribeFactory.java @@ -2663,7 +2663,7 @@ private MessageConsumer newKafkaStream( m.topic(topic); if (qos >= MqttQoS.AT_LEAST_ONCE.value()) { - m.groupId(String.format("%s-%s", groupIdPrefix, clientId)); + m.groupId(String.format("%s-%s", groupIdPrefix, clientId.asString())); } m.partitionsItem(p -> p.partitionId(offsetType.value()) diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/client.rpt index f828fe54bc..047683d143 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -177,7 +177,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -235,7 +235,7 @@ connect await RECEIVED_PRODUCER write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -404,7 +404,7 @@ connect await RECEIVED_SESSION_STATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/server.rpt index a9c56f3429..9712ddc994 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -221,7 +221,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -378,7 +378,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/client.rpt index 52e8157fab..45ee66c2d4 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -177,7 +177,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/server.rpt index 6902e218ac..b99a6af17d 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/client.rpt index 443f1e7ad8..6cc69463ff 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/server.rpt index 2a941a9f15..148f797744 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/client.rpt index 44fb9ec716..a884d696ec 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -177,7 +177,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -235,7 +235,7 @@ connect await RECEIVED_PRODUCER write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -356,7 +356,7 @@ connect await RECEIVED_SESSION_STATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/server.rpt index 048abff16f..7793ca0d32 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -221,7 +221,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -334,7 +334,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/client.rpt index 66c8e4e541..b98b70a5cd 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -177,7 +177,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -235,7 +235,7 @@ connect await RECEIVED_PRODUCER write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/server.rpt index 88ec7fd4f2..f77ba95889 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase2/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -221,7 +221,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/client.rpt index 1566b57c8f..aa9f7574db 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/server.rpt index 353a1ce36d..e14c2d74d5 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.fetch.abort/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/client.rpt index c3a673319e..a84ab2cceb 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -184,7 +184,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -217,7 +217,7 @@ connect await RECEIVED_INITIAL_OFFSETS write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/server.rpt index 728b295bb3..b41afffe16 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.recovery/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -175,7 +175,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -206,7 +206,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/client.rpt index 61b4e9c8be..c93e60e14f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -178,7 +178,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -236,7 +236,7 @@ connect await RECEIVED_PRODUCER write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -385,7 +385,7 @@ connect await RECEIVED_SESSION_STATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/server.rpt index c50e6f077d..667dd6930e 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.retained/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -221,7 +221,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -360,7 +360,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/client.rpt index 2d567ec776..9a9a600da7 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/client.rpt @@ -56,7 +56,7 @@ connect await SENT_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -65,7 +65,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -146,7 +146,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -177,7 +177,7 @@ connect await RECEIVED_PARTITION_METADATA write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -235,7 +235,7 @@ connect await RECEIVED_PRODUCER write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -384,7 +384,7 @@ connect await RECEIVED_SESSION_STATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/server.rpt index 5fdddaf3c0..73374d38c2 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() @@ -62,7 +62,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .instanceId("zilla") .host("broker1.example.com") @@ -139,7 +139,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-messages") @@ -169,7 +169,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetFetch() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .host("broker1.example.com") .port(9092) .topic("mqtt-retained") @@ -221,7 +221,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") @@ -362,7 +362,7 @@ accepted read zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .offsetCommit() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .memberId("consumer-1") .instanceId("zilla") .host("broker1.example.com") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/client.rpt index 3fdd0c6ee0..9cabefa019 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/client.rpt @@ -58,7 +58,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/server.rpt index 18fedbb5d2..86b84d0d37 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.reject.qos2/server.rpt @@ -55,7 +55,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-session") + .groupId("zilla:test-mqtt0-client-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/client.rpt index 2c85050720..986be7a582 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/client.rpt @@ -147,7 +147,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/server.rpt index e91cec466b..f71b8a5e36 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.expire.session.state/server.rpt @@ -148,7 +148,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/client.rpt index 80fe36103c..e9ba898ca0 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/client.rpt @@ -59,7 +59,7 @@ connect await INIT_MIGRATE_SENT write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -279,7 +279,7 @@ connect await INIT2_MIGRATE_SENT write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/server.rpt index db0768bf21..cc8ed41bd5 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.abort.reconnect.non.clean.start/server.rpt @@ -55,7 +55,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -260,7 +260,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/client.rpt index e916057f57..d74b6f5caf 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/client.rpt @@ -59,7 +59,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/server.rpt index 29f8e82d9d..89910ba678 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.sent.reset/server.rpt @@ -56,7 +56,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/client.rpt index cd26e98ac7..3433866e4e 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/client.rpt @@ -59,7 +59,7 @@ connect await INIT_MIGRATE_CLOSED write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -335,7 +335,7 @@ connect await INIT_MIGRATE2_FINISHED write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/server.rpt index aa8c917076..2742732c13 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.client.takeover/server.rpt @@ -55,7 +55,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -326,7 +326,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/client.rpt index 87d324f040..1fc5137875 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/client.rpt @@ -177,7 +177,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/server.rpt index 9539436f92..283105d6c8 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.close.expire.session.state/server.rpt @@ -180,7 +180,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/client.rpt index 7844bab3b2..a3ecbadd58 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/client.rpt @@ -59,7 +59,7 @@ connect await INIT_MIGRATE_CLOSED write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(100000) .build() @@ -68,7 +68,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(30000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/server.rpt index a191d61495..99d155cd98 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.max.session.expiry/server.rpt @@ -55,7 +55,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(100000) .build() @@ -64,7 +64,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(30000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/client.rpt index fd9404995d..1067543da3 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/client.rpt @@ -59,7 +59,7 @@ connect await INIT_MIGRATE_CLOSED write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(2147483647) .build() @@ -68,7 +68,7 @@ write zilla:begin.ext ${kafka:beginEx() read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(2000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/server.rpt index ab0c13d4ee..4dff84a947 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.connect.override.min.session.expiry/server.rpt @@ -55,7 +55,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(2147483647) .build() @@ -64,7 +64,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(2000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/client.rpt index fa3f853487..9b594e0250 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/client.rpt @@ -59,7 +59,7 @@ connect await INIT_MIGRATE_SENT1 write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -331,7 +331,7 @@ connect await INIT_MIGRATE_SENT2 write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/server.rpt index ccdb515366..31b3fc7545 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.exists.clean.start/server.rpt @@ -54,7 +54,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() @@ -324,7 +324,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/client.rpt index 1dbf3d9fd4..d1ebfd37ba 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/client.rpt @@ -56,7 +56,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/server.rpt index 9ac10dd099..7a1913e35d 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.describe.config/server.rpt @@ -54,7 +54,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/client.rpt index bd9cc67716..c3e8ed5b30 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/client.rpt @@ -56,7 +56,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/server.rpt index 81bea19f30..93f0eeca09 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.invalid.session.timeout/server.rpt @@ -54,7 +54,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/client.rpt index 09c1567649..5c7d939456 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/client.rpt @@ -56,7 +56,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/server.rpt index edb6577317..c9cdd8e2b3 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.reset.not.authorized/server.rpt @@ -54,7 +54,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/client.rpt index 7a6a7c99b6..6868ec0eba 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/client.rpt @@ -59,7 +59,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/server.rpt index 67940525cc..6ea7e9f0f4 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.group.server.sent.reset/server.rpt @@ -56,7 +56,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/client.rpt index 071a65a2a9..e676db825f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/client.rpt @@ -60,7 +60,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/server.rpt index e0cb1dfcad..305a24424f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.redirect/server.rpt @@ -57,7 +57,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/client.rpt index 73cecfe231..9388701d18 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/client.rpt @@ -58,7 +58,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/server.rpt index 4631dedee5..bb198e28b5 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.server.sent.reset/server.rpt @@ -56,7 +56,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/client.rpt index 69b8f44a8c..e80faf6768 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/client.rpt @@ -56,7 +56,7 @@ connect await INIT_MIGRATE_SENT write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/server.rpt index 73a5bd57de..729aab023a 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe.via.session.state/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/client.rpt index 8a53c1ae7e..b59b1065f4 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/client.rpt @@ -59,7 +59,7 @@ connect await SENT_INIT_MIGRATE write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/server.rpt index 358d5c8121..7bc477eb3c 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.subscribe/server.rpt @@ -56,7 +56,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/client.rpt index f29a72c182..77d0e9f4e8 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/client.rpt @@ -56,7 +56,7 @@ connect await SESSION1_FINISHED write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/server.rpt index f933edc8db..a7c99572e9 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.after.subscribe/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/client.rpt index 0c5d9187a0..20fffaf2af 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/client.rpt @@ -56,7 +56,7 @@ connect await INIT_MIGRATE_SENT write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/server.rpt index 50d7bace4f..6985511349 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.unsubscribe.via.session.state/server.rpt @@ -53,7 +53,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/client.rpt index 56c3d90960..475d319c22 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/client.rpt @@ -188,7 +188,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/server.rpt index ed852ab2c7..6a94ceafa1 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.10k.abort.deliver.will/server.rpt @@ -190,7 +190,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/client.rpt index cc9a9f494d..175abe3f8a 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/client.rpt @@ -188,7 +188,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/server.rpt index 6b618ea998..3ccb56a839 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will.retain/server.rpt @@ -190,7 +190,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/client.rpt index b21d0d9550..2da8d3d277 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/client.rpt @@ -188,7 +188,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/server.rpt index 254ba8d3b1..22811efe8a 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.abort.deliver.will/server.rpt @@ -190,7 +190,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/client.rpt index e1f30e79db..817b6c1a8f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/client.rpt @@ -103,7 +103,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/server.rpt index 05d35c0392..16a7cfba85 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.clean.start/server.rpt @@ -103,7 +103,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/client.rpt index b825342e82..8c7b13309d 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/client.rpt @@ -174,7 +174,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/server.rpt index ae33b84729..351b8caddb 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.normal.disconnect/server.rpt @@ -173,7 +173,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/client.rpt index e233a0b86f..74a65f0e73 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/client.rpt @@ -188,7 +188,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/server.rpt index 6019ac10ae..a0be2a761f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.takeover.deliver.will/server.rpt @@ -190,7 +190,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/client.rpt index 70fe06ec70..68b227a578 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/client.rpt @@ -163,7 +163,7 @@ connect await SENT_INITIAL_MIGRATE_SIGNAL write zilla:begin.ext ${kafka:beginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/server.rpt index 9fe8fe5ce4..c9a082c223 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/session.will.message.will.id.mismatch.skip.delivery/server.rpt @@ -163,7 +163,7 @@ accepted read zilla:begin.ext ${kafka:matchBeginEx() .typeId(zilla:id("kafka")) .group() - .groupId("client-1-session") + .groupId("zilla:test-mqtt0-client-1-session") .protocol("highlander") .timeout(1000) .build() diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/client.rpt index db7deb6ca0..de153e4569 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/client.rpt @@ -82,7 +82,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -176,7 +176,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/server.rpt index 3cdb43bffd..bcbc9570bd 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.overlapping.wildcard.mixed.qos/server.rpt @@ -82,7 +82,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -177,7 +177,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/client.rpt index 3b0fd8ac48..824c066ba8 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/client.rpt @@ -55,7 +55,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/server.rpt index 2c2557a72b..88821e9c6a 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1.published.qos2/server.rpt @@ -55,7 +55,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/client.rpt index 2a56eb052b..706b0e8300 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/client.rpt @@ -55,7 +55,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/server.rpt index ee9d24fca4..49585fa027 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos1/server.rpt @@ -55,7 +55,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/client.rpt index a69d804085..2e02f04bc9 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/client.rpt @@ -55,7 +55,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -89,7 +89,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/server.rpt index 5fa79e6863..bb3cf4daba 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.message.qos2/server.rpt @@ -55,7 +55,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -87,7 +87,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/client.rpt index 9a163c068a..34ca570c6f 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/client.rpt @@ -73,7 +73,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -141,7 +141,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/server.rpt index 9170ccb85b..89fd7a8a61 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.receive.messages.mixture.qos/server.rpt @@ -75,7 +75,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -145,7 +145,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/client.rpt index 5491586816..75eb71eedd 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/client.rpt @@ -57,7 +57,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -147,7 +147,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/server.rpt index e1857b9bfc..98e5ebe124 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos1.unacked.message/server.rpt @@ -57,7 +57,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -141,7 +141,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/client.rpt index 6ea03c6f8e..77e749c090 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/client.rpt @@ -57,7 +57,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -93,7 +93,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -196,7 +196,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -231,7 +231,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/server.rpt index fef08595d9..052bff1ecc 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.incomplete.message/server.rpt @@ -57,7 +57,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -91,7 +91,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -189,7 +189,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -221,7 +221,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/client.rpt index 13394d3897..1183e456e7 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/client.rpt @@ -57,7 +57,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -93,7 +93,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -184,7 +184,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -219,7 +219,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/server.rpt index fef2858068..8e881de11b 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.reconnect.replay.qos2.unreceived.message/server.rpt @@ -57,7 +57,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -91,7 +91,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -177,7 +177,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -209,7 +209,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/client.rpt index 2b3cef30c2..18a12d7bfe 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/client.rpt @@ -93,7 +93,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -166,7 +166,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/server.rpt index 444ad61a23..aa91647649 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos1/server.rpt @@ -91,7 +91,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -163,7 +163,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/client.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/client.rpt index 4e6f38e92b..faaed22e95 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/client.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/client.rpt @@ -94,7 +94,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -133,7 +133,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -167,7 +167,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -262,7 +262,7 @@ write zilla:begin.ext ${kafka:beginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") diff --git a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/server.rpt b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/server.rpt index b96ddb2bf4..9ce6f74566 100644 --- a/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/server.rpt +++ b/specs/binding-mqtt-kafka.spec/src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/subscribe.replay.retained.message.qos2/server.rpt @@ -91,7 +91,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -128,7 +128,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -160,7 +160,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-retained") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor") @@ -254,7 +254,7 @@ read zilla:begin.ext ${kafka:matchBeginEx() .merged() .capabilities("FETCH_ONLY") .topic("mqtt-messages") - .groupId("client") + .groupId("zilla:test-mqtt0-client") .filter() .headers("zilla:filter") .sequence("sensor")