Skip to content

GRPC DaprClient unable to connect to Dapr #210

Description

@RicardoNiepel

Environment

PS C:\Sources\dapr-java-sdk> mvn -v
  Apache Maven 3.6.3 (cecedd343002696d0abb50b32b541b8a6ba2883f)
  Maven home: C:\Program Files\apache-maven-3.6.3\bin\..
  Java version: 11.0.6, vendor: AdoptOpenJDK, runtime: C:\Users\riniepel\AppData\Local\Programs\AdoptOpenJDK
  Default locale: de_DE, platform encoding: Cp1252
  OS name: "windows 10", version: "10.0", arch: "amd64", family: "windows"
PS C:\Sources\dapr-java-sdk>dapr --version
  CLI version: 0.3.0
  Runtime version: 0.3.0

Branch: release-0.2.0-beta

Expected Behavior

The Method invocation GRPC sample should be possible to follow and start the HelloWorldService and HelloWorldClient without any errors.

Actual Behavior

Starting the HelloWorldClient brings the following error

The HelloWorldClient was unable to connect to Dapr:
== APP == java.lang.RuntimeException: java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:52772
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:214)
== APP ==     at reactor.core.publisher.MonoCallable.call (MonoCallable.java:91)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:126)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.invoke.grpc.HelloWorldClient.main (HelloWorldClient.java:35)

But I was able to send manually a POST successful to
http://localhost:52772/v1.0/invoke/hellogrpc/method/say
at the same time

Steps to Reproduce the Problem

Start HelloWorldService and HelloWorldClient.

Logs / Output

HelloWorldService

dapr run --app-id hellogrpc --app-port 5000 --protocol grpc -- mvn exec:java  -D exec.mainClass=io.dapr.examples.invoke.grpc.HelloWorldService -D exec.args="-p 5000"
Starting Dapr with id hellogrpc. HTTP Port: 52654. gRPC Port: 52655
You're up and running! Both Dapr and your app logs will appear here.

== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="starting Dapr Runtime -- version 0.3.0 -- commit v0.3.0-rc.0-1-gfe6c306-dirt
y"
    == DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="log level set to: info"
== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="standalone mode configured"
== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="dapr id: hellogrpc"
== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="loaded component sample123 (bindings.kafka)"
    == DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="loaded component statestore (state.redis)"
== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="loaded component messagebus (pubsub.redis)"
== DAPR == time="2020-02-05T13:29:47+01:00" level=info msg="application protocol: grpc. waiting on port 5000"
== APP == [INFO] Scanning for projects...
== APP == [WARNING]
== APP == [WARNING] Some problems were encountered while building the effective model for io.dapr:dapr-sdk-examples:jar:0.2.0-beta-1ta-1

== APP == [WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-deploy-plugin is missing. @ line 130, column 1
5
== APP == [WARNING]
== APP == [WARNING] It is highly recommended to fix these problems because they threaten the stability of your build.
== APP == [WARNING]
== APP == [WARNING] For this reason, future Maven versions might no longer support building such malformed projects.
== APP == [WARNING]
== APP == [INFO] Inspecting build with total of 1 modules...
== APP == [INFO] Installing Nexus Staging features:
== APP == [INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plugin
== APP == [INFO]
== APP == [INFO] ---------------------< io.dapr:dapr-sdk-examples >----------------------
== APP == [INFO] Building dapr-sdk-examples 0.2.0-beta-1
== APP == [INFO] --------------------------------[ jar ]---------------------------------
== APP == [INFO]
== APP == [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dapr-sdk-examples ---
== APP == 13:29:57.465 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.log
ging.InternalLoggerFactory - Using SLF4J as the default logging framework
== APP == 13:29:57.469 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - Platform: Windows
== APP == 13:29:57.472 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - -Dio.netty.noUnsafe: false
== APP == 13:29:57.472 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - Java version: 11
== APP == 13:29:57.473 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - sun.misc.Unsafe.theUnsafe: available
== APP == 13:29:57.474 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - sun.misc.Unsafe.copyMemory: available
== APP == 13:29:57.475 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - java.nio.Buffer.address: available
== APP == 13:29:57.480 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - direct buffer constructor: unavailable
== APP == java.lang.UnsupportedOperationException: Reflective setAccessible(true) disabled
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.ReflectionUtil.trySetAccessible(ReflectionUtil.java:31)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent0$4.run(PlatformDependent0.java:224)
== APP ==    at java.base/java.security.AccessController.doPrivileged(Native Method)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent0.<clinit>(PlatformDependent0.java:218)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.isAndroid(PlatformDependent.java:272)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.<clinit>(PlatformDependent.java:92)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<init>(AsciiString.java:222)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<init>(AsciiString.java:209)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.cached(AsciiString.java:1406)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<clinit>(AsciiString.java:47)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.Utils.<clinit>(Utils.java:69)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder.<clinit>(NettyServerBuilder.java:77)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerProvider.builderForPort(NettyServerProvider.java:39)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerProvider.builderForPort(NettyServerProvider.java:24)
== APP ==    at io.grpc.ServerBuilder.forPort(ServerBuilder.java:41)
== APP ==    at io.dapr.examples.invoke.grpc.HelloWorldService$GrpcHelloWorldDaprService.start(HelloWorldService.java:61)
== APP ==    at io.dapr.examples.invoke.grpc.HelloWorldService.main(HelloWorldService.java:145)
== APP ==    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
== APP ==    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
== APP ==    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
== APP ==    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
== APP ==    at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)
== APP ==    at java.base/java.lang.Thread.run(Thread.java:834)
== APP == 13:29:57.482 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - java.nio.Bits.unaligned: available, true
== APP == 13:29:57.484 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable
== APP == java.lang.IllegalAccessException: class io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent0$6 cannot access cla
ss jdk.internal.misc.Unsafe (in module java.base) because module java.base does not export jdk.internal.misc to unnamed module @443eba43       
== APP ==    at java.base/jdk.internal.reflect.Reflection.newIllegalAccessException(Reflection.java:361)
== APP ==    at java.base/java.lang.reflect.AccessibleObject.checkAccess(AccessibleObject.java:591)
== APP ==    at java.base/java.lang.reflect.Method.invoke(Method.java:558)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent0$6.run(PlatformDependent0.java:334)
== APP ==    at java.base/java.security.AccessController.doPrivileged(Native Method)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent0.<clinit>(PlatformDependent0.java:325)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.isAndroid(PlatformDependent.java:272)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.<clinit>(PlatformDependent.java:92)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<init>(AsciiString.java:222)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<init>(AsciiString.java:209)
== APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.cached(AsciiString.java:1406)
    == APP ==    at io.grpc.netty.shaded.io.netty.util.AsciiString.<clinit>(AsciiString.java:47)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.Utils.<clinit>(Utils.java:69)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder.<clinit>(NettyServerBuilder.java:77)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerProvider.builderForPort(NettyServerProvider.java:39)
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.NettyServerProvider.builderForPort(NettyServerProvider.java:24)
== APP ==    at io.grpc.ServerBuilder.forPort(ServerBuilder.java:41)
== APP ==    at io.dapr.examples.invoke.grpc.HelloWorldService$GrpcHelloWorldDaprService.start(HelloWorldService.java:61)
== APP ==    at io.dapr.examples.invoke.grpc.HelloWorldService.main(HelloWorldService.java:145)
== APP ==    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
== APP ==    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
== APP ==    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    == APP ==    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
== APP ==    at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)
== APP ==    at java.base/java.lang.Thread.run(Thread.java:834)
== APP == 13:29:57.484 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent0 - java.nio.DirectByteBuffer.<init>(long, int): unavailable
== APP == 13:29:57.484 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - sun.misc.Unsafe: available
    == APP == 13:29:57.510 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - maxDirectMemory: 4276092928 bytes (maybe)
== APP == 13:29:57.510 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - -Dio.netty.tmpdir: C:\Users\riniepel\AppData\Local\Temp (java.io.tmpdir)
== APP == 13:29:57.510 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
== APP == 13:29:57.511 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - -Dio.netty.maxDirectMemory: -1 bytes
== APP == 13:29:57.511 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - -Dio.netty.uninitializedArrayAllocationThreshold: -1
    == APP == 13:29:57.514 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Cle
anerJava9 - java.nio.ByteBuffer.cleaner(): available
== APP == 13:29:57.515 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - -Dio.netty.noPreferDirect: false
== APP == 13:29:57.630 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.channel.Multithre
adEventLoopGroup - -Dio.netty.eventLoopThreads: 16
    == APP == 13:29:57.654 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Int
ernalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
    == APP == 13:29:57.654 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Int
ernalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
    == APP == 13:29:57.661 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.channel.nio.NioEv
entLoop - -Dio.netty.noKeySetOptimization: false
== APP == 13:29:57.661 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.channel.nio.NioEv
entLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
== APP == 13:29:57.668 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.internal.Pla
tformDependent - org.jctools-core.MpscChunkedArrayQueue: available
    == APP == 13:29:58.086 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.channel.DefaultCh
annelId - -Dio.netty.processId: 37784 (auto-detected)
    == APP == 13:29:58.089 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.NetUtil - -D
java.net.preferIPv4Stack: false
    == APP == 13:29:58.089 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.NetUtil - -D
java.net.preferIPv6Addresses: false
    == APP == 13:29:58.440 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.NetUtil - Lo
opback interface: lo (Software Loopback Interface 1, 127.0.0.1)
    == APP == 13:29:58.441 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.NetUtil - Fa
iled to get SOMAXCONN from sysctl and file \proc\sys\net\core\somaxconn. Default: 200
    == APP == 13:29:58.761 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.channel.DefaultCh
annelId - -Dio.netty.machineId: 00:00:00:00:00:00:00:e0 (auto-detected)
    == APP == 13:29:58.772 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.ResourceLeak
Detector - -Dio.grpc.netty.shaded.io.netty.leakDetection.level: simple
== APP == 13:29:58.772 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.util.ResourceLeak
Detector - -Dio.grpc.netty.shaded.io.netty.leakDetection.targetRecords: 4
    == APP == 13:29:58.801 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.numHeapArenas: 16
== APP == 13:29:58.801 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.numDirectArenas: 16
== APP == 13:29:58.801 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.pageSize: 8192
== APP == 13:29:58.801 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.maxOrder: 11
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.chunkSize: 16777216
    == APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
    == APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.smallCacheSize: 256
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.normalCacheSize: 64
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
    == APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
== DAPR == time="2020-02-05T13:29:58+01:00" level=info msg="application discovered on port 5000"
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.cacheTrimIntervalMillis: 0
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.useCacheForAllThreads: true
== APP == 13:29:58.802 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.PooledByte
BufAllocator - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
== APP == 13:29:58.812 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.ByteBufUti
l - -Dio.netty.allocator.type: pooled
== DAPR == 2020-02-05 13:29:58.927107 I | redis: connecting to localhost:6379
== DAPR == 2020-02-05 13:29:58.930112 I | redis: connected to localhost:6379 (localAddr: [::1]:52736, remAddr: [::1]:6379)
== APP == 13:29:58.812 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.ByteBufUti
l - -Dio.netty.threadLocalDirectBufferSize: 0
== APP == 13:29:58.812 [io.dapr.examples.invoke.grpc.HelloWorldService.main()] DEBUG io.grpc.netty.shaded.io.netty.buffer.ByteBufUti
l - -Dio.netty.maxThreadLocalCharBufferSize: 16384
== APP == Server: started listening on port 5000
    == APP == 13:29:58.994 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.buffer.AbstractByteBuf - -Dio.grpc.netty.shaded
.io.netty.buffer.checkAccessible: true
    == APP == 13:29:58.994 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.buffer.AbstractByteBuf - -Dio.grpc.netty.shaded
.io.netty.buffer.checkBounds: true
== APP == 13:29:58.995 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.util.ResourceLeakDetectorFactory - Loaded defau
lt ResourceLeakDetector: io.grpc.netty.shaded.io.netty.util.ResourceLeakDetector@648c248c
    == APP == 13:29:59.085 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xa2710853, L:/0
:0:0:0:0:0:0:1:5000 - R:/0:0:0:0:0:0:0:1:52733] OUTBOUND SETTINGS: ack=false settings={MAX_CONCURRENT_STREAMS=2147483647, INITIAL_WINDOW_SIZE=1048576, MAX_HEADER_LIST_SIZE=8192}
    == APP == 13:29:59.085 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND SETTINGS: ack=false settings={MAX_CONCURRENT_STREAMS=2147483647, INITIAL_WINDOW_SIZE=1048576, MAX_HEADER_LIST_SIZE=8192}
== APP == 13:29:59.090 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity
PerThread: 4096
== APP == 13:29:59.090 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.util.Recycler - -Dio.netty.recycler.maxSharedCa
pacityFactor: 2
== APP == 13:29:59.090 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.util.Recycler - -Dio.netty.recycler.linkCapacit
y: 16
== APP == 13:29:59.090 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.util.Recycler - -Dio.netty.recycler.ratio: 8   
    == APP == 13:29:59.113 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=983041
    == APP == 13:29:59.113 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xa2710853, L:/0
:0:0:0:0:0:0:1:5000 - R:/0:0:0:0:0:0:0:1:52733] OUTBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=983041
== APP == 13:29:59.127 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xa2710853, L:/0
:0:0:0:0:0:0:1:5000 - R:/0:0:0:0:0:0:0:1:52733] OUTBOUND GO_AWAY: lastStreamId=0 errorCode=2 length=86 bytes=45696e6520626573746568656e64652056657262696e64756e6720777572646520736f6674776172656765737465756572740d0a64757263682064656e20486f...
== APP == 13:29:59.129 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND SETTINGS: ack=false settings=[id: 0xc1e23417, L:/127.0.0.1:5000 - R:/127.0.0.1:52735]
== APP == 13:29:59.129 [grpc-nio-worker-ELG-3-1] DEBUG io.grpc.netty.shaded.io.netty.handler.codec.http2.Http2ConnectionHandler - [i
d: 0xa2710853, L:/0:0:0:0:0:0:0:1:5000 ! R:/0:0:0:0:0:0:0:1:52733] Sending GOAWAY failed: lastStreamId '0', errorCode '2', debugData 'Eine bestehende Verbindung wurde softwaregesteuert
== APP == durch den Hostcomputer abgebrochen'. Forcing shutdown of the connection.
== APP == java.io.IOException: Eine bestehende Verbindung wurde softwaregesteuert
== APP == durch den Hostcomputer abgebrochen
== APP ==    at java.base/sun.nio.ch.SocketDispatcher.writev0(Native Method)
== APP ==    at java.base/sun.nio.ch.SocketDispatcher.writev(SocketDispatcher.java:55)
== APP ==    at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:182)
== APP ==    at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:130)
== APP ==    at java.base/sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:496)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:420)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:354)  
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:898)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1384)    
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:
749)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:7
41)
    == APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:727)
== APP ==    at io.grpc.netty.shaded.io.netty.handler.codec.http2.Http2ConnectionHandler.onError(Http2ConnectionHandler.java:643)   
== APP ==    at io.grpc.netty.shaded.io.grpc.netty.AbstractNettyHandler.exceptionCaught(AbstractNettyHandler.java:81)
    == APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerCont
ext.java:297)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerCont
ext.java:276)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.fireExceptionCaught(AbstractChannelHandlerContex
t.java:268)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.exceptionCaught(DefaultChannelPipeline.java
:1389)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerCont
ext.java:297)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerCont
ext.java:276)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline.fireExceptionCaught(DefaultChannelPipeline.java:919)   
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.handleReadException(AbstractNioByteCh
annel.java:125)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:174)

== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:700)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:635)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:552)
== APP ==    at io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:514)
== APP ==    at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044)  4)
== APP ==    at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
== APP ==    at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
== APP ==    at java.base/java.lang.Thread.run(Thread.java:834)
== APP == 13:29:59.130 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND SETTINGS: ack=true
== APP == 13:29:59.153 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND SETTINGS: ack=true
== APP == 13:29:59.165 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND HEADERS: streamId=1 headers=GrpcHttp2RequestHeaders[:path: /daprclient.DaprClient/GetTopicSubscriptions, :authority: 127.0.0.1:5000, :method: POST, :scheme: http, te: trailers, content-type: application/grpc, user-agent: grpc-go/1.24.0] padding=0 endStream=false
== APP == 13:29:59.194 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND DATA: streamId=1 padding=0 endStream=true length=5 bytes=0000000000
== APP == 13:29:59.247 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=1 headers=GrpcHttp2OutboundHeaders[:status: 200, content-type: application/grpc, grpc-status: 12, grpc-message: Method daprclient.DaprClient/GetTopicSubscriptions is unimplemented] streamDependency=0 weight=16 exclusive=false padding=0 endStream=true
== DAPR == time="2020-02-05T13:29:59+01:00" level=info msg="Initialized service discovery to standalone"
== DAPR == time="2020-02-05T13:30:09+01:00" level=warning msg="failed to init output binding bindings.kafka: kafka: client has run oun o
ut of available brokers to talk to (Is your cluster reachable?)"
== APP == 13:30:09.225 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND HEADERS: streamId=3 headers=GrpcHttp2RequestHeaders[:path: /daprclient.DaprClient/GetBindingsSubscriptions, :authority: 127.0.0.1:5000, :method: POST, :scheme: http, te: trailers, content-type: application/grpc, user-agent: grpc-go/1.24.0] padding=0 endStream=false
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: starting connection attempt to placement service at localhost:60t:60
50"
== APP == 13:30:09.227 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND DATA: streamId=3 padding=0 endStream=true length=5 bytes=0000000000
== APP == 13:30:09.229 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=3 headers=GrpcHttp2OutboundHeaders[:status: 200, content-type: application/grpc, grpc-status: 12, grpc-message: Method daprclient.DaprClient/GetBindingsSubscriptions is unimplemented] streamDependency=0 weight=16 exclusive=false padding=0 endStream=true
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actor runtime started. actor idle timeout: 1h0m0s. actor scan interval: 
30s"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="http server is running on port 52654"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="gRPC server is running on port 52655"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="local service entry announced"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="dapr initialized. Status: Running. Init Elapsed 21846.2997ms"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: established connection to placement service at localhost:6050"  
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: placement order received: lock"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: placement order received: update"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: placement tables updated"
== DAPR == time="2020-02-05T13:30:09+01:00" level=info msg="actors: placement order received: unlock"
== APP == 13:31:18.658 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND HEADERS: streamId=5 headers=GrpcHttp2RequestHeaders[:path: /daprclient.DaprClient/OnInvoke, :authority: 127.0.0.1:5000, :method: POST, :scheme: http, te: trailers, content-type: application/grpc, user-agent: grpc-go/1.24.0, grpc-timeout: 60000000u] padding=0 endStream=false
== APP == 13:31:18.661 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND DATA: streamId=5 padding=0 endStream=true length=27 bytes=00000000160a03736179120f120d4869204d75737465726d616e6e
== APP == Server: Hi Mustermann @ 2020-02-05 13:31:18.715
== APP == 13:31:18.793 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=5 headers=GrpcHttp2OutboundHeaders[:status: 200, content-type: application/grpc, grpc-encoding: identity, grpc-accept-encoding: gzip] streamDependency=0 weight=16 exclusive=false padding=0 endStream=false
== APP == 13:31:18.808 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND DATA: streamId=5 padding=0 endStream=false length=78 bytes=00000000490a2c747970652e676f6f676c65617069732e636f6d2f646170726578616d706c65732e536179526573706f6e736512190a17323032302d30322d30...
== APP == 13:31:18.809 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=5 headers=GrpcHttp2OutboundHeaders[grpc-status: 0] streamDependency=0 weight=16 
exclusive=false padding=0 endStream=true
== APP == 13:31:18.810 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=78
== APP == 13:31:18.810 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND PING: ack=false bytes=145258749040133895
== APP == 13:31:18.810 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND PING: ack=true bytes=145258749040133895
    == APP == 13:31:29.944 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND HEADERS: streamId=7 headers=GrpcHttp2RequestHeaders[:path: /daprclient.DaprClient/OnInvoke, :authority: 127.0.0.1:5000, :method: POST, :scheme: http, te: trailers, content-type: application/grpc, user-agent: grpc-go/1.24.0, grpc-timeout: 60000000u] padding=0 endStream=false
    == APP == 13:31:29.944 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND DATA: streamId=7 padding=0 endStream=true length=27 bytes=00000000160a03736179120f120d4869204d75737465726d616e6e
    == APP == Server: Hi Mustermann @ 2020-02-05 13:31:29.945
== APP == 13:31:29.946 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=7 headers=GrpcHttp2OutboundHeaders[:status: 200, content-type: application/grpc, grpc-encoding: identity, grpc-accept-encoding: gzip] streamDependency=0 weight=16 exclusive=false padding=0 endStream=false
== APP == 13:31:29.948 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND DATA: streamId=7 padding=0 endStream=false length=78 bytes=00000000490a2c747970652e676f6f676c65617069732e636f6d2f646170726578616d706c65732e536179526573706f6e736512190a17323032302d30322d30...
== APP == 13:31:29.949 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND HEADERS: streamId=7 headers=GrpcHttp2OutboundHeaders[grpc-status: 0] streamDependency=0 weight=16 
exclusive=false padding=0 endStream=true
== APP == 13:31:29.950 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND WINDOW_UPDATE: streamId=0 windowSizeIncrement=78
== APP == 13:31:29.950 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] INBOUND PING: ack=false bytes=145258749040133895
== APP == 13:31:29.950 [grpc-nio-worker-ELG-3-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyServerHandler - [id: 0xc1e23417, L:/1
27.0.0.1:5000 - R:/127.0.0.1:52735] OUTBOUND PING: ack=true bytes=145258749040133895

HelloWorldClient

dapr run -- mvn exec:java  -D exec.mainClass=io.dapr.examples.invoke.grpc.HelloWorldClient
Starting Dapr with id Heronhollow-Lasher. HTTP Port: 52772. gRPC Port: 52773
You're up and running! Both Dapr and your app logs will appear here.

== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="starting Dapr Runtime -- version 0.3.0 -- commit v0.3.0-rc.0-1-gfe6c306-dirt
y"
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="log level set to: info"
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="standalone mode configured"
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="dapr id: Heronhollow-Lasher"
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="loaded component messagebus (pubsub.redis)" 
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="loaded component statestore (state.redis)"  
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="loaded component sample123 (bindings.kafka)"
== DAPR == 2020-02-05 13:30:56.233725 I | redis: connecting to localhost:6379
== DAPR == 2020-02-05 13:30:56.239723 I | redis: connected to localhost:6379 (localAddr: [::1]:52774, remAddr: [::1]:6379)
== DAPR == time="2020-02-05T13:30:56+01:00" level=info msg="Initialized service discovery to standalone"
== APP == [INFO] Scanning for projects...
== APP == [WARNING] 
== APP == [WARNING] Some problems were encountered while building the effective model for io.dapr:dapr-sdk-examples:jar:0.2.0-beta-1

== APP == [WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-deploy-plugin is missing. @ line 130, column 1
5
== APP == [WARNING] 
== APP == [WARNING] It is highly recommended to fix these problems because they threaten the stability of your build.
== APP == [WARNING] 
== APP == [WARNING] For this reason, future Maven versions might no longer support building such malformed projects.
== APP == [WARNING] 
== APP == [INFO] Inspecting build with total of 1 modules...
== APP == [INFO] Installing Nexus Staging features:
== APP == [INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plugin
== APP == [INFO] 
== APP == [INFO] ---------------------< io.dapr:dapr-sdk-examples >----------------------
== APP == [INFO] Building dapr-sdk-examples 0.2.0-beta-1
== APP == [INFO] --------------------------------[ jar ]---------------------------------
== APP == [INFO] 
== APP == [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dapr-sdk-examples ---
== APP == Sending message: Message #0
== APP == 13:31:00.891 [io.dapr.examples.invoke.grpc.HelloWorldClient.main()] DEBUG reactor.util.Loggers$LoggerFactory - Using Slf4j
 logging framework
== APP == [WARNING] 
== APP == java.lang.RuntimeException: java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:52772
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:214)
== APP ==     at reactor.core.publisher.MonoCallable.call (MonoCallable.java:91)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:126)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.invoke.grpc.HelloWorldClient.main (HelloWorldClient.java:35)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)     
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
== APP == Caused by: java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:52772
== APP ==     at okhttp3.internal.connection.RealConnection.connectSocket (RealConnection.kt:270)
== APP ==     at okhttp3.internal.connection.RealConnection.connect (RealConnection.kt:176)       
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findConnection (ExchangeFinder.kt:236)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findHealthyConnection (ExchangeFinder.kt:109)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.find (ExchangeFinder.kt:77)
== APP ==     at okhttp3.internal.connection.Transmitter.newExchange$okhttp (Transmitter.kt:162)
== APP ==     at okhttp3.internal.connection.ConnectInterceptor.intercept (ConnectInterceptor.kt:35)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.cache.CacheInterceptor.intercept (CacheInterceptor.kt:82)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.http.BridgeInterceptor.intercept (BridgeInterceptor.kt:84)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept (RetryAndFollowUpInterceptor.kt:71)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
    == APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.RealCall.getResponseWithInterceptorChain (RealCall.kt:184)
== APP ==     at okhttp3.RealCall.execute (RealCall.kt:66)
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:196)
== APP ==     at reactor.core.publisher.MonoCallable.call (MonoCallable.java:91)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:126)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.invoke.grpc.HelloWorldClient.main (HelloWorldClient.java:35)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
== APP == Caused by: java.net.ConnectException: Connection refused: connect
== APP ==     at java.net.PlainSocketImpl.waitForConnect (Native Method)
== APP ==     at java.net.PlainSocketImpl.socketConnect (PlainSocketImpl.java:107)
== APP ==     at java.net.AbstractPlainSocketImpl.doConnect (AbstractPlainSocketImpl.java:399)
== APP ==     at java.net.AbstractPlainSocketImpl.connectToAddress (AbstractPlainSocketImpl.java:242)
== APP ==     at java.net.AbstractPlainSocketImpl.connect (AbstractPlainSocketImpl.java:224)
== APP ==     at java.net.SocksSocketImpl.connect (SocksSocketImpl.java:403)
== APP ==     at java.net.Socket.connect (Socket.java:609)
== APP ==     at okhttp3.internal.platform.Platform.connectSocket (Platform.kt:127)
== APP ==     at okhttp3.internal.connection.RealConnection.connectSocket (RealConnection.kt:268)
== APP ==     at okhttp3.internal.connection.RealConnection.connect (RealConnection.kt:176)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findConnection (ExchangeFinder.kt:236)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.findHealthyConnection (ExchangeFinder.kt:109)
== APP ==     at okhttp3.internal.connection.ExchangeFinder.find (ExchangeFinder.kt:77)
== APP ==     at okhttp3.internal.connection.Transmitter.newExchange$okhttp (Transmitter.kt:162)
== APP ==     at okhttp3.internal.connection.ConnectInterceptor.intercept (ConnectInterceptor.kt:35)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.cache.CacheInterceptor.intercept (CacheInterceptor.kt:82)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.internal.http.BridgeInterceptor.intercept (BridgeInterceptor.kt:84)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept (RetryAndFollowUpInterceptor.kt:71)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:112)
== APP ==     at okhttp3.internal.http.RealInterceptorChain.proceed (RealInterceptorChain.kt:87)
== APP ==     at okhttp3.RealCall.getResponseWithInterceptorChain (RealCall.kt:184)
== APP ==     at okhttp3.RealCall.execute (RealCall.kt:66)
== APP ==     at io.dapr.client.DaprHttp.lambda$invokeApi$3 (DaprHttp.java:196)
== APP ==     at reactor.core.publisher.MonoCallable.call (MonoCallable.java:91)
== APP ==     at reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap (FluxFlatMap.java:126)
== APP ==     at reactor.core.publisher.MonoFlatMap.subscribeOrReturn (MonoFlatMap.java:53)
== APP ==     at reactor.core.publisher.Mono.subscribe (Mono.java:4090)
== APP ==     at reactor.core.publisher.Mono.block (Mono.java:1662)
== APP ==     at io.dapr.examples.invoke.grpc.HelloWorldClient.main (HelloWorldClient.java:35)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
== APP ==     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
== APP ==     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
== APP ==     at java.lang.reflect.Method.invoke (Method.java:566)
== APP ==     at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:282)
== APP ==     at java.lang.Thread.run (Thread.java:834)
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] BUILD FAILURE
== APP == [INFO] ------------------------------------------------------------------------
== APP == [INFO] Total time:  7.985 s
== APP == [INFO] Finished at: 2020-02-05T13:31:05+01:00
== APP == [INFO] ------------------------------------------------------------------------
== APP == [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.6.0:java (default-cli) on project dapr-sdk-examples: 
An exception occured while executing the Java class. java.net.ConnectException: Failed to connect to localhost/0:0:0:0:0:0:0:1:52772: Connection refused: connect -> [Help 1]
== APP == [ERROR]
== APP == [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
== APP == [ERROR] Re-run Maven using the -X switch to enable full debug logging.
== APP == [ERROR]
== APP == [ERROR] For more information about the errors and possible solutions, please read the following articles:
== APP == [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
== DAPR == time="2020-02-05T13:31:06+01:00" level=warning msg="failed to init output binding bindings.kafka: kafka: client has run oun o
ut of available brokers to talk to (Is your cluster reachable?)"
== DAPR == time="2020-02-05T13:31:06+01:00" level=warning msg="failed to init input bindings: app channel not initialized"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actor runtime started. actor idle timeout: 1h0m0s. actor scan interval: 
30s"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: starting connection attempt to placement service at localhost:60
50"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="http server is running on port 52772"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="gRPC server is running on port 52773"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="local service entry announced"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="dapr initialized. Status: Running. Init Elapsed 10046.7773ms"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: established connection to placement service at localhost:6050"  
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: placement order received: lock"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: placement order received: update"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: placement tables updated"
== DAPR == time="2020-02-05T13:31:06+01:00" level=info msg="actors: placement order received: unlock"

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Fields

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions