AB
kafka_partition_dynamic[netflow]: true
kafka_partition_key[netflow]: $peer_src_ip
вот так делал, в итоге одна партиция выровнялась, но в остальных пилы остались
Size: a a a
AB
kafka_partition_dynamic[netflow]: true
kafka_partition_key[netflow]: $peer_src_ip
R
AK
AK
VA
VA
VK
VA
VK
VK
AS
AS
VA
AK
VA
AK
VK
AK
VK