abhirockzz

#------------ bootstrap the cluster nodes --------------------

start_cmd='redis-server --port 6379 --cluster-enabled yes --cluster-config-file nodes.conf --cluster-node-timeout 5000 --appendonly yes'
redis_image='redis:5.0-rc'
network_name='redis_cluster_net'

docker network create $network_name
echo $network_name " created"

#---------- create the cluster ------------------------

abhirockzz

import java.util.Collections;
import java.util.List;
import java.util.Objects;
import java.util.function.Predicate;

public class RandomGist {

    public static <T> T requireNonEmpty(T object, Predicate<T> predicate, String msgToCaller){
        Objects.requireNonNull(object);
        Objects.requireNonNull(predicate);

abhirockzz

Dapr NATS Streaming pubsub component config

Configuration parameters

• natsURL

  • description: NATS server URL
  • required: yes
  • sample value: nats://demo.nats.io:4222

• natsStreamingClusterID

abhirockzz

apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: azure-disk-pvc
spec:
  storageClassName: ""
  accessModes:
    - ReadWriteOnce
  resources:
    requests:

abhirockzz

apiVersion: v1
kind: PersistentVolume
metadata:
  name: azure-disk-pv
spec:
  capacity:
    storage: 2Gi
  storageClassName: ""
  volumeMode: Filesystem
  accessModes:

abhirockzz

spec:
containers:
- name: kstreams-lower-to-upper
    image: [REPLACE_ACR_NAME].azurecr.io/kstreams-lower-to-upper:v1
    env:
    - name: KAFKA_BROKER
        value: [to be filled]

abhirockzz

apiVersion: v1
kind: ConfigMap
metadata:
  name: config3
data:
  appconfig.json: |
    {
      "array": [
        1,
        2,

abhirockzz

apiVersion: apps/v1
kind: Deployment
metadata:
  name: kin-stateless-depl
spec:
  replicas: 2
  selector:
    matchLabels:
      app: kin-stateless-depl
  template:

abhirockzz

apiVersion: apps/v1
kind: ReplicaSet
metadata:
  name: kin-stateless-rs
spec:
  replicas: 2
  selector:
    matchLabels:
      app: kin-stateless-rs
  template:

abhirockzz

apiVersion: v1
kind: Pod
metadata:
  name: kin-stateless-1
spec:
  containers:
  - name: nginx
    image: nginx