#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))
Есть какие-нибудь идеи о том, как удалить промежуточный вывод?