pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [pulsar] Jennifer88huang commented on a change in pull request #4677: Blog of 2.4.0 release
Date Mon, 08 Jul 2019 05:25:17 GMT
Jennifer88huang commented on a change in pull request #4677: Blog of 2.4.0 release
URL: https://github.com/apache/pulsar/pull/4677#discussion_r300924898
 
 

 ##########
 File path: site2/website/blog/2019-07-05-Apache-Pulsar-2-4-0.md
 ##########
 @@ -0,0 +1,118 @@
+---
+author: Penghui Li
+authorURL: https://twitter.com/lipenghui6
+title: Apache Pulsar 2.4.0
+---
+
+We are glad to present the new 2.4.0 release of Pulsar. This is the result of a huge 
+effort from the community, with over 460 commits and a long list of new features, 
+general improvements and bug fixes.
+
+Check out the <b>[release notes](/release-notes/#2.4.0)</b> for a detailed list
of 
+the changes, with links to the relevant pull-requests, discussions and documentation.
+
+Regarding new features introduced, I just want to highlight here a tiny subset of them:
+
+<!--truncate-->
+
+### Delayed message delivery
+
+It's now possible to send delayed message by pulsar producer, and delayed message will 
+available after delay time.
+
+The Java code for a client using delayed message delivery will look like:
+
+```java
+producer.newMessage().value("delayed message").deliverAfter(10, TimeUnit.SECONDS).send()
+```
+
+> Note:
+>
+> 1. Messages are only delayed on shared subscriptions. Other subscriptions will deliver
immediately.
+> 2. Can't work well with batching messages while messages has different delay time.
+
+### Go functions
+
+Before 2.4.0, pulsar support use Java/Python to write pulsar functions. Now, it's 
+possible to use golang to write pulsar functions, the following is an example of 
+a Pulsar Function written in golang.
+
+```go
+import (
+    "fmt"
+    "context"
+
+    "github.com/apache/pulsar/pulsar-function-go/pf"
+)
+
+func HandleRequest(ctx context.Context, in []byte) error {
+    fmt.Println(string(in) + "!")
+    return nil
+}
+
+func main() {
+    pf.Start(HandleRequest)
+}
+```
+
+### Key_shared subscription
+
+A new subscribe type `Key_shared`. By `Key_shared` one partition could have several 
 
 Review comment:
   It's better to re-write this paragraph.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message