Skip to content

Instantly share code, notes, and snippets.

View rdhabalia's full-sized avatar

Rajan Dhabalia rdhabalia

34 followers · 0 following
  • Yahoo Inc.
View GitHub Profile
@rdhabalia
rdhabalia / MyX509ExtendedTrustManager.java
Created August 29, 2019 01:40
package org.apache.pulsar.client.api;
import java.net.Socket;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.NoSuchProviderException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
@rdhabalia
rdhabalia / multi-ssh.sh
Created May 16, 2019 01:08
#!/bin/bash
# ssh-multi
# Based on http://linuxpixies.blogspot.jp/2011/06/tmux-copy-mode-and-how-to-control.html
# a script to ssh multiple servers over multiple tmux panes
starttmux() {
if [ -z "$HOSTS" ]; then
echo -n "Please provide of list of hosts separated by spaces [ENTER]: "
@rdhabalia
rdhabalia / broker-deadlock.jstack
Created February 20, 2019 22:37
broker-deadlock.jstack
2019-02-20 18:20:56
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.131-b11 mixed mode):
"ForkJoinPool.commonPool-worker-31" #403 daemon prio=5 os_prio=0 tid=0x00002af194001000 nid=0x2fc1 waiting on condition [0x00002af0c6404000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x000000057d829960> (a java.util.concurrent.ForkJoinPool)
at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693)
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
@rdhabalia
rdhabalia / StuckTopicTest.java
Created January 23, 2019 18:59
@Test
public void testPartitionStuckTopic() throws Exception{
log.info("-- Starting {} test --", methodName);
int numPartitions = 2;
DestinationName dn = DestinationName.get("persistent://my-property/use/my-ns/my-partition");
ConsumerConfiguration conf = new ConsumerConfiguration();
conf.setSubscriptionType(SubscriptionType.Failover);
@rdhabalia
rdhabalia / bookkeeper.conf
Created January 15, 2019 02:33
bookkeeper.conf
#
#/**
# * Copyright 2007 The Apache Software Foundation
# *
# * Licensed to the Apache Software Foundation (ASF) under one
# * or more contributor license agreements. See the NOTICE file
# * distributed with this work for additional information
# * regarding copyright ownership. The ASF licenses this file
# * to you under the Apache License, Version 2.0 (the
# * "License"); you may not use this file except in compliance
@rdhabalia
rdhabalia / 18-Partitions-200K-publish-0.5KB-payload.yaml
Created January 15, 2019 02:28
18-Partitions-200K-publish-0.5KB-payload.yaml
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
@rdhabalia
rdhabalia / 18-Partitions-200K-publish-0.5KB-payload-Pulsar-2019-01-15-02-17-37.json
Created January 15, 2019 02:27
18-Partitions-200K-publish-0.5KB-payload-Pulsar-2019-01-15-02-17-37.json
{
"workload" : "1 producer / 1 consumers on 1 topic",
"driver" : "Pulsar",
"publishRate" : [ 85217.64057307634, 92356.1911412627, 97507.63537965644, 97488.1122879112, 110585.32136050497, 106260.98920231829, 104043.15782619169, 109230.0375557784, 101644.76285517756, 111720.36796405782, 109959.17717768563, 116301.85882174221, 87123.33975221429, 111534.98346120339, 94967.38442069707, 102181.2342328387, 100577.12798487266, 108490.14609865892, 98427.38988659414, 103518.21368766978, 105322.10867140935, 97769.29379086317, 103994.41687747125, 96166.31367578442, 99187.53526908005, 109513.73741660589, 94132.28580489557, 105765.49551503874, 105353.26821523774, 103100.7213080198, 102239.41166256336, 110474.24212080595, 105283.71367092757, 106368.17302195694, 106265.55116829649, 118815.93951463955, 121249.08123483814, 116784.75107991614, 113787.15134193268, 112524.25258505277, 109796.61986656192, 95855.76075994244, 101076.27622954918, 99546.80151250958, 93340.2078543188, 88354.35649715713, 96753.16095133426, 93467.7
@rdhabalia
rdhabalia / workload.yaml
Created January 7, 2019 22:49
workload.yaml
name: 1 topic / 1 partition / 1Kb / 80000 per second
topics: 1
partitionsPerTopic: 1
keyDistributor: "NO_KEY"
messageSize: 1024
payloadFile: "payload/payload-1Kb.data"
subscriptionsPerTopic: 1
consumerPerSubscription: 1
producersPerTopic: 1
@rdhabalia
rdhabalia / pulsar.yaml
Created January 7, 2019 22:47
pulsar.yaml
name: Pulsar
driverClass: io.openmessaging.benchmark.driver.pulsar.PulsarBenchmarkDriver
# Pulsar client-specific configuration
client:
serviceUrl: pulsar://ec2-52-32-131-68.us-west-2.compute.amazonaws.com:6650
httpUrl: http://ec2-52-32-131-68.us-west-2.compute.amazonaws.com:8080
ioThreads: 8
connectionsPerBroker: 8
namespacePrefix: benchmark/pulsar-cluster-1/ns
@rdhabalia
rdhabalia / broker.conf
Created January 7, 2019 22:32
broker.conf
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0