Re: [grpc-io] Re: serverCallStreamObserver.isCancelled() cannot detect client disconnection for gRPC version higher than 1.41.0

2022-04-18 Thread 'Wen Bo (Bill) Li' via grpc.io
Okay, thanks. It looks like Context is more generic in client disconnecting from the server compared to ServerCall. In this case, I will use Context for our service. On Monday, April 18, 2022 at 10:53:27 AM UTC-4 Eric Anderson wrote: > On Fri, Apr 15, 2022 at 10:09 PM 'Wen Bo (Bill)

Re: [grpc-io] Re: serverCallStreamObserver.isCancelled() cannot detect client disconnection for gRPC version higher than 1.41.0

2022-04-15 Thread 'Wen Bo (Bill) Li' via grpc.io
as a lot to the discussion when the change was made, and we'll need to > reread it to remember what all was going on. > > If you wouldn't mind, could you create an issue on github for grpc-java > for this? If not, we can, but having the original reporter create the issue >

[grpc-io] Re: serverCallStreamObserver.isCancelled() cannot detect client disconnection for gRPC version higher than 1.41.0

2022-04-15 Thread Bill Li
I have just found that it's grpc-netty-shaded that is causing the behaviour described above. The latest working version is 1.40.2. It's working fine by setting grpc-protobuf, grpc-stub and grpc-testing to the latest release version. On Friday, 15 April 2022 at 16:47:33 UTC-4 Bil

[grpc-io] Re: serverCallStreamObserver.isCancelled() cannot detect client disconnection for gRPC version higher than 1.41.0

2022-04-15 Thread Bill Li
Yes, it is grpc-java. How I detected this was that google-cloud-pubsub is one of our dependencies and I noticed that 1.114.6 works but not 1.114.7. After digging into it deeper, I found the grpc version was upgrade from 1.40.x to 1.41.x. The server is written in Java and the client is written i

[grpc-io] serverCallStreamObserver.isCancelled() cannot detect client disconnection for gRPC version higher than 1.41.0

2022-04-14 Thread Bill Li
Hi, I have recently discovered serverCallStreamObserver.isCancelled() cannot detect disconnection of a client when gRPC version is higher than 1.41.x. So, the server logic that I have contains a while loop that runs forever and if the client disconnects from the server, it will call onCompleted

[grpc-io] Process request message fields in gRPC Server Interceptor [Java]

2021-06-17 Thread Bill Li
Hi, I have a question regarding how I can access each field of the input request object in ServerInterceptor. The following is my code: public ServerCall.Listener interceptCall(ServerCall serverCall, Metadata metadata, ServerCallHandler serverCallHandler) { ServerCall.Listener listener =

Re: [grpc-io] Configure MAX_CONCURRENT_STREAMS for HTTP/2

2021-05-21 Thread Bill Li
Okay, sure. I will share that once I have some experimental results. On Friday, 21 May 2021 at 02:11:31 UTC-4 sanjay...@google.com wrote: > On Thu, May 20, 2021 at 5:35 PM Bill Li wrote: > >> Cool thank you! >> >> One additional question, given the application a

Re: [grpc-io] Configure MAX_CONCURRENT_STREAMS for HTTP/2

2021-05-20 Thread Bill Li
On Wed, May 19, 2021 at 2:32 PM Bill Li wrote: > >> >> > >> Upon adding the block, I was able to make multiple threads executing >> onNext() concurrently. >> >> I am just curious about whether this is the right way of doing >> synchronizati

Re: [grpc-io] Configure MAX_CONCURRENT_STREAMS for HTTP/2

2021-05-19 Thread Bill Li
day, 19 May 2021 at 01:47:54 UTC-4 sanjay...@google.com wrote: > Pls include a code snippet of what you want to do. Show how you intend to > share "one ResponseObserver". > > On Tue, May 18, 2021 at 6:56 PM Bill Li wrote: > >> Got it, thanks! >> >> I am c

Re: [grpc-io] Configure MAX_CONCURRENT_STREAMS for HTTP/2

2021-05-18 Thread Bill Li
> This is the same as setting MAX_CONCURRENT_STREAMS per connection. > > On Tue, May 18, 2021 at 3:36 PM Bill Li wrote: > >> Hi, >> >> Does anyone know or have an example for configuring the parameter >> MAX_CONCURRENT_STREAMS for gRPC server written in Java? >

[grpc-io] Configure MAX_CONCURRENT_STREAMS for HTTP/2

2021-05-18 Thread Bill Li
Hi, Does anyone know or have an example for configuring the parameter MAX_CONCURRENT_STREAMS for gRPC server written in Java? Thanks, Bill -- You received this message because you are subscribed to the Google Groups "grpc.io" group. To unsubscribe from this group and stop receiving emails fro

[grpc-io] gRPC with Kafka: has anyone tried?

2021-04-27 Thread Bill Li
Hi, I am curious about what is the best approach to combine gRPC and Kafka. My goal is to be able to submit a gRPC request from the client side to the server side and get response stream back with messages consumed from Kafka topic. The request channel stays open as long as there are more messa