Make sure that release build is working:
docker-compose build && docker-compose up -d
./run-producer.sh
./run-consumer.sh
- Play with them.
Change the package version to 0.11.3-ci-303
, rebuild container (docker-compose build
), try to run producer, get an exception:
$ ./run-producer.sh
docker-compose run dotnet dotnet Producer/bin/Release/netcoreapp2.0/Producer.dll kafka1:9092,kafka2:9092,kafka3:9092 test-topic
+ docker-compose run dotnet dotnet Producer/bin/Release/netcoreapp2.0/Producer.dll kafka1:9092,kafka2:9092,kafka3:9092 test-topic
Unhandled Exception: System.ArgumentException: Cannot bind to the target method because its signature or security transparency is not compatible with that of the delegate type.
at System.Reflection.RuntimeMethodInfo.CreateDelegateInternal(Type delegateType, Object firstArgument, DelegateBindingFlags bindingFlags, StackCrawlMark& stackMark)
at System.Reflection.RuntimeMethodInfo.CreateDelegate(Type delegateType)
at Confluent.Kafka.Impl.LibRdKafka.SetDelegates(Type nativeMethodsClass)
at Confluent.Kafka.Impl.LibRdKafka.Initialize(String userSpecifiedPath)
at Confluent.Kafka.Producer..ctor(IEnumerable`1 config, Boolean manualPoll, Boolean disableDeliveryReports)
at Confluent.Kafka.Producer`2..ctor(IEnumerable`1 config, ISerializer`1 keySerializer, ISerializer`1 valueSerializer, Boolean manualPoll, Boolean disableDeliveryReports)
at AenSidhe.Kafka.Test.Producer.Program.<MainAsync>d__1.MoveNext() in /app/Producer/Program.cs:line 31
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at AenSidhe.Kafka.Test.Producer.Program.Main(String[] args) in /app/Producer/Program.cs:line 25