Skip to content

Commit

Permalink
change tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@bmaidics
bmaidics committed May 17, 2024
1 parent 069500b commit 5982129
Show file tree
Hide file tree
Showing 91 changed files with 197 additions and 197 deletions.
2 changes: 1 addition & 1 deletion .../aklivity/zilla/runtime/binding/mqtt/kafka/internal/stream/MqttKafkaSubscribeFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand Down
12 changes: 6 additions & 6 deletions ...s/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
12 changes: 6 additions & 6 deletions ...s/io/aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.mixture.qos/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
8 changes: 4 additions & 4 deletions .../zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
8 changes: 4 additions & 4 deletions .../zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.init.producer.abort/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
4 changes: 2 additions & 2 deletions .../aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down
4 changes: 2 additions & 2 deletions .../aklivity/zilla/specs/binding/mqtt/kafka/streams/kafka/publish.qos2.meta.abort/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down
12 changes: 6 additions & 6 deletions ...specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/client.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
12 changes: 6 additions & 6 deletions ...specs/binding/mqtt/kafka/streams/kafka/publish.qos2.offset.commit.abort.phase1/server.rpt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down Expand Up @@ -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")
Expand Down
Loading

0 comments on commit 5982129

Please sign in to comment.