Skip to content

Commit 44afd88

Browse files
authored
CacheProduceIT.shouldRejectMessageValues nondeterministic failure in git actions fix (#845)
1 parent 74fb9b8 commit 44afd88

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaCacheServerProduceFactory.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1204,6 +1204,13 @@ private void doProduceInitialData(
12041204
final int deferred = remaining - length;
12051205
assert deferred >= 0 : String.format("%d >= 0", deferred);
12061206

1207+
if (messageOffset == 0 &&
1208+
length == 0 &&
1209+
deferred > 0)
1210+
{
1211+
break produce;
1212+
}
1213+
12071214
int flags = 0x00;
12081215
if (messageOffset == 0)
12091216
{

0 commit comments

Comments
 (0)