Hi All
In my application I have a client which sends the streams of record and
server streams the acknowledgment, things are working fine for first
request however for the subsequent request I am getting below errors. The
subsequent request is made after 2 or 3 seconds(GetRequest in proto file
Yeah, we don't have anything pre-existing that does something like that; it
gets into the specifics of your use-case. Making something yourself was
appropriate. I will say that the strategy used in
OrderedConcurrentOutputBuffer with the Buckets seems really clean.
On Thu, Apr 22, 2021 at 9:21 AM P
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
The trick above works, although I set the path to the OpenSSL header
directory on my system (/usr/include/openssl), so that the target can
provide the headers as well as the libraries.
native.new_local_repository(
name = "boringssl",
path = "/usr/include/openssl",
build_file_content
Hello,
I am using version 1.37.0 using the async option.
What I am trying to do is detect the status code in my interceptor for
logging reasons.
It worked fine in the non-async version but not in the async one.
Is there any other way to get the status code from the context object in
the asyn mod
