我有一个运行的wso2流处理器代码,其中有6个不同的kafka主题,分别是@source和6个mysql数据库连接。
我可以接收5个主题中的数据,只有一个主题,但是如果我单独运行代码,同一个主题也可以工作。例子,
主题列表:主题1、主题2、主题3、主题4、主题5、主题6
专题2-6可以获取数据。
但是,如果我在wso2中作为一个独立的程序执行topic1,它可以获取数据,但当与所有其他主题作为一个程序执行时,它就不能了。
我无法找出任何可能的原因,任何关于如何解决这个问题的意见和想法?
我有一个运行的wso2流处理器代码,其中有6个不同的kafka主题,分别是@source和6个mysql数据库连接。
我可以接收5个主题中的数据,只有一个主题,但是如果我单独运行代码,同一个主题也可以工作。例子,
主题列表:主题1、主题2、主题3、主题4、主题5、主题6
专题2-6可以获取数据。
但是,如果我在wso2中作为一个独立的程序执行topic1,它可以获取数据,但当与所有其他主题作为一个程序执行时,它就不能了。
我无法找出任何可能的原因,任何关于如何解决这个问题的意见和想法?
1条答案
按热度按时间jfewjypa1#
我得到的问题,这是因为我的本地系统无法处理流式数据加载和它正在内存不足,虽然没有显示错误。如果我减少数据量,它就可以正常工作。