提交 · 12f896ee70f5911ee04e5dafde04ede1921ccb0b · apache / pulsar

10 1月, 2017 6 次提交
- R
  
  Fair message consumption from all partitions in partitioned-cons… (#153) · 12f896ee
  由 Rajan 提交于 1月 10, 2017
  
  12f896ee
- M
  
  Include DataSketches metrics provider for bookie stats (#143) · 3aaff932
  由 Matteo Merli 提交于 1月 09, 2017
  
  3aaff932
- R
  
  Validate cursor-readPosition before reading while checkingBacklogCursor (#162) · 3a5ff469
  由 Rajan 提交于 1月 09, 2017
  
  3a5ff469
- R
  
  Replicator-producer creation should be idempotent (#161) · e2d8c2e6
  由 Rajan 提交于 1月 09, 2017
  
  e2d8c2e6
- R
  
  recycle OpSendMsg after releasing payload (#157) · efd21ba2
  由 Rajan 提交于 1月 09, 2017
  
  efd21ba2
- S
  
  Async reset cursor (#155) · 2e7ecc9c
  由 sschepens 提交于 1月 09, 2017
  
  2e7ecc9c
23 12月, 2016 1 次提交
- R
  
  Stop consuming messages from consumer-listener if incoming-queue is cleared (#142) · 4dbe9d34
  由 Rajan 提交于 12月 23, 2016
  
  4dbe9d34
22 12月, 2016 1 次提交
- R
  
  Use binary-proto-lookup url for replication lookup (#128) · 9609885c
  由 Rajan 提交于 12月 21, 2016
  
  9609885c
20 12月, 2016 2 次提交
- R
  
  Support url/uri encoding of topic-name for http-request (#148) · 6f1fcd31
  由 Rajan 提交于 12月 19, 2016
  
  6f1fcd31
- R
  
  Fix: PartitionedConsumer support queueSize 1 (#149) · e83647a6
  由 Rajan 提交于 12月 19, 2016
  
  e83647a6
08 12月, 2016 3 次提交

Updated to BK-4.3.1.45-yahoo (#127) · 4136b400

由 Matteo Merli 提交于 12月 07, 2016

Changes included:
 * [a25b53] Removed unused SortedLruCache
 * [74cd2f] Removed unused DbLedgerStorage configuration keys
 * [fb279e] Reorder read operations based on Bookie availability
 * [d203c2] DataSketches metrics provider
 * [17ab66] Catch IndexOutOfBoundsException when reading entry log index map
 * [270b69] Fixed NPE when accessing readonly bookie list

4136b400

R

adminApi: add brokerServiceUrl while creating cluster (#140) · caba91c9
由 Rajan 提交于 12月 07, 2016

caba91c9
R

signSafeMod while getNextBroker index (#141) · 6448d361
由 Rajan 提交于 12月 07, 2016

6448d361

04 12月, 2016 1 次提交
- R
  
  Add support of auth&auth at discovery BinaryProto-lookup (#126) · 710755ff
  由 Rajan 提交于 12月 03, 2016
  
  710755ff
03 12月, 2016 2 次提交
- R
  
  Cleanup pending lookup request on connection close (#131) · d04b36fb
  由 Rajan 提交于 12月 02, 2016
  
  d04b36fb
- A
  Fix Error in NodeJS consumer example code (#138) · 4283b1a0
  由 Aaron Gong 提交于 12月 03, 2016
```
There was some problems with the URL and also the data packet coming in was a string and should be parsed...
```
  4283b1a0
02 12月, 2016 1 次提交
- Y
  
  Replaced Json Library (#130) · 6ea847cc
  由 yush1ga 提交于 12月 02, 2016
  
  6ea847cc
29 11月, 2016 1 次提交
- M
  
  Added DbLedgerStorage configuration keys with default values in bookkeeper.conf (#123) · 5af7d3fe
  由 Matteo Merli 提交于 11月 28, 2016
  
  5af7d3fe
23 11月, 2016 2 次提交
- R
  
  exclude: conflicting artifact from async-http-client to avoid split-package conflict (#125) · 83ff8575
  由 Rajan 提交于 11月 22, 2016
  
  83ff8575
- R
  
  Add blockedConsumerOnUnackedMsgs flag in consumer-stats (#124) · 3cec7e46
  由 Rajan 提交于 11月 22, 2016
  
  3cec7e46
21 11月, 2016 3 次提交
- R
  
  Fix: split-package conflict while server startup (#122) · e525da35
  由 Rajan 提交于 11月 20, 2016
  
  e525da35
- R
  
  Check symbolicLink file type before reading it as SymbolicLink file (#121) · 6089dcba
  由 Rajan 提交于 11月 20, 2016
  
  6089dcba
- M
  Pulsar binary protocol documentation (#111) · a7e746dc
  由 Matteo Merli 提交于 11月 20, 2016
```
Fixes #109
```
  a7e746dc
18 11月, 2016 2 次提交

Upgrade to BK-4.3.1.42-yahoo (#120) · b21e0f35

由 Matteo Merli 提交于 11月 17, 2016

Changes included: 
 * [c4f1f9a] Avoid RocksDB get() operations during read-ahead cache filling (#145)

Related to #110

b21e0f35

R
Remove shading-package-relocation for async-client as it creates conflict... · 610a9fb0
由 Rajan 提交于 11月 17, 2016
```
Remove shading-package-relocation for async-client as it creates conflict while reading property file (#119)
```
610a9fb0

17 11月, 2016 6 次提交
- R
  
  Initialize lookup-request variables locally before request-instance recycle (#117) · 70ae6710
  由 Rajan 提交于 11月 16, 2016
  
  70ae6710
- M
  
  [#114] Process ZK event from background thread to avoid deadlock on ZK sync operations (#115) · 4563540c
  由 Matteo Merli 提交于 11月 16, 2016
  
  4563540c
- S
  
  Fix LinuxBrokerHostUsageImpl scheduled timer (#113) · 3c596d49
  由 sschepens 提交于 11月 16, 2016
  
  3c596d49
- R
  
  Fix: Discovery-lookup returns correct PartitionMetadataResponse on partition-lookup (#112) · 536d353e
  由 Rajan 提交于 11月 16, 2016
  
  536d353e
- S
  
  Implement BrokerHostUsage using java (#88) · f9993942
  由 sschepens 提交于 11月 16, 2016
  
  f9993942
- S
  
  Increment permits when redelivering messages from incomingMessages (#101) · 5e9884c7
  由 sschepens 提交于 11月 16, 2016
  
  5e9884c7
15 11月, 2016 1 次提交
- M
  Issue #80: Use receiveAsync() to aggregate messages into shared queue for... · 72cc6779
  由 Matteo Merli 提交于 11月 14, 2016
```
Issue #80: Use receiveAsync() to aggregate messages into shared queue for partitioned consumer (#106)
```
  72cc6779
14 11月, 2016 1 次提交
- M
  
  Issue #80: Use receiveAsync() to aggregate messages into shared queue for partitioned consumer · ff8318be
  由 Matteo Merli 提交于 11月 10, 2016
  
  ff8318be
12 11月, 2016 2 次提交
- R
  
  Fix typo in pulsar-admin (#108) · f2636e1e
  由 Rajan 提交于 11月 11, 2016
  
  f2636e1e
- R
  
  Avoid setting ReplicatedFrom while init batchMessageMetadata (#107) · 4e9b0517
  由 Rajan 提交于 11月 11, 2016
  
  4e9b0517
10 11月, 2016 2 次提交
- R
  
  Support Topic lookup using Pulsar binary protocol (#5) · 004e022f
  由 Rajan 提交于 11月 09, 2016
  
  004e022f
- R
  
  Async authorization check while creation of producer/consumer (#98) · afaa63fd
  由 Rajan 提交于 11月 09, 2016
  
  afaa63fd
05 11月, 2016 1 次提交
- R
  Complete Message replay immediately if there is no entry to replay which will... · 15683fd0
  由 Rajan 提交于 11月 04, 2016
```
Complete Message replay immediately if there is no entry to replay which will not block reads from other consumer (#103)
```
  15683fd0
02 11月, 2016 2 次提交
- R
  
  Fix: broken websocket test and proxy-producer error handling (#99) · 1f053681
  由 Rajan 提交于 11月 01, 2016
  
  1f053681
- S
  
  Updating ning async-http-client to use Netty4 based implementation (#97) · 5799ffaa
  由 sschepens 提交于 11月 01, 2016
  
  5799ffaa