Я писал PO C при длинном опросе, используя go. Я вижу общий пакет для использования https://github.com/jcuga/golongpoll. Но при условии, что я хотел бы опубликовать sh событие в golongpoll.SubscriptionManager из общего контекста, особенно когда существует вероятность того, что длинный запрос API опроса обслуживается одной машиной, в то время как событие Kafka для этого конкретного потребителя group используется другим экземпляром в кластере.
Примеры, приведенные в документации, вообще не говорили о таком сценарии, даже если это кажется распространенным сценарием. Один из способов, который я могу придумать, - это иметь распределенный кеш, такой как Redis между ними, и все службы опрашивают его для изменения? Но это звучит немного глупо для меня.