Hi Team,

We started using NIFI data flow in our current project by replacing node js
tcp listeners. we are using nifi listenTCP processor.

our use case: we have some devices they will send message to tcp port, from
nifi we have to get message and then place data into kafka.

Processors we are using:

ListenTCP processor: to receive data from port and send to kafka topic

PutKafka: place data into kafka topic.

Problem we are facing:

from device side we have message delimiter as "$" but nifi listenTCP
processor is accepting only "/n". we changed the delimeter in nifi admin
its not reflecting.. by looking at nifi code we saw TCP_DELIMETER field as
final. then we changed that class with our delimiter its working fine..

Path:
https://github.com/apache/nifi/blob/master/nifi-commons/nifi-processor-utilities/src/main/java/org/apache/nifi/processor/util/listen/handler/socket/SocketChannelHandler.java

Is this expected behavior? or we missing something?.. if it is excepted
behavior is they any chance to change that modifiable field?.

Thanks,
Venkat

Reply via email to