[ 
https://issues.apache.org/jira/browse/NIFI-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18014196#comment-18014196
 ] 

Zenkovac commented on NIFI-14864:
---------------------------------

tried setting those values to 1 or 10MB but still the same.

I can see from logs that those values are ok by default:
fetch.max.bytes = 52428800
max.partition.fetch.bytes = 1048576

i'll see if i can spin up a kafka 3 server to test performance.

> ConsumeKafka performance
> ------------------------
>
>                 Key: NIFI-14864
>                 URL: https://issues.apache.org/jira/browse/NIFI-14864
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Configuration
>    Affects Versions: 2.5.0
>         Environment: nifi 2.5, kafka server 2.8
>            Reporter: Zenkovac
>            Priority: Major
>
> switching from nifi 1.19 to 2.5 and using ConsumeKafka cant get to consume 
> flowfiles with more than ~500 records per flowfile despite having millions of 
> messages available in kafka topic.
> This has a penalty performance for me because I consume thousands of 
> flowfiles vs a few in nifi 1.19 which means less disc i/o usage.
> this is my config:
> *Processing Strategy: RECORD*
> *Max Uncommitted Time* 10 sec



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to