Можно ли установить часовой пояс при агрегировании, используя временное окно 24 часа

Question

Я хочу агрегировать какое-то значение, используя временное окно 24 часа, оно работает нормально, но временное окно с 00:00 до 23:59 по времени UTC позволяет установить часовой пояс так, чтобы начало и конец временного окнамое местное время (Пекин)?

Answer 1

В настоящее время (Kafka 2.0) поддержка часовых поясов отсутствует.Что вы можете сделать, это изменить, т. Е. Сдвинуть временные метки, прежде чем передать их в aggregation() и затем сдвинуть их обратно.

В зависимости от вашего приложения, для входных данных (не будет работать длявы можете использовать пользовательский TimestampExtractor.

. Вы также можете использовать оператор transfrom().В context.forward(...) вы можете установить временную метку соответственно (т.е. сдвиг вперед / назад) с помощью третьего параметра To.all().withTimestamp(...).