flume的java代码,flume java

flume 在配置source 访问netcat 的时候，java怎么创建socket发送数据给netcat接收

etcat-0.7.1.tar.gz 然后当然是解压了 tar zxvf netcat-0.7.1.tar.gz 解压完毕之后会生成目录，要cd进去 cd netcat-0.7.1 然后进行编译前的配置。 ./configure 配置完了之后就可以make编译了。 编译成功就生成了netcat可执行的文件了

相关问答

Q1: flume-ng的数据传输功能怎么通过java代码的形式进行实现

TCP传输需要建立客户端和服务器端，即Socket和Server Socket ， 建立连接后，通过Socket中的IO流进行数据的传输 。传输结束后关闭Socket。

客户端和服务器端是两个独立的应用程序。

Q2: 在flume中采集数据时，stop后，在start重新采集，出现java.io.IOException: Write error？

你好，不知道你stop的时候有没有把相应的IO或者句柄关掉？

最好把代码贴出来看下！

Q3: 求助flume + kafka 异常 java.nio.BufferUnderflowException

求助flume + kafka 异常 java.nio.BufferUnderflowException

缓冲的长度不匹配，，，，，，，，，使用短缓冲，接收/处理 长缓冲

框架处理原理分析：可以根据实际情况，设置buffersize的大小，让buffersize处在平均略高的状态下工作，节省由于初始设置过大，而浪费内存。

解决方案：

1，最简单的修改框架原码。将其中的NioSocketSession类重写即可，里面有TransportMetadata创建的地方修改。

2，通过对断包或粘包的处理。