Существуют ли какие-либо аргументы sparklyr для возврата дополнительной информации журнала во время использования потоков kafka topi c с помощью R? - PullRequest
0 голосов
/ 28 мая 2020

После того, как удалось установить sh соединение с кафкой, при попытке потребить топи c ничего не возвращается, и мне любопытно, можно ли передать какие-либо соответствующие аргументы, чтобы получить дополнительные журналы о том, что происходит. Полоса прогресса появляется над моей консолью, и я чувствую, что все работает нормально. enter image description here

1 Ответ

0 голосов
/ 28 мая 2020

spark_log(sc, n = NULL) кажется, возвращает полезную информацию

...