ABCDEFGHIJKLMNOPQRSTVWXYZ
1
This file was created by Anonymitaet (Yu). It was last updated by Yu, momo-jun, RobertIndie, and Baodi on Apr 10, 2023.
2
āœ… means supported. āŒ means not supported yet. šŸ”§ means WIP.
3
4
FeatureJavaC++GoPythonNodeJSWebSocketC# / DotPulsarREST.NET (C#/F#/VB)
5
CodeDocCodeDocCodeDocCodeDocCodeDocCodeDocCodeDocCodeDocCode
6
7
ClientTLSEncryptionāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
8
Hostname verficationāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
9
AuthenticationJWTāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
10
m-TLSāœ…āœ…āœ…āœ…āœ… āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
11
Kerberosāœ…āœ…āŒ āŒ
12
OAuth2āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
13
Athenzāœ…āœ…āœ…āŒ
14
HTTP basicāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ
15
Multi-Hosts Service URLāœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
16
Proxyāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ āœ…
17
SNI Routingāœ…āœ…āœ… āœ…āœ…āŒ āœ…
18
Statisticsāœ…āŒ āœ…
19
Transactionsāœ…šŸ”§
āœ…
Go 0.10
ā‰„ Pulsar 2.9.5
āŒ āœ…
22
Memory Limitsāœ…šŸ”§āœ…
Go 0.10
Server-indenpendent
šŸ”§šŸ”§https://github.com/fsprojects/pulsar-client-dotnet/issues/169
23
ServiceUrlProviderāœ…šŸ”§šŸ”§šŸ”§šŸ”§āŒ
24
Cluster-level auto failoverāœ…šŸ”§šŸ”§šŸ”§šŸ”§šŸ”§āŒ
25
Auto release client useless connectionsāœ…āŒ
26
Notifications for faster topic discoveryāœ…āŒ
27
28
ProducerPartitioned Topicsāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
Support partitioned topics for producers
āœ…āœ…
29
Batchingāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
30
Chunkingāœ…āœ…
āœ…
āœ…
āœ…
āœ…
āœ…āœ…āœ…
31
CompressionLZ4āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
32
ZLIBāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
33
ZSTDāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
34
SNAPPYāœ…āœ…āœ…šŸ”§āœ…āœ…āœ…āœ…
35
SchemaPrimitiveāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…šŸ”§āœ…āœ…āœ…
36
Avroāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…šŸ”§āœ…āœ…āœ…
37
Jsonāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…šŸ”§āœ…āœ…
38
Protobufāœ…āœ…āœ…āœ…āœ…āœ…āœ…
39
protobuf-nativeāœ…āœ…āœ…āœ…āœ…āœ…
40
Native Avroāœ…āœ…āŒ
41
KeyValueāœ…āœ…āœ…āœ…šŸ”§šŸ”§šŸ”§āœ…āœ…āœ…āœ…
42
AutoSchemaāœ…šŸ”§āœ…
43
SendMsgWithDifferentSchemaāœ…āŒ
44
Multi-version Schemaāœ…āœ…āœ…
45
User-defined propertiesāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ
46
Key-based batcherāœ…āœ…āœ…āœ…šŸ”§āœ…
47
Delayed/scheduled messagesāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
48
Interceptorsāœ…āœ…āœ…
C++ 3.2
Server independent
āœ…šŸ”§šŸ”§āœ…
49
Message Routerāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
50
End-to-end Encryptionāœ…āœ…āœ…āœ… āœ…āœ…āœ…
51
BlockIfQueueFullāœ…āœ…āœ…āœ…āœ…āœ…
52
AccessModeSharedāœ…āœ…āœ…
C++ 3.2
Pulsar 2.8.x
šŸ”§šŸ”§šŸ”§āŒ
53
Exclusiveāœ…āœ…āœ…
C++ 3.2
Pulsar 2.8.x
šŸ”§šŸ”§šŸ”§āŒ
54
ExclusiveWithFencingāœ…āœ…
C++ 3.2
Pulsar 2.8.x
šŸ”§šŸ”§šŸ”§āŒ
55
WaitForExclusiveāœ…āœ…āœ…
C++ 3.2
Pulsar 2.8.x
šŸ”§šŸ”§šŸ”§āŒ
56
Transactionsāœ…šŸ”§
āœ…
Go 0.10
Pulsar 2.9.5
āœ…
57
58
ConsumerPartitioned Topicsāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
59
Batchingāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
60
Chunkingāœ…āœ…
āœ…āœ… āœ…āœ…āœ…āœ…
61
CompressionLZ4āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
62
ZLIBāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
63
ZSTDāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
64
SNAPPYāœ…āœ…āœ…šŸ”§āœ…āœ…āœ…āœ…
65
Compacted Topicsāœ…āœ…āœ… Pulsar 2.8.xāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
66
Multiple Topicsāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
67
Regex Consumerāœ…āœ…āœ…āœ…āœ…āœ…āœ…
68
SeekMessageIDāœ…āœ…āœ…āœ…āœ…āœ…
https://pulsar.apache.org/api/python/2.10.0/pulsar.html#Consumer.seek
āœ…āœ…
69
Timestampāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
70
SchemaPrimitiveāœ…āœ…āœ… Pulsar 2.8.xāœ…āœ…āœ…āœ…šŸ”§āœ…āœ…
71
Avroāœ…āœ…āœ… Pulsar 2.8.xāœ…āœ…āœ…āœ…āœ…šŸ”§āœ…āœ…
72
Jsonāœ…āœ…āœ… Pulsar 2.8.xāœ…āœ…āœ…āœ…šŸ”§āœ…
73
Protobufāœ…āœ…āœ… Pulsar 2.8.xāœ…āœ…
74
protobuf-nativeāœ…
75
Native AvroāŒ
76
KeyValueāœ…āœ…āœ… Pulsar 2.8.xāœ…šŸ”§šŸ”§šŸ”§āœ…āœ…āœ…
77
AutoSchemaāœ…āœ…
78
Multi-version Schemaāœ…āœ…
79
User-defined propertiesāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āŒ
80
hasMessageAvailableāœ…āœ…
81
Subscription
Type
Exclusiveāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
82
Failoverāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
83
Sharedāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
84
Key_Sharedāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
85
Subscription
Mode
Durableāœ…āœ…āœ…āœ…
86
Non-durableāœ…āœ…āœ…āœ…
87
Interceptorsāœ…āœ…āœ…
C++ 3.2
Server independent
āœ…šŸ”§šŸ”§āœ…
88
AckAck Individualāœ…āœ…āœ…āœ…āœ…āœ…āœ…
89
Ack Cumulativeāœ…āœ…āœ…āœ…āœ…āœ…
https://pulsar.apache.org/docs/en/next/client-libraries-node/#consumer-operations
āœ…āœ…
90
Batch-Index Ackāœ…šŸ”§šŸ”§šŸ”§šŸ”§āœ…
91
Wait for responseackReceiptEnabledāœ…
C++ 3.2
Pulsar 2.8.x

setAckReceiptEnabled / isAckReceiptEnabled
92
Ack Timeoutāœ…āœ…āŒ (not supported)āœ…āœ…āœ…
93
Negative AckNegative Ackāœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…āœ…
94
Negative acknowledgment backoffāœ…āœ…šŸ”§āŒ
95
Retry letter topicāœ…āœ…āœ…āœ…āœ…
96
Dead Letter Policyāœ…āœ…āœ…āœ…āœ…āœ…
97
End-to-end Encryptionāœ…āœ…āœ…āœ…āœ…āœ…
98
SubscriptionInitialPositionāœ…āœ…āœ…āœ…āœ…āœ…āœ…
99
Batch Receiving Messagesāœ…āœ…āœ…šŸ”§āœ…šŸ”§āœ…
100
TransactionšŸ”§
āœ…
Go 0.10
Pulsar 2.9.5
101
102
ReaderPartitioned Topicsāœ…āœ…šŸ”§āœ…āœ…šŸ”§šŸ”§āœ…āœ…āœ