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

Я пытаюсь записать огромное количество журналов в 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

РЕДАКТИРОВАТЬ: фиксированный блок кода


avro flume
person Ramandeep Singh    schedule 04.12.2013    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Используйте RpcClient от Flume. :

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