codelipenghui commented on issue #4079: PIP-34 Key_Shared subscription core
implementation.
URL: https://github.com/apache/pulsar/pull/4079#issuecomment-485206863
run java8 tests
run cpp tests
This is an automated message
jerrypeng merged pull request #4081: For functions metrics in prometheus also
remove TYPE
URL: https://github.com/apache/pulsar/pull/4081
This is an automated message from the Apache Git Service.
To respond to the message, p
This is an automated email from the ASF dual-hosted git repository.
jerrypeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 7b2bf95 For functions metrics in prometheus
ConcurrencyPractitioner commented on issue #3217: Auto scaling up and down
number of partitions
URL: https://github.com/apache/pulsar/issues/3217#issuecomment-485203073
Oh sorry, found the answer. Will be editing the doc within a few days. :)
--
jerrypeng edited a comment on issue #4093: [issue#4042] improve java functions
API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485191485
@sijie adding another support for ```MessageBuilder process(I input,
Context context);``` will likely involve adding another function in
jerrypeng edited a comment on issue #4093: [issue#4042] improve java functions
API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485191485
@sijie adding another support for ```MessageBuilder process(I input,
Context context);``` will likely involve adding another function in
jerrypeng commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485191485
@sijie adding another support for ```MessageBuilder process(I input,
Context context);``` will likely involve adding another function interface
jerrypeng edited a comment on issue #4093: [issue#4042] improve java functions
API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485191485
@sijie adding another support for ```MessageBuilder process(I input,
Context context);``` will likely involve adding another function in
jerrypeng commented on issue #4081: For functions metrics in prometheus also
remove TYPE
URL: https://github.com/apache/pulsar/pull/4081#issuecomment-485186956
rerun java8 tests
This is an automated message from the A
merlimat commented on issue #4046: [pulsar-io] [doc] Add docs for Redis sink
URL: https://github.com/apache/pulsar/pull/4046#issuecomment-485164403
run java8 tests
run cpp tests
This is an automated message from the Apache
merlimat commented on issue #4083: [pulsar-proxy]Add the LookupProxyHandler
handle getSchema request and test
URL: https://github.com/apache/pulsar/pull/4083#issuecomment-485164307
run java8 tests
This is an automated message
merlimat commented on issue #4059: Ensure Pulsar HTTP proxy carries over
Authorization header after 307 redirects
URL: https://github.com/apache/pulsar/pull/4059#issuecomment-485164357
run java8 tests
This is an automated mes
merlimat commented on issue #4084: [c++][pulsar-client-cpp] Protect against
double joining the worker thread in ExecutorService::close()
URL: https://github.com/apache/pulsar/pull/4084#issuecomment-485164254
run java8 tests
T
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 84a4141 Fix: set receive queue size for sinks (
merlimat merged pull request #4091: Fix: set receive queue size for sinks
URL: https://github.com/apache/pulsar/pull/4091
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
lovelle removed a comment on issue #3962: Feature / Interceptor for negative
ack redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485133456
run java8 tests
This is an automated message from the Apache G
lovelle commented on issue #3962: Feature / Interceptor for negative ack
redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485149966
run java8 tests
This is an automated message from the Apache Git Servi
jerrypeng commented on issue #4091: Fix: set receive queue size for sinks
URL: https://github.com/apache/pulsar/pull/4091#issuecomment-485149683
rerun java8 tests
This is an automated message from the Apache Git Service.
To re
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new c3e8a33 Optimizing performance for Pulsar funct
merlimat merged pull request #4082: Optimizing performance for Pulsar function
archive download
URL: https://github.com/apache/pulsar/pull/4082
This is an automated message from the Apache Git Service.
To respond to the mess
lovelle commented on issue #3962: Feature / Interceptor for negative ack
redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485141788
run java8 tests
This is an automated message from the Apache Git Servi
lovelle removed a comment on issue #3962: Feature / Interceptor for negative
ack redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485054225
run java8 tests
This is an automated message from the Apache G
lovelle commented on issue #3962: Feature / Interceptor for negative ack
redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485133456
run java8 tests
This is an automated message from the Apache Git Servi
lovelle removed a comment on issue #3962: Feature / Interceptor for negative
ack redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485115237
run java8 tests
This is an automated message from the Apache G
lovelle commented on issue #3962: Feature / Interceptor for negative ack
redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485115237
run java8 tests
This is an automated message from the Apache Git Servi
lovelle removed a comment on issue #3962: Feature / Interceptor for negative
ack redelivery
URL: https://github.com/apache/pulsar/pull/3962#issuecomment-485042243
run java8 tests
This is an automated message from the Apache G
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485083825
> Yes but we need this.
As I said, it can be add to the wrapper of sendAsync.
For handling the output result, I have mentioned followin
foreversunyao opened a new issue #4094: [WIP][Pipeline Plugin] add Pipeline
plugin feature to pulsar
URL: https://github.com/apache/pulsar/issues/4094
**Is your feature request related to a problem? Please describe.**
Currently we already have pulsar-io framework to let us make sourc
jerrypeng edited a comment on issue #4093: [issue#4042] improve java functions
API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485080376
> The only function code involve in current context.publish is
“this.statsManager.incrSysExceptions(e);”.
Yes but we need this.
jerrypeng commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485080376
> The only function code involve in current context.publish is
“this.statsManager.incrSysExceptions(e);”.
Yes but we need this.
@s
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485079466
The only function code involve in current context.publish is
“this.statsManager.incrSysExceptions(e);”.
--
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485079116
I strongly believe newOutputMessage is the right approach for deprecating
context.publish. All context.publish methods should be deprecated and they
jerrypeng commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485077510
Besides for this "TypedMessageBuilder messageBuilder =
newOutputMessage("output", Schema.JSON());" we would need to wrap sendAsync
somehow so t
jerrypeng commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485076939
@sijie I don't want to yet introduce another way for users to publish
messages. We already have the publish method so lets just keep it. We ca
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485075756
It doesn’t break the abstraction. The context.publish was designed for
function users publishing messages inside a function. There is no difference
merlimat commented on a change in pull request #3904: [go schema] support go
schema for pulsar-client-go
URL: https://github.com/apache/pulsar/pull/3904#discussion_r277129050
##
File path: pulsar-client-go/pulsar/client.go
##
@@ -103,16 +103,22 @@ type Client interface {
merlimat commented on a change in pull request #3904: [go schema] support go
schema for pulsar-client-go
URL: https://github.com/apache/pulsar/pull/3904#discussion_r277128960
##
File path: pulsar-client-go/pulsar/message.go
##
@@ -66,6 +69,9 @@ type Message interface {
merlimat commented on a change in pull request #3904: [go schema] support go
schema for pulsar-client-go
URL: https://github.com/apache/pulsar/pull/3904#discussion_r277129084
##
File path: pulsar-client-go/pulsar/c_message.go
##
@@ -97,8 +98,8 @@ func buildMessage(message
jerrypeng commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485072935
@sijie I strongly disagree. Allowing users to the send out messages via
```
messageBuilder.value("my-topic").key("key").properties("mypr
wolfstudy commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485072795
> @wolfstudy after looking a bit more into #4009, it is similar but it is a
different topic. The request is for attaching properties to the resu
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485071664
@wolfstudy after looking a bit more into #4009, it is similar but it is a
different topic. The request is for attaching properties to the result ret
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485070898
Jerry, I don’t think we should reinvent a new API. We should just use
message builder hence whatever is available in pulsar client is available to
jiazhai commented on issue #4079: PIP-34 Key_Shared subscription core
implementation.
URL: https://github.com/apache/pulsar/pull/4079#issuecomment-485070511
retest this please
This is an automated message from the Apache Git
wolfstudy edited a comment on issue #4093: [issue#4042] improve java functions
API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485070352
> The usage would something like this:
>
> ```
> MessageConf messageConf =
MessageConf.Builder().key("key").properties(myPrope
wolfstudy commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485070352
> The usage would something like this:
>
> ```
> MessageConf messageConf =
MessageConf.Builder().key("key").properties(myProperties).b
jerrypeng commented on issue #4082: Optimizing performance for Pulsar function
archive download
URL: https://github.com/apache/pulsar/pull/4082#issuecomment-485068876
rerun java8 tests
This is an automated message from the Ap
wolfstudy commented on a change in pull request #4093: [issue#4042] improve
java functions API
URL: https://github.com/apache/pulsar/pull/4093#discussion_r277127761
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
sijie commented on a change in pull request #4093: [issue#4042] improve java
functions API
URL: https://github.com/apache/pulsar/pull/4093#discussion_r277127575
##
File path:
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
##
sijie commented on issue #4093: [issue#4042] improve java functions API
URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485067523
@wolfstudy thank you for picking this up! #4009 and #4042 are addressing the
same problem.
49 matches
Mail list logo
