Chcę przeczytać plik dziennika w folderze znajdującym się na innym serwerze - hadoop, flume

Chcę odczytać plik dziennika z innego serwera w flume, który działa i działa na innym serwerze ....... aby to zrobić, jak mogę to osiągnąć, zmieniając mój flume-conf.properties plik ....... co mam napisać w pliku konfiguracyjnym flume, aby to osiągnąć

a1.sources = AspectJ
a1.channels = memoryChannel
a1.sinks = kafkaSink
a1.sources.AspectJ.type = com.flume.MySource
a1.sources.AspectJ.command = tail -F /tmp/data/Log.txt

za osiągnięcie tego, co powinienem napisać zamiast a1.sources.AspectJ.command = tail -F /tmp/data/Log.txt

Odpowiedzi:

Wierzę, że chcesz zapytać, czy jeśli Flume jest skonfigurowany na hoście „F”, a twoje pliki dziennika istnieją na hoście „L”, jak skonfigurujesz flume do odczytu plików dziennika z hosta „L”?

Jeśli tak, musisz ustawić Flume na hoście „L”, a nie na „F”. Ustaw flume na tym samym hoście, na którym znajdują się pliki dziennika, i skonfiguruj Sink, aby wskazywał na temat Kafka.