About shailendra1_loh

shailendra1_loh · ‎09-11-2018

@Rajkumar Singh Can we override these value in PublishKafka processor instead of making change at broker/producer level? If no, then why this "PublishKafka_0_10 1.5.0.3.1.0.0-564" processor in NiFi has field "Max Request Size" which allow us to modify. Default value of this field is 1MB. Thanks!

shailendra1_loh · ‎07-18-2018

Thank you @Matt Clarke to give detailed answer! It really helped me to understand the use of "container queue size" configuration. Though one more question I have. Is there a way, I can find, how many queue are being created? This would help me to determine queue size needed for my application. Thanks for your help! Regards Shailendra

shailendra1_loh · ‎07-17-2018

I am using HandleHttpRequest processor to ingest my data. In this processor, I configured Container Queue Size property as 30K. Can it cause a heap memory issue? Default value is 50. Also, there is one known issue in HandleHTTPReqeust processor reported here "https://issues.apache.org/jira/browse/NIFI-4959" and fix is available in HDF 3.2. Currently, we are not in state of upgrading our HDF version. Is there any alternative to HandleHTTPRequest processor?

shailendra1_loh · ‎08-29-2017

There are two different topic and each topic have 30 partitions and two different producer is producing data in these topics. Also, there are two different kafka consumer but with same group Id. Will it create any problem? Also, how many consumer instance will be created under one group id? Please help me to understand this.

shailendra1_loh · ‎08-29-2017

Thank you! It worked for me.

shailendra1_loh · ‎08-25-2017

I do not want to send content of incoming flowfile rather I would like set my own response body which will be static.

shailendra1_loh · ‎08-25-2017

Currently, I am using HandleHttpResponse processor to set http status code but I also want to send static body. I tried to add property but it is not working. Can anyone help me out with some pointers on what to try?

Online	Offline
Last Visited	‎11-27-2018 08:38 PM

Member Since	‎07-12-2017 03:29 AM
Last Visited	‎11-27-2018 08:38 PM
Posts	9
Kudos received	1

Cloudera Community

Re: Kafka producer running into multiple org.apach...

Re: I am using HandleHttpRequest processor to ing...

I am using HandleHttpRequest processor to ingest ...

Can I use same consumer group Id for two different...

Re: How can I set static response using HandleHttp...

Re: How can I set static response using HandleHttp...

How can I set static response using HandleHttpResp...