hocyadav

{
  "Comment": "A simple AWS Step Functions state machine that automates a call center support session.",
  "StartAt": "ProcessTransaction",
  "States": {
    "ProcessTransaction": {
        "Type" : "Choice",
        "Choices": [ 
          {
            "Variable": "$.TransactionType",
            "StringEquals": "PURCHASE",

hocyadav

{ 
   "Comment":"Transaction Processor State Machine Using SQS",
   "StartAt":"ProcessTransaction",
   "States":{ 
      "ProcessTransaction":{ 
         "Type":"Pass",
         "Next":"BroadcastToSqs"
      },
      "BroadcastToSqs":{ 
         "Type":"Task",

hocyadav

import java.util.concurrent.BlockingQueue;

public class ConsumerTask implements Runnable {

    private static final int H1 = 0;
    private static final int H2 = 1;
    private static final int H3 = 2;
    private static final int H4 = 3;

    final static int LIMIT = 100;

hocyadav

Kafka Distributed Streaming Platform

Publish and Subscribe / Process / Store

Start Kafka

• Kafka uses ZooKeeper as a distributed backend.

Start Zookeeper

hocyadav

### Aliases



# Open specified files in Sublime Text
# "s ." will open the current directory in Sublime
alias subl='open -a "Sublime Text"'
alias phpini='cd /usr/local/etc/php/7.1; subl php.ini'

# Color LS