About ravi_vagadiya4

ravi_vagadiya4 · ‎07-25-2017

@dbains Thanks for your answer. As of now, the request.timeout.ms=30000 and linger.ms=1 PublishKafka processor properties are as following: Kafka Brokers: 10.2.2.10:6667 Security Protocol: PLAINTEXT Topic Name: test_topic Delivery Guarantee: Best Effort Key Attribute Encoding: UTF-8 Encoded Max Request Size: 1 MB Acknowledgement Wait Time: 5 secs Max Metadata Wait Time: 5 secs Yes, we see same issue for all the topics we tried. Thanks.

ravi_vagadiya4 · ‎07-25-2017

Hi dbains, Thanks for your answer. As of now, the request.timeout.ms=30000 and linger.ms=1 PublishKafka processor properties are as following: Kafka Brokers: 10.2.2.10:6667 Security Protocol: PLAINTEXT Topic Name: test_topic Delivery Guarantee: Best Effort Key Attribute Encoding: UTF-8 Encoded Max Request Size: 1 MB Acknowledgement Wait Time: 5 secs Max Metadata Wait Time: 5 secs Yes, we see same issue for all the topics we tried. Thanks.

ravi_vagadiya4 · ‎07-24-2017

Hello All, We are sending some data from Nifi to Kafka topic using PublishKafka processor. We are getting the following error: PublishKafka Failed to send all messages for StandardFlowFileRecord to Kafka; routing to failure due to org.apache.kafka.common.errors.TimeoutException: Expiring 10 record(s) for test_topic:30011 ms has passed since batch creation plus linger time We have tried increasing the linger time and request.timeout.ms but still facing the issue. Any help would be appreciated.

Online	Offline
Last Visited	‎08-05-2017 06:15 AM

Member Since	‎07-05-2017 12:03 PM
Last Visited	‎08-05-2017 06:15 AM
Posts	6

Cloudera Community

Re: TimeoutException while sending data from Nifi ...

Re: TimeoutException while sending data from Nifi ...

TimeoutException while sending data from Nifi to K...