Max_partition_fetch_bytes not work

max_partition_fetch_bytes not work , i have big message in kafka (abount 150000b)。 i want to limit
to 500, and print it . i find max_partition_fetch_bytes config ,but it not work, it print is also big message

config

input {
kafka { bootstrap_servers => ["rizhi.zookeeper1:9092"]
group_id => "logstash"
codec => "json"
topics => ["rizhi_notice"]
auto_offset_reset => "latest"
decorate_events => true
max_partition_fetch_bytes => "1024"
send_buffer_bytes => "1024"
consumer_threads => 1
}
}

kafka data:

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.