A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | V | W | X | Y | Z | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
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 | Feature | Java | C++ | Go | Python | NodeJS | WebSocket | C# / DotPulsar | REST | .NET (C#/F#/VB) | ||||||||||||||||
5 | Code | Doc | Code | Doc | Code | Doc | Code | Doc | Code | Doc | Code | Doc | Code | Doc | Code | Doc | Code | |||||||||
6 | ||||||||||||||||||||||||||
7 | Client | TLS | Encryption | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||
8 | Hostname verfication | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||
9 | Authentication | JWT | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||
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 | Producer | Partitioned Topics | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā
Support partitioned topics for producers | ā | ā | |||||||||||
29 | Batching | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||||
30 | Chunking | ā | ā
| ā
| ā
| ā
| ā
| ā | ā | ā | ||||||||||||||||
31 | Compression | LZ4 | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||
32 | ZLIB | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||||||
33 | ZSTD | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||||||||
34 | SNAPPY | ā | ā | ā | š§ | ā | ā | ā | ā | |||||||||||||||||
35 | Schema | Primitive | ā | ā | ā | ā | ā | ā | ā | ā | ā | š§ | ā | ā | ā | |||||||||||
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 | AccessMode | Shared | ā | ā | ā
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 | Consumer | Partitioned Topics | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||
59 | Batching | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||
60 | Chunking | ā | ā
| ā | ā | ā | ā | ā | ā | |||||||||||||||||
61 | Compression | LZ4 | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||
62 | ZLIB | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||||||||
63 | ZSTD | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||||||||
64 | SNAPPY | ā | ā | ā | š§ | ā | ā | ā | ā | |||||||||||||||||
65 | Compacted Topics | ā | ā | ā Pulsar 2.8.x | ā | ā | ā | ā | ā | ā | ā | ā | ā | |||||||||||||
66 | Multiple Topics | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||||
67 | Regex Consumer | ā | ā | ā | ā | ā | ā | ā | ||||||||||||||||||
68 | Seek | MessageID | ā | ā | ā | ā | ā | ā
https://pulsar.apache.org/api/python/2.10.0/pulsar.html#Consumer.seek | ā | ā | ||||||||||||||||
69 | Timestamp | ā | ā | ā | ā | ā | ā | ā | ā | ā | ||||||||||||||||
70 | Schema | Primitive | ā | ā | ā 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 | Ack | Ack Individual | ā | ā | ā | ā | ā | ā | ā | |||||||||||||||||
89 | Ack Cumulative | ā | ā | ā | ā | ā | ā
https://pulsar.apache.org/docs/en/next/client-libraries-node/#consumer-operations | ā | ā | |||||||||||||||||
90 | Batch-Index Ack | ā | š§ | š§ | š§ | š§ | ā | |||||||||||||||||||
91 | Wait for response | ackReceiptEnabled | ā
C++ 3.2 Pulsar 2.8.x setAckReceiptEnabled / isAckReceiptEnabled | |||||||||||||||||||||||
92 | Ack Timeout | ā | ā | ā (not supported) | ā | ā | ā | |||||||||||||||||||
93 | Negative Ack | Negative 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 | Reader | Partitioned Topics | ā | ā | š§ | ā | ā | š§ | š§ | ā | ā | ā |