Может ли apache avro записываться в сеть?

Question

Я пытаюсь написать огромное количество журналов в hdfs. Для этого я использую flume с hdfs как приемник и avro в качестве источника. Мне нужно сделать сериализацию моих журналов, используя avro по сети, чтобы мой лоток. Источник транспортере сконфигурирован как:

a1.sources = r1 
a1.channels = c1 
a1.sources.r1.type = avro 
a1.sources.r1.channels = c1 
a1.sources.r1.bind = 0.0.0.0 
a1.sources.r1.port = 4141 

EDIT: кодовый блок фиксированной

Answer 1

Использование Flume-х RpcClient:

RpcClient client = RpcClientFactory.getDefaultInstance(host, 4141); 
client.append(EventBuilder.withBody(message)); 
client.close();