Zaimplementowałem operator do deserializacji z bajtu avro [] do obiektu. Następnie wysłałem obiekt do ConsoleOutputOperator. public final transient DefaultInputPort<byte[]> input = new DefaultInputPort<byte[]>() { @Override...

Mam DAG aplikacji Apache Apex, który odczytuje wiadomość RabbitMQ z kolejki. Którego operatora Apache Apex Malhar powinienem użyć? Istnieje kilka operatorów, ale nie jest jasne, którego użyć i jak go używać.

Aha, i jeśli powinno to zostać zrobione w wątku w tle (z wyłączeniem aktualizacji naszego interfejsu użytkownika), podczas pisania pojawia się paskudne opóźnienie...

Czy można dodać operator wejściowy dla innego źródła w działającej aplikacji Apex? Na przykład: W środowisku produkcyjnym używam aplikacji Apex do odczytu pliku tekstowego ze źródła wejściowego i chcę dodać źródło Kafki wraz z jego operatorem...