Тесты Apache kafka дают дополнительные выходные данные при объединении таблиц

#apache-kafka #ksqldb

Вопрос:

Я тестирую свои потоки apache kafka с помощью ksql-test-runner, и после обновления образа docker с confluentinc/cp-ksqldb-cli:6.0.0 до confluentinc/cp-ksqldb-cli:7.0.0 у меня возникла следующая проблема:

Левые внешние соединения начали производить дополнительный вывод при соединении:

 lt;1, {accountId=1, firstName=FIRSTNAME, lastName=LASTNAME, country=COUNTRY, roleIds=null, jobTitle=TITLE, imageUrl=IMAGEURL, groupIds=null, id=1, department=DEPARTMENT, email=EMAIL, createDate=12222222}gt; with timestamp=0 lt;1, {accountId=1, firstName=FIRSTNAME, lastName=LASTNAME, country=COUNTRY, roleIds=null, jobTitle=TITLE, imageUrl=IMAGEURL, groupIds=[1], id=1, department=DEPARTMENT, email=EMAIL, createDate=12222222}gt; with timestamp=0 lt;1, {accountId=1, firstName=FIRSTNAME, lastName=LASTNAME, country=COUNTRY, roleIds=null, jobTitle=TITLE, imageUrl=IMAGEURL, groupIds=[1, 2], id=1, department=DEPARTMENT, email=EMAIL, createDate=12222222}gt; with timestamp=0  

но это должен быть только последний с groupIds=[1, 2]

 lt;1, {accountId=1, firstName=FIRSTNAME, lastName=LASTNAME, country=COUNTRY, roleIds=null, jobTitle=TITLE, imageUrl=IMAGEURL, groupIds=[1, 2], id=1, department=DEPARTMENT, email=EMAIL, createDate=12222222}gt; with timestamp=0  

Соединение выглядит следующим образом:

 FROM USERS_TBL USER LEFT OUTER JOIN USER_ROLES_TBL USER_ROLES_TBL ON ((USER.ID = USER_ROLES_TBL.USERID))  

Есть какие-нибудь идеи о том, как удалить промежуточный вывод?