0
我一直運行到以下錯誤:EasyMock的意外方法調用錯誤
org.apache.kafka.connect.runtime.distributed.DistributedHerderTest > testCreateConnector FAILED
java.lang.AssertionError:
Unexpected method call Worker.getConnectorType("sourceB"):
Worker.getPlugins(): expected: 3, actual: 0
at org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:44)
at org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:94)
at org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:97)
at org.apache.kafka.connect.runtime.Worker$$EnhancerByCGLIB$$124447d.getConnectorType(<generated>)
at org.apache.kafka.connect.runtime.distributed.DistributedHerderTest.testCreateConnector(DistributedHerderTest.java:344)
即使我提出:
EasyMock.expect(worker.getConnectorType(CONN2)).andReturn(ConnectorType.SOURCE);
代碼可以在這裏找到: https://github.com/apache/kafka/pull/3812
歡迎提供建議。