小编per*_*Dev的帖子

我有一个带有脚本任务的SSIS包,当我尝试在我的本地系统中运行它时出现以下错误.它适用于我的同事和生产.但是,我无法在本地运行它来进行测试.我在main方法中保留了一个调试点,但它永远不会到达,我在进入main方法之前得到了错误.

我正在使用VS 2010,.Net framework 4.5.

脚本任务确实编译.我得到以下消息SSIS包"..\Test.dtsx"开始.错误:测试时为0x1:调用目标引发了异常.任务失败:测试SSIS包"..\Test.dtsx"完成:成功.程序'[2552] DtsDebugHost.exe:DTS'已退出代码0(0x0).

以下是代码:

public void Main()
{
try
{
 LogMessages("Update Bug package execution started at :: " + DateTime.Now.ToLongTimeString());
 LogMessages("Loading package configuration values to local variables.");

strDBConn = Dts.Variables["User::DBConnection"] != null ? Dts.Variables["User::DBConnection"].Value.ToString() : string.Empty;
strTPCUrl = Dts.Variables["User::TPCUrl"] != null ? Dts.Variables["User::TPCUrl"].Value.ToString() : string.Empty;

TfsTeamProjectCollection objTPC = new TfsTeamProjectCollection(new Uri(strTPCUrl));
WorkItemStore objWIS = new WorkItemStore(objTPC);
WorkItemCollection objWIC = objWIS.Query("SELECT...");

foreach (WorkItem wi in objWIC)
{
}

}
catch(Exception ex)
{
}

当我评论来自TfsTeamProjectCollection的代码时objTPC = new TfsTeamProjectCollection(new …

我创建了一个自定义库(CodeLibrary),它在内部引用了dll Microsoft.TeamFoundation.Client和Microsoft.TeamFoundation.WorkItemTracking.Client.

我将此自定义Dll codelibrary.dll添加到我的SSRS报告中.以及其中一个字段的表达式

=codelibrary.codefunction.GetValue(1000)  

codefunction是类,GetValue是方法.

当我预览报告时,我收到错误"加载代码模块时出错:'CodeLibrary,Version = 1.0.0.0,Culture = neutral,PublicKeyToken = null'.无法加载文件或程序集'CodeLibrary,Version1.0.0.0, Culture = neutral,PublicKeyToken = null'或其中一个依赖项.系统找不到指定的文件."

我使用VS2013,我已将自定义库DLL放在路径C:\ Program Files\Microsoft Visual Studio 12.0\Common7\IDE\PrivateAssemblies中

我用WPF应用程序测试了自定义库,它工作正常.

我无法弄清楚导致此错误的原因.

我有一个反应式 kafka 应用程序，它从一个主题读取数据并写入另一个主题。该主题有多个分区，我想创建与主题中的分区相同数量的消费者（在同一消费者组中）。根据我对此线程的理解，.receive() 将仅创建一个 KafkaReceiver 实例，该实例将从主题中的所有分区中读取数据。所以我需要多个接收器并行地从不同的分区读取数据。

为此，我想出了以下代码：

@Bean
    public ReceiverOptions<String, String> kafkaReceiverOptions(String topic, KafkaProperties kafkaProperties) {
        ReceiverOptions<String, String> basicReceiverOptions = ReceiverOptions.create(kafkaProperties.buildConsumerProperties());
        return basicReceiverOptions.subscription(Collections.singletonList(topic))
                .addAssignListener(receiverPartitions -> log.debug("onPartitionAssigned {}", receiverPartitions))
                .addRevokeListener(receiverPartitions -> log.debug("onPartitionsRevoked {}", receiverPartitions));
    }

    @Bean
    public ReactiveKafkaConsumerTemplate<String, String> kafkaConsumerTemplate(ReceiverOptions<String, String> kafkaReceiverOptions) {
        return new ReactiveKafkaConsumerTemplate<String, String>(kafkaReceiverOptions);
    }

    @Bean
    public ReactiveKafkaProducerTemplate<String, List<Object>> kafkaProducerTemplate(
            KafkaProperties properties) {
        Map<String, Object> props = properties.buildProducerProperties();
        return new ReactiveKafkaProducerTemplate<String, List<Object>>(SenderOptions.create(props));
    }


public void run(String... args) {

        for(int i = 0; i < topicPartitionsCount ; …

我正在尝试模拟reactiveKafkaConsumerTemplate 的发送方法。

 @Mock
private ReactiveKafkaConsumerTemplate<String, String> reactiveKafkaConsumerTemplate;
@Mock
private ReactiveKafkaProducerTemplate<String, List<Object>> reactiveKafkaProducerTemplate;

 Mockito.when(reactiveKafkaConsumerTemplate.receiveAutoAck())
        .thenReturn(createConsumerRecords(2));



Mockito.when(reactiveKafkaProducerTemplate
.send(Mockito.anyString(),Mockito.anyString(),Mockito.anyList()))
                    .thenReturn(???);

我试图模拟reactiveProducerTemplate 的send 方法以返回SenderResult。可以这样做吗？如果是，有人可以指出我的文档/示例来执行此操作。我花了很多时间寻找解决方案，但找不到任何解决方案。

更新：我根据加里的建议尝试了以下操作

ProducerRecord<String, List<Object>> record 
= new  ProducerRecord<String, List<Object>>(topic,"key", objectSetup.setup());
RecordMetadata meta 
= new RecordMetadata(new TopicPartition("topic",0),0,0,0,(long)1,2,1);
 
Mockito.when(reactiveKafkaProducerTemplate.send(topic,"key",objectSetup.setup())
.thenReturn(Mono.just(new SendResult<>(record, meta))));

我在 .thenReturn(Mono.just(new SendResult<>(record, meta)))) 行收到以下异常。它没有提到异常中的 null 值，而且我没有看到任何 null 值。

java.lang.NullPointerException
    at com.ServiceTests.cTestMethod(ServiceTests.java:69)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
    at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
    at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
    at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
    at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
    at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
    at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
    at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
    at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
    at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) …