Hello NiFi Experts: I am getting time-out errors from the PutKafka processor when using the Guarantee Replicated Delivery option in the Guarantee Delivery property on NiFi 0.5.1 with Kafka 0.8.2 cluster. However, everything is working as normal when I switched to the Best Effort option. In addition, NiFi 0.4.1 works just fine with either option. Here's the error:
19:33:02 CDTERROR478f6a4f-4b79-4253-afe4-ecda8174df67 PutKafka[id=478f6a4f-4b79-4253-afe4-ecda8174df67] Failed to send StandardFlowFileRecord[uuid=ebceeeed-5220-45c0-a713-f3d68fac633f,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1458692540256-122, container=default, section=122], offset=110349, length=122],offset=0,name=1033351446389479,size=122] to Kafka; routing to 'failure'; last failure reason reported was org.apache.kafka.common.errors.TimeoutException: Batch Expired;: org.apache.kafka.common.errors.TimeoutException: Batch Expired Is this issue related to Joe's comment in the following thread: http://mail-archives.apache.org/mod_mbox/nifi-users/201603.mbox/%3CCALJK9a4h%3D_A-LZPsAvWaAKcGu3qR78fWh2572gDh53Z9LeuLFQ%40mail.gmail.com%3E Please advise. Thanks, Indus
