Skip to content

Instantly share code, notes, and snippets.

@cdbartholomew
cdbartholomew / simpleProducer.java
Created March 22, 2019 19:12
Simple java producer
import org.apache.pulsar.client.api.*;
import java.io.IOException;
public class simpleProducer {
private static final String SERVICE_URL = "pulsar://ASIAEAST2.GCP.KAFKAESQUE.IO:6650";
public static void main(String[] args) throws IOException
{
@cdbartholomew
cdbartholomew / 1-topic-6-partition-100b-Pulsar-2019-08-26-19-44-07.json
Last active December 11, 2019 19:54
Pulsar with fsync, 1 topic, 6 partition, 100 byte
{
"workload" : "1 topic / 6 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50790.87476165077, 49977.872125701564, 49945.30822277841, 50092.122033649546, 49946.36159751746, 50056.48248278649, 50001.158225560765, 49907.45873396709, 50008.67050593243, 50075.31300475616, 49991.08617119234, 49794.17346789896, 50212.66387040846, 50006.003179206426, 49985.274918290976, 49952.76890961529, 49948.91818952119, 50086.877998333024, 50013.18299313341, 50018.09621692047, 50003.107329479586, 49997.591092723786, 49939.97584934062, 50036.44342591058, 50020.67037675661, 50004.891517326534, 49992.75634946068, 49935.51281287183, 49951.09572804743, 50025.929125887415, 50074.965837059506, 50000.568215891195, 50007.562878189034, 50002.16526606391, 49996.53425881668, 50008.48737271637, 49915.312759727545, 50059.626974202845, 50013.55754229559, 50001.49250181137, 50011.62267887402, 49988.75089509224, 50000.79475050193, 50005.25729987157, 49931.97214581692, 49871.22312022959, 50191.18686313468, 49996.69959441163, 50016
@cdbartholomew
cdbartholomew / 1-topic-16-partition-100b-Pulsar-2019-08-26-20-23-10.json
Last active December 11, 2019 19:54
Pulsar with fsync, 1 topic, 16 partition, 100 byte
{
"workload" : "1 topic / 16 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50582.92471374752, 50031.911638597136, 49793.912545666186, 50233.008689293776, 49953.06034655588, 50050.708991602194, 49995.068069442495, 49761.46408629391, 50244.924095361916, 49996.52106038477, 49937.09018995609, 50068.11227300752, 49996.218957613964, 49952.7837840712, 50036.86103575526, 49951.74291366581, 50063.817341629954, 49994.309294283, 49837.012490721514, 50150.65576343851, 49958.48853591224, 50058.47592736917, 49985.03815724686, 49979.31886048656, 50018.771443812366, 49978.00425960612, 50039.046583372045, 49802.67018337127, 50201.04764636323, 49926.7856612988, 50064.95655183359, 49954.226010075756, 50047.52622077883, 49780.46291041408, 50219.79145584204, 49960.605686619405, 50020.372115998, 49957.55968171027, 50050.98807394249, 49842.79701031261, 50171.354398370415, 49958.40808542528, 50036.75444243841, 49982.245629039724, 49968.90293349348, 50058.24665342443, 49831.83390873779, 50163.880273478986, 49962.000
@cdbartholomew
cdbartholomew / 1-topic-1-partition-100b-no-flush-Pulsar-2019-08-26-20-56-54.json
Last active December 11, 2019 19:54
Pulsar with no fsync, 1 topic, 1 partition, 100 byte
{
"workload" : "1 topic / 1 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50928.22376910101, 49955.45681486271, 49959.09479001916, 50074.86563594301, 49949.3131273699, 50053.78794202871, 50005.48966206737, 49907.321262691206, 50006.800836588896, 50065.19085027455, 49997.65075071435, 49800.99536870044, 50220.86194844711, 49976.346059303905, 50018.01480052815, 49924.85259450599, 49971.79740213914, 50116.192052707214, 49985.849282379255, 50012.96618145542, 50002.21295250549, 49763.69543985337, 50230.27500855977, 50000.06054412292, 49999.95730774179, 49993.84398814038, 49972.4472620979, 49922.75768011535, 50015.36224974565, 50095.79968634562, 50005.82807282678, 49994.840701534704, 49995.91251101659, 50000.32410384953, 49998.09791447646, 49948.10334468103, 49085.67138702012, 50989.930654465345, 49999.61114822901, 49982.73695649315, 50022.50495376131, 49986.78598642096, 49949.3693029748, 49930.08439102235, 50070.936809366234, 50058.173083873306, 49999.514405892565, 49987.03667736105, 50016.3139896
@cdbartholomew
cdbartholomew / 1-topic-6-partition-100b-no-flush-Pulsar-2019-08-26-21-16-22.json
Last active December 11, 2019 19:55
Pulsar with no fsync, 1 topic, 6 partition, 100 byte
{
"workload" : "1 topic / 6 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50760.35247614512, 50058.94785463528, 49986.57341500786, 49914.749833562564, 49899.281151136354, 50198.976896721564, 50000.431235399854, 49822.04406433928, 50181.09664199593, 49993.188931263656, 50001.56373579086, 49908.21516869131, 49825.30965760165, 50269.26818984969, 50002.4207239643, 49997.742026850756, 49998.00449265408, 49986.167297747605, 49952.354489713645, 50046.034317960846, 50014.278432194085, 49988.177028171966, 50011.45374843163, 49940.767756879606, 49957.647951937244, 49982.8014217017, 50032.23293718844, 50086.829490302065, 50004.87912482434, 50001.219999916764, 49999.84318442053, 49994.43395408256, 49997.54118367049, 50011.95513654939, 49941.788496493864, 50050.9296434229, 50003.71848225965, 49993.14479357168, 50006.50324469455, 49999.4124629378, 49994.18876285941, 49999.01457643405, 49987.9270476987, 49881.58601800264, 50117.22387394298, 50011.47642629522, 49986.52794570154, 50013.39088970302, 49986.234
@cdbartholomew
cdbartholomew / 1-topic-16-partition-100b-no-flush-Pulsar-2019-08-26-21-36-18.json
Last active December 11, 2019 19:55
Pulsar with no fsync, 1 topic, 16 partition, 100 byte
{
"workload" : "1 topic / 16 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50872.13826917449, 49978.477908710105, 49982.61210062224, 50056.58664859296, 49948.55652005874, 50049.10620638829, 49971.65895387991, 49922.56262208366, 50084.47114934899, 50010.534924815176, 50000.651114105516, 49928.68778136625, 50079.373558568484, 49982.71266472559, 49995.81050671464, 49922.9113444821, 49866.41040980193, 50221.0620191769, 49997.38987195083, 50018.13943664933, 49999.85758720759, 49927.89934373773, 50072.45303201027, 50000.434168020634, 49999.49762586016, 49989.00352296585, 49978.28432568758, 49918.561304321025, 49824.32149567976, 50279.407260726126, 49993.76249497816, 50012.60802344887, 49996.22762799818, 49990.69402494346, 50003.41839088431, 50013.95319611434, 49948.618009129365, 50050.84687850051, 50001.375336587145, 49985.02241478341, 50009.99103195496, 50006.57851873948, 50005.811625978735, 49912.33814718612, 49943.77133257381, 50143.86628493182, 49995.628799250495, 49984.25520860926, 48972.7668
@cdbartholomew
cdbartholomew / 1-topic-1-partition-100b-Pulsar-2019-08-27-21-00-24.json
Last active December 11, 2019 19:55
Pulsar with fsync, 1 topic, 1 partition, 100 byte
{
"workload" : "1 topic / 1 partition / 100b",
"driver" : "Pulsar",
"publishRate" : [ 50884.34015783831, 49962.78210109278, 49962.37804052986, 50062.17747097228, 49961.99099733123, 50044.936924895796, 50007.30315006357, 49902.38582325414, 50014.09999872996, 50080.94585550751, 49996.65539072931, 49788.00712125509, 50223.34295953515, 49996.2800860047, 50002.46887476503, 49940.486826099375, 49951.944198435274, 50048.808013549504, 50053.60980800623, 49999.23428293644, 49997.62193426766, 50005.92917740943, 49934.63836322079, 50060.98303336924, 50000.284983434074, 50005.355545665465, 50000.76764583408, 49935.29721458992, 49954.34144387871, 50000.347670612435, 50112.979742952746, 49992.39198737709, 50007.434032386875, 49996.36018906239, 49998.54957947152, 49996.133087608505, 49927.115988361256, 50078.064509567404, 49990.63561472928, 49999.36053642898, 50005.3531480185, 50002.009775666134, 50004.49092753877, 49998.03748041575, 49917.45897532746, 49846.65332822962, 50237.92054875211, 49996.80243913564, 49997.997
@cdbartholomew
cdbartholomew / 1-topic-1-partition-100b-Kafka-2019-08-27-23-50-14.json
Last active December 11, 2019 19:55
Kafka with no fsync, 1 topic, 1 partition, 100 byte
{
"workload" : "1 topic / 1 partition / 100b",
"driver" : "Kafka",
"publishRate" : [ 50983.03175743923, 49916.5652034733, 50088.73594192873, 49813.561514232366, 50174.797792333906, 49974.186377912476, 50050.598510947704, 49961.5512675861, 50027.05967538579, 49947.2476244998, 50067.67686841946, 49959.54147506098, 50044.7925162239, 49964.16969998391, 50031.20476634242, 49977.39430817243, 49805.75818272376, 50206.19495964331, 49968.23400637336, 50030.45707737099, 49814.33456807837, 50169.98436214445, 49954.27311634257, 50049.75554546281, 48982.36410442766, 51011.36480139958, 50000.31659293722, 49835.62048132035, 50169.0806025025, 49958.93418071097, 50014.322719167205, 50031.569517454365, 49977.43691910073, 49850.901130177466, 50192.31729117897, 49955.24786565914, 49986.76632487251, 50046.1757160783, 49989.141702663685, 49957.028367971434, 49882.86406354846, 50124.98827702351, 49893.596054294285, 50153.3173007006, 49948.82071326588, 50012.88912008715, 49994.21475732546, 49988.42472763299, 49903.39059615924,
@cdbartholomew
cdbartholomew / 1-topic-6-partition-100b-Kafka-2019-08-28-00-06-31.json
Last active December 11, 2019 19:56
Kafka with no fsync, 1 topic, 6 partition, 100 byte
{
"workload" : "1 topic / 6 partition / 100b",
"driver" : "Kafka",
"publishRate" : [ 50810.82074183304, 50031.476456617325, 49830.05710104602, 50168.0322183214, 49961.40691149998, 50052.50091832401, 49950.41833142821, 50024.31298916584, 49994.631822364005, 49557.41848707923, 50439.57952925059, 49838.492501830035, 50186.64712791937, 49936.017425569, 50077.51904185554, 49782.5780244384, 50198.96592382339, 49961.4212467103, 50044.23172246834, 49845.55374240216, 50134.01795177192, 49975.24698996032, 50046.61669753672, 49996.195329732145, 49830.22387907095, 50182.36323269109, 49952.60949608777, 49844.20918219755, 50207.49040281308, 49951.05908962593, 49856.73907112345, 50164.49902027025, 49959.75212850856, 49878.28107504863, 50191.16186016173, 49947.079151506725, 50016.85567160606, 49991.397998886045, 49866.36585484769, 50127.05471466398, 50033.703386230314, 49983.775833499734, 49957.36351629568, 50055.92436458979, 49993.117702383424, 49995.89632532074, 49991.43432625479, 49830.27887134385, 50006.08227643392
@cdbartholomew
cdbartholomew / 1-topic-16-partition-100b-Kafka-2019-08-28-00-22-48.json
Last active December 11, 2019 19:56
Kafka with no fsync, 1 topic, 16 partition, 100 byte
{
"workload" : "1 topic / 16 partition / 100b",
"driver" : "Kafka",
"publishRate" : [ 50899.91269297135, 49918.185874847186, 50086.010948198666, 49785.128425497336, 50233.539675136126, 49964.163818350746, 50050.96808859566, 49933.711023070035, 50075.591774405846, 49960.47266441688, 50029.316993193635, 50011.22490071385, 50018.97574779234, 49975.276910142784, 50034.22353134778, 49988.844021065524, 49808.508492754234, 50236.68858054058, 49960.010471547976, 50053.29897378355, 49844.57120233794, 50172.251727914954, 49972.92655389818, 50057.43067675602, 49963.83134060473, 50057.16343109814, 49967.05697430209, 49861.27370522308, 50192.63646662609, 49965.92557821011, 50008.94385348612, 50048.74258499221, 49979.17831833153, 49864.02479307875, 50202.60568728528, 49978.91929299875, 49996.710130167536, 50068.96063510263, 49978.2781528974, 49994.65531640232, 49858.23536936952, 50151.32434325398, 50061.402921080495, 49943.0631300435, 50029.35739392712, 49678.98774892976, 50321.1209010913, 49882.36721111314, 50136.70