J'ai une topologie en construction utilisant streamparse, il reçoit des entrées de kafka et plus tard le bec transmet le message au maître boulon, le maître boulon calcule et génère 10 Mo de message et ce message doit être transmis à 3 autres boulons.

Les données sont générées avec succès dans le boulon maître, mais obtiennent l'erreur suivante lors du transfert vers l'autre boulon.

ERROR Unable to write to stream UDP:localhost:514 for appender syslog: org.apache.logging.log4j.core.appender.AppenderLoggingException: Error flushing stream UDP:localhost:514

0
Bimal Gangawal 4 nov. 2019 à 16:26

1 réponse

Le journal que vous avez publié ne semble avoir rien à voir avec la taille du message. Cela signifie qu'il ne peut pas écrire de journal sur localhost: 514. Peut-être que votre journalisation est mal configurée?

Pour autant que je sache, la taille maximale des messages est uniquement déterminée par la taille maximale de votre tas, elle dépendra donc de votre configuration RAM et JVM. Je serais surpris si vous atteignez une limite de 10 Mo.

0
Stig Rohde Døssing 4 nov. 2019 à 17:27