2020-03-11 09:57:39 UTC - Konstantinos Papalias: I'm coming into Pulsar from a
Kafka / Kafka Streams background, and have been trying to adopt Pulsar /
Functions for similar tasks, the main hurdles I see for Pulsar adoption, are
the following based on my limited exposure:
1. The benefit of Kafka
Hi Team,
Please help me to resolve me below topics urgently:-
1. Unable to remove duplicate message in broker.below Is my Code and config
File.
Producer Coding Related:-
PulsarClient pulsarClient = PulsarClient.builder()
.serviceUrl( "pulsar://192.168.x.x:6650" )
.build();
Producer prod
> 1. Unable to remove duplicate message in broker.below Is my Code and
config File.
How did you send the messages and how did you verify the messages are
duplicated?
Just FYI the duplication is identified by sequence id, not by content. Just
want to make sure the verification method you used is c
alexyans commented on issue #78: Error: Failed to send message: AlreadyClosed
URL:
https://github.com/apache/pulsar-client-node/issues/78#issuecomment-598421709
@equanz your example handles the rejection, sure. But there shouldn't be a
rejection in the first place. A producer closing afte
equanz commented on issue #78: Error: Failed to send message: AlreadyClosed
URL:
https://github.com/apache/pulsar-client-node/issues/78#issuecomment-598552987
As above, it seems that client has already been destructed when executing
`send` after timeout ms. Therefore, it seems that the co
