i'm tring to receive a tcp stream using the listentcp module, but when the
connection start, i see the traffic reaching my server (usgin tcpdump), but
the nifi does note generate a flow file.
Ther is no error ow warning in the module or in the nifi cluster.
Changing in the processor the bulleting level to "debug" , i can see the
following message for every package that i receive:
SPOLPAVMW131:8080ListenTCP[id=e083186d-017e-1000-0000-000040efa66e]
Accepted incoming connection from /192.0.2.12:55209
SPOLPAVMW131:8080ListenTCP[id=e083186d-017e-1000-0000-000040efa66e] bytes
read 46
SPOLPAVMW131:8080ListenTCP[id=e083186d-017e-1000-0000-000040efa66e] No more
data available, returning for selection
SPOLPAVMW131:8080ListenTCP[id=e083186d-017e-1000-0000-000040efa66e] Reached
EOF, closing connection
bellow is the same message, but in the tcpdump format.
Internet Protocol Version 4, Src: 192.0.2.12, Dst: 192.0.2.128
Transmission Control Protocol, Src Port: 55209 , Dst Port: 4737, Seq: 1,
Ack: 1, Len: 46
Source Port: 55209
Destination Port: 4737
<Source or Destination Port: 55209 >
<Source or Destination Port: 4737>
[Stream index: 0]
[TCP Segment Len: 46]
Sequence number: 1 (relative sequence number)
Sequence number (raw): 3765145522
[Next sequence number: 47 (relative sequence number)]
Acknowledgment number: 1 (relative ack number)
Acknowledgment number (raw): 274707205
0101 .... = Header Length: 20 bytes (5)
Flags: 0x018 (PSH, ACK)
Window size value: 10000
[Calculated window size: 10000]
[Window size scaling factor: 1]
Checksum: 0x5fd7 [unverified]
[Checksum Status: Unverified]
Urgent pointer: 0
[SEQ/ACK analysis]
[Timestamps]
TCP payload (46 bytes)
[PDU Size: 46]
IPDR
Version: 2
Message id: CONNECT (5)
Session id: 0
Message flags: 0x00
Message length: 46
Initiator id: 0.0.0.0
Initiator port: 0
Capabilities: 0x00000006
Keep-alive interval: 90
Vendor id: ARRIS E6000 Exporter
Here somethings that i tried:
- Increase the number of simultaneos connections and batch size, but it
does not change at all.
- Use listentcprecord but the behavior is the same, it only change when i
select the avroreader, then i got an error informing that is a "wrong data
format".
So i belive that nifi is receving the messages that come from tcp , but for
some reason is not generating flowfiles.
Does anyone got same behavior ?
There is anything else that i can do ?
i'm using nifi 1.15.3 with a 4 nodes cluster.
Breno
