Я создаю автономное приложение с весенней загрузкой, которое должно получать сообщения с удаленного сервера и записывать их в Syslog Server. Я использую встроенный агент Flume для надежной регистрации сообщений. Но я получаю следующую ошибку.
Вызывается: org.apache.flume.FlumeException: тип компонента
com.security.flume.sink.SyslogSink не в разрешенных типах
[AVRO] в
org.apache.flume.agent.embedded.EmbeddedAgentConfiguration.checkAllowed (EmbeddedAgentConfiguration.java:308)
~ [flume-ng-embedded-agent-1.9.0.jar: 1.9.0] в
org.apache.flume.agent.embedded.EmbeddedAgentConfiguration.validate (EmbeddedAgentConfiguration.java:182)
~ [flume-ng-embedded-agent-1.9.0.jar: 1.9.0] в
org.apache.flume.agent.embedded.EmbeddedAgentConfiguration.configure (EmbeddedAgentConfiguration.java:199)
~ [flume-ng-embedded-agent-1.9.0.jar: 1.9.0] в
org.apache.flume.agent.embedded.EmbeddedAgent.doConfigure (EmbeddedAgent.java:151)
~ [flume-ng-embedded-agent-1.9.0.jar: 1.9.0] в
org.apache.flume.agent.embedded.EmbeddedAgent.configure (EmbeddedAgent.java:98)
~ [Желоб-нг встраиваемый-агент-1.9.0.jar: 1.9.0]
Согласно документации Embedded Agent поддерживает только Avro Sink. Означает ли это, что мы даже не можем написать собственный приемник?
Я довольно новичок во Флуме. Я очень ценю вашу помощь в этом вопросе.
Спасибо!