Я использую приложение-агрегатор SCDF для агрегирования сообщений на основе поля и просто освобождаю их по истечении установленного времени ожидания группы.В документации к агрегатору указано, что по умолчанию оно выпускает коллекцию полезных нагрузок.Итак, я не изменил свойство агрегации или что-то еще.
Но вместо того, чтобы возвращать коллекцию полезных нагрузок, я получаю эту строку как вывод [[B @ U89, [B @ 54UT].Если я добавлю #this в свойство aggregate, он вернет строку заголовков сообщений через запятую. Но # this.payload ничего не печатает.Есть ли способ, которым я могу явно указать свойство агрегации для возврата коллекции полезных нагрузок, используя выражения Spel?
Созданный мною поток:
http --port=9000 | aggregator --group-timeout=10000 --correlation=#jsonPath(payload,'payload.INVOICE_ID') -- aggregation=#this| log
Я отправляю сообщения json.Поэтому, если я отправлю { "empID" : 12 , "name":"John"} и { "empID" : 12, "age":30 } и агрегирую их на основе empID, я ожидаю, что агрегатор должен вернуть что-то вроде: [{ "empID" : 12 , "name":"John"} , { "empID" : 12 , "name":"John"} ], но вместо этого я получу что-то вроде этого [[B @ U89, [B @ 54UT].