Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Issue 4175] [pulsar-function-go] Create integration tests for Go Functions for production-readiness #1

Open
wants to merge 83 commits into
base: go-features
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
83 commits
Select commit Hold shift + click to select a range
c6e258d
[Functions] The argument and description for dead letter topic is wro…
sijie Jan 21, 2020
e4099a2
[docs] Remove Dashboard from sidebar (#6097)
Jennifer88huang-zz Jan 21, 2020
f8a7386
Remove duplicated lombok annotations in the pulsar-functions modules …
vzhikserg Jan 21, 2020
d1afdf9
Apply correct language identifiers to the code blocks in the document…
vzhikserg Jan 21, 2020
f0d339e
Allow to enable/disable delayed delivery for messages on namespace (#…
wolfstudy Jan 21, 2020
7d851a3
[Fix doc issue 6058] Add consumer descriptions (#6088)
Anonymitaet Jan 22, 2020
f9674f7
Fix missing Swagger files for the version 2.5.0 (#6118)
vzhikserg Jan 22, 2020
cb19ee8
[Issue 6094][doc] fix Incorrect picture in pulsar function-overview (…
huangdx0726 Jan 22, 2020
992fc1e
[Issue 3681][docs] Update client-libraries in Get Started chapter (#6…
Jennifer88huang-zz Jan 22, 2020
56280ea
Fix issue 5505 (#6060)
ntysdd Jan 23, 2020
0aee35a
Support for python native logging from python wrapper (#6113)
BlackJohnny Jan 23, 2020
3035aa6
[Issue 5996][docs] Update broken links in 2.4.1 and 2.4.2 releases (#…
sijie Jan 23, 2020
472f448
[Issue 6056][docs] Add example on how to choose partition when using …
Jennifer88huang-zz Jan 23, 2020
c90854a
make acker transient (#6064)
yjshen Jan 23, 2020
f4ad1e8
Improve documentation about batching (#5989)
gmethvin Jan 23, 2020
138f662
[Issue 5983][docs] promote assign the advertisedAddress when startup …
fangpengcheng95 Jan 23, 2020
e23c6a8
[Issue 5690][pulsar-io] Make type name of Elasticsearch sink connecto…
Jan 23, 2020
d0920fc
Remove duplicated lombok annotations in the pulsar-broker module (#6130)
vzhikserg Jan 23, 2020
c078a55
[CPP] Compile fixes for ARM cpus (#6129)
merlimat Jan 23, 2020
9db9605
[website]Fixed website error (#6125)
tuteng Jan 24, 2020
c09314c
Fix zeroQueueConsumer using listener (#6106)
hrsakai Jan 24, 2020
66ea4c3
enable zh-TW website translation (#5956)
erhwenkuo Jan 24, 2020
68c33a7
Fix typo in Reader documentation. (#6103)
bwalendz Jan 24, 2020
8f62eb5
Support CLI pulsar tokens for concise description. (#6037)
murong00 Jan 24, 2020
648ed0e
[pulsar-broker] Fix some comment typos (#5926)
zhenglaizhang Jan 24, 2020
ec122ed
Check for the presence of presto libraries only when sql commands are…
srkukarni Jan 24, 2020
49a9897
[Websocket] Websocket doesn't set the correct cluster data (#6102)
sijie Jan 24, 2020
abb7a50
Simplify templating in log messages (#6133)
vzhikserg Jan 24, 2020
9cc2fe4
move fix for topic deletion in release notes to 2.5.0 (#6136)
EugenDueck Jan 25, 2020
e1e2523
[docs][functions] Remove redundancy (#6138)
EugenDueck Jan 25, 2020
5ae7a00
make bookie ranges stored in path/to/bkdata/ranges (#6082)
hanbo1990 Jan 25, 2020
73c013e
[docs] improve statement on ordering guarantees for multi-topic subsc…
EugenDueck Jan 25, 2020
91fbc32
[doc] Invalid code tab markdown for TW translation (#6142)
sijie Jan 26, 2020
2725132
[docs] Correct language idenitifiers in IO quickstart documentation (…
vzhikserg Jan 26, 2020
2976542
[Issue 3289][docs 2.5.0] Append / to metrics url to fix documentation…
agilob Jan 26, 2020
d42cfa1
Add timeout to search for web service URLs to avoid web threads getti…
Jan 28, 2020
6b04f6f
Skip tests if a pull request only changes documentation (#6182)
sijie Feb 1, 2020
b924bad
Fix ConsumerBuilder.create() -> .subscribe() (#6169)
EugenDueck Feb 1, 2020
b8760d5
Fixed the typo (#6167)
abhilashmandaliya Feb 1, 2020
b838c59
[Issue-5994]: Start proxy pods when at least one broker pod is runnin…
roman-popenov Feb 1, 2020
c7cdfa8
Update reference-configuration.md (#6155)
PiotrJander Feb 1, 2020
c76c19e
[Issue-5958][helm]: Fixing templates for helm deployment (#6148)
roman-popenov Feb 1, 2020
efee516
add missing check to dashboard-ingress (helm chart) (#6160)
tmemenga Feb 1, 2020
4ea02a3
Add maxUnackedMessagesPerSubscription and maxUnackedMessagesPerConsum…
wolfstudy Feb 3, 2020
0b06dba
Remove duplicated lombok annotations in the pulsar-client module (#6147)
vzhikserg Feb 3, 2020
af6b5f6
[Issue 6024][pulsar_storm] PulsarSpout emit to multiple streams (#6039)
dawillcox Feb 3, 2020
39380d4
Allow Customization of version and name of python packages (#6188)
aahmed-se Feb 3, 2020
5728977
Expose lastConsumedTimestamp and lastAckedTimestamp to consumer stats…
zymap Feb 4, 2020
e1c8d14
[Issue 4175] [pulsar-function-go] Add Go Function heartbeat (and gRPC…
devinbost Feb 4, 2020
e184e7d
Enabled grpc plugin to gRPC generate.sh script to fix issues causing …
Jan 11, 2020
4c43eb0
Updated Git workflow to fix Github Action CI build and test actions f…
Feb 4, 2020
3fedf08
Edited build step for Github Action CI for Go. (#6104)
Feb 4, 2020
67357ac
Edited path to golangci file for Github Action CI for Go. (#6104)
Feb 4, 2020
c93ff1f
Fixed formatting and style (#6104)
Feb 4, 2020
0f88c2a
Attempt to get Github CI style check working (#6104)
Feb 4, 2020
6b2d378
Changed comment to trigger rebuild to get flaky tests to pass. (#6104)
Feb 4, 2020
13d8ecd
Add copy file for cli tools (#6210)
tuteng Feb 4, 2020
a5647ef
Add acknowledgement explanation (#6212)
Anonymitaet Feb 4, 2020
0d981fb
[Doc] Fix issue 6186 - Add explanations for methods in producer and c…
Anonymitaet Feb 4, 2020
846e470
[Github actions]Improve integration test (#6184)
tuteng Feb 4, 2020
6ac2b6f
Update functions-overview.md (#6218)
Feb 5, 2020
d3f7caa
Add .asf.yaml for configuring the github project (#6217)
sijie Feb 5, 2020
2d02017
Switch to use github actions hosted under pulsar-test-infra (#6221)
sijie Feb 5, 2020
009e03f
Enable the pulsarbot action to react comments (#6223)
sijie Feb 5, 2020
a8e56b9
Fix license header and always run license check (#6222)
sijie Feb 5, 2020
4a2bceb
[CI] Add GITHUB_TOKEN as the environment variable for running pulsarb…
sijie Feb 5, 2020
92d7102
Revert "Support for python native logging from python wrapper (#6113)…
sijie Feb 6, 2020
0e8d533
Replace client api use correct version (#6240)
tuteng Feb 6, 2020
3b46f50
[Doc] Fix issue 6177 - Correct explanation for routing mode (#6244)
Anonymitaet Feb 6, 2020
d631156
[deployement] make kubernetes yamls for aws operational (#6192)
trexinc Feb 7, 2020
44dd412
Fix get schema version in HttpLookupService. (#6193)
codelipenghui Feb 7, 2020
4018d0b
Use fully qualified hostname as default to advertise brokers (#6235)
merlimat Feb 7, 2020
125a588
Fixed static linking on C++ lib on MacOS (#5581)
merlimat Feb 7, 2020
54b39e6
Fix bug that backlog message that has not yet expired could be delete…
Feb 7, 2020
d63b6c1
[C++] Ensure ExecutorServicePtr is not destroyed while the timer obje…
merlimat Feb 7, 2020
75c145a
Fix mispelling of tolarations. Correctly spelled at tolerations. (#6…
ericpsimon Feb 7, 2020
6511763
add Korean code base. (#6261)
oeegee Feb 8, 2020
2a912da
Merge remote-tracking branch 'apache/master' into go-features-integra…
sijie Feb 8, 2020
a45eb34
Moved core module back to parent. Kept examples module to allow build…
Feb 13, 2020
ec248ba
Merge branch 'go-features-integration' of https://github.com/devinbos…
Feb 13, 2020
8650ef0
Fixed workflow files to use parent directories for Go module, as per …
Feb 13, 2020
d4fc197
Fixed workflow files to use parent directories for Go module, as per …
Feb 13, 2020
40e14d8
Fixed Go function build errors #6104
Feb 14, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
[Doc] Fix issue 6177 - Correct explanation for routing mode (apache#6244
Anonymitaet authored Feb 6, 2020
commit 3b46f502fed947b02066e0769a655266e94d2eb0
2 changes: 1 addition & 1 deletion site2/docs/concepts-messaging.md
Original file line number Diff line number Diff line change
@@ -283,7 +283,7 @@ The diagram below illustrates this:

Here, the topic **Topic1** has five partitions (**P0** through **P4**) split across three brokers. Because there are more partitions than brokers, two brokers handle two partitions a piece, while the third handles only one (again, Pulsar handles this distribution of partitions automatically).

Messages for this topic are broadcast to two consumers. The [routing mode](#routing-modes) determines both which broker handles each partition, while the [subscription mode](#subscription-modes) determines which messages go to which consumers.
Messages for this topic are broadcast to two consumers. The [routing mode](#routing-modes) determines each message should be published to which partition, while the [subscription mode](#subscription-modes) determines which messages go to which consumers.

Decisions about routing and subscription modes can be made separately in most cases. In general, throughput concerns should guide partitioning/routing decisions while subscription decisions should be guided by application semantics.