CommunityTeamEnterprise

Extended examples

Interactive examples!

All examples on this page are fully interactive! You can modify both the kJQ filter and the JSON data in real-time to see how different filters work.

Changes update instantly as you type, making it easy to experiment and learn kJQ syntax.

Type conversion transforms

Converting data types

Transform and validate data types in Kafka messages:

JSON Input

{
  "key": {
    "partition": 0
  },
  "value": {
    "user_id": 123456,
    "action": "login",
    "timestamp": "2023-06-20T10:30:00Z"
  }
}

Filter Result

Parsing nested JSON

Extract data from JSON strings within Kafka messages:

JSON Input

{
  "key": {
    "event_type": "user_action"
  },
  "value": {
    "user_id": "12345",
    "metadata": "{\"user_preferences\": {\"theme\": \"dark\", \"notifications\": true}, \"device\": \"mobile\"}"
  }
}

Filter Result

Date and time operations

Current time filtering

Filter recent events using now:

JSON Input

{
  "key": {
    "stream": "user_events"
  },
  "value": {
    "event": "page_view",
    "created_at": "2023-06-20T15:30:00Z",
    "user_id": "12345"
  }
}

Filter Result

Duration-based filtering

Find sessions lasting more than 30 minutes:

JSON Input

{
  "key": {
    "session_type": "user_session"
  },
  "value": {
    "session_id": "sess_12345",
    "start_time": "2023-06-20T14:00:00Z",
    "end_time": "2023-06-20T14:45:00Z",
    "user_id": "user_789"
  }
}

Filter Result

Numeric operations

Statistical analysis

Find maximum transaction amounts:

JSON Input

{
  "key": {
    "date": "2023-06-20"
  },
  "value": {
    "user_id": "premium_user",
    "daily_transactions": [
      150,
      200,
      1250,
      75,
      300
    ],
    "total_spent": 1975
  }
}

Filter Result

Financial calculations

Calculate and validate price ranges:

JSON Input

{
  "key": {
    "product_category": "electronics"
  },
  "value": {
    "product_id": "ELEC12345",
    "prices": [
      12.99,
      15.5,
      18.25,
      22
    ],
    "currency": "USD"
  }
}

Filter Result

String operations

Text processing pipeline

Clean and validate user input:

JSON Input

{
  "key": {
    "post_id": "post_12345"
  },
  "value": {
    "user_id": "user_789",
    "comment": "  this is a great product!  ",
    "rating": 5
  }
}

Filter Result

String validation chain

Validate email domains after cleaning:

JSON Input

{
  "key": {
    "signup_event": "new_user"
  },
  "value": {
    "email": "John.Doe@Company.com    ",
    "department": "engineering",
    "join_date": "2023-06-20"
  }
}

Filter Result

Array operations

Data processing pipeline

Process and analyze arrays in Kafka messages:

JSON Input

{
  "key": {
    "alert_type": "system"
  },
  "value": {
    "message": "Database connection timeout",
    "tags": [
      "database",
      "timeout",
      "urgent",
      "production"
    ],
    "severity": "high"
  }
}

Filter Result

Unique values analysis

Find unique visitor countries:

JSON Input

{
  "key": {
    "analytics_period": "daily"
  },
  "value": {
    "date": "2023-06-20",
    "visitor_countries": [
      "US",
      "CA",
      "UK",
      "DE",
      "US",
      "FR",
      "CA",
      "JP",
      "AU"
    ],
    "total_visitors": 1250
  }
}

Filter Result

Array flattening

Process nested category structures:

JSON Input

{
  "key": {
    "product_sync": "categories"
  },
  "value": {
    "product_id": "PROD12345",
    "nested_categories": [
      [
        "electronics",
        "computers"
      ],
      [
        "hardware",
        "laptops",
        "gaming"
      ],
      [
        "accessories",
        "keyboards",
        "mice"
      ]
    ]
  }
}

Filter Result

Object operations

Key-value analysis

Analyze configuration changes:

JSON Input

{
  "key": {
    "service": "user_service"
  },
  "value": {
    "deployment_id": "deploy_789",
    "config_changes": {
      "database.timeout": 5000,
      "cache.ttl": 3600,
      "api.rate_limit": 1000,
      "logging.level": "INFO",
      "feature.new_ui": true
    }
  }
}

Filter Result

Value extraction

Extract and validate configuration values:

JSON Input

{
  "key": {
    "config_update": "server_settings"
  },
  "value": {
    "timestamp": "2023-06-20T10:30:00Z",
    "settings": {
      "connection_pool": 100,
      "timeout_ms": 5000,
      "max_requests": 1000
    }
  }
}

Filter Result

Advanced math operations

Modulo operations

Partition data based on user ID:

JSON Input

{
  "key": {
    "routing": "user_partition"
  },
  "value": {
    "user_id": "1024",
    "action": "purchase",
    "amount": 99.99
  }
}

Filter Result

Quotient and remainder

Analyze batch processing metrics:

JSON Input

{
  "key": {
    "batch_stats": "processing_complete"
  },
  "value": {
    "batch_id": "batch_789",
    "total_records": 5050,
    "processing_time_ms": 45000,
    "errors": 2
  }
}

Filter Result

Object functions

Contains key

Checks for the presence of a key:

JSON Input

{
  "key": {
    "user_event": "permission_check"
  },
  "value": {
    "user_id": "user_456",
    "active_permissions": {
      "read_access": "2023-06-20T10:00:00Z",
      "write_access": "2023-06-20T10:00:00Z",
      "admin_access": "2023-06-15T08:00:00Z"
    }
  }
}

Filter Result

Containment checks

Validate if current value exists in allowed lists:

JSON Input

{
  "key": {
    "geo_validation": "allowed_regions"
  },
  "value": {
    "user_id": "international_user",
    "country_code": "CA",
    "timezone": "America/Toronto"
  }
}

Filter Result

String inside

Check if an error code exists within a larger error classification string:

JSON Input

{
  "key": {
    "request_id": "req_12345"
  },
  "value": {
    "service": "payment_processor",
    "error_code": "ERROR_CODE_001",
    "message": "Database connection timeout during payment processing",
    "retry_count": 2,
    "timestamp": "2023-06-20T15:30:00Z"
  }
}

Filter Result

String functions

Advanced string matching

Complex domain validation:

JSON Input

{
  "key": {
    "email_validation": "corporate"
  },
  "value": {
    "user_id": "emp_12345",
    "email": "john.doe@corp-internal.com",
    "department": "engineering"
  }
}

Filter Result

Pattern matching

Validate transaction IDs with regex:

JSON Input

{
  "key": {
    "payment_validation": "format_check"
  },
  "value": {
    "transaction_id": "TXN-1234-AB",
    "amount": 250,
    "currency": "USD",
    "status": "pending"
  }
}

Filter Result

Text analysis

Check if error messages contain specific terms:

JSON Input

{
  "key": {
    "error_analysis": "retry_logic"
  },
  "value": {
    "service": "payment_processor",
    "error_message": "Connection TIMEOUT occurred during processing",
    "retry_count": "2",
    "timestamp": "2023-06-20T10:30:00Z"
  }
}

Filter Result

Array to string conversion

Join tags for search indexing:

JSON Input

{
  "key": {
    "alert_indexing": "search_terms"
  },
  "value": {
    "alert_id": "alert_789",
    "message": "High CPU usage detected",
    "tags": [
      "production",
      "critical",
      "cpu",
      "monitoring"
    ]
  }
}

Filter Result

Utility operations

Empty value detection

Filter out incomplete records:

JSON Input

{
  "key": {
    "data_quality": "completeness_check"
  },
  "value": {
    "product_id": "PROD789",
    "description": "High-quality wireless headphones",
    "metadata": {
      "brand": "TechCorp",
      "model": "WH-1000"
    }
  }
}

Filter Result

Tagged literals

Date literals

Compare against specific dates:

JSON Input

{
  "key": {
    "product_release": "q2_2023"
  },
  "value": {
    "product_id": "PROD2023Q2",
    "launch_date": "2023-06-15T09:00:00Z",
    "status": "launched"
  }
}

Filter Result

UUID literals

Match specific system-generated IDs:

JSON Input

{
  "key": {
    "system_event": "maintenance"
  },
  "value": {
    "system_id": "550e8400-e29b-41d4-a716-446655440000",
    "maintenance_type": "scheduled",
    "duration_minutes": 30
  }
}

Filter Result

Complex real-world examples

E-commerce order processing

Multi-condition validation for order processing:

JSON Input

{
  "key": {
    "order_type": "premium_shipping"
  },
  "value": {
    "order": {
      "id": "ORD12345",
      "total_amount": "75.50",
      "items": [
        {
          "sku": "ITEM1",
          "price": "25.00"
        },
        {
          "sku": "ITEM2",
          "price": "50.50"
        }
      ]
    },
    "customer": {
      "id": "CUST789",
      "tier": "gold"
    },
    "shipping": {
      "country_code": "US",
      "method": "express"
    }
  }
}

Filter Result

IoT sensor data analysis

Log analysis and alerting

Parse and analyze application logs:

JSON Input

{
  "key": {
    "log_type": "application_error"
  },
  "value": {
    "service_name": "user-service-v2",
    "log_level": "ERROR",
    "message": "Database connection pool exhausted - unable to acquire connection",
    "occurred_at": "2023-06-20T15:28:00Z",
    "request_id": "req_789456",
    "user_id": "user_12345"
  }
}

Filter Result

Type conversion transforms​

Converting data types​

Parsing nested JSON​

Date and time operations​

Current time filtering​

Duration-based filtering​

Numeric operations​

Statistical analysis​

Financial calculations​

String operations​

Text processing pipeline​

String validation chain​

Array operations​

Data processing pipeline​

Unique values analysis​

Array flattening​

Object operations​

Key-value analysis​

Value extraction​

Advanced math operations​

Modulo operations​

Quotient and remainder​

Object functions​

Contains key​

Containment checks​

String inside​

String functions​

Advanced string matching​

Pattern matching​

Text analysis​

Array to string conversion​

Utility operations​

Empty value detection​

Tagged literals​

Date literals​

UUID literals​

Complex real-world examples​

E-commerce order processing​

IoT sensor data analysis​

Log analysis and alerting​

Type conversion transforms

Converting data types

Parsing nested JSON

Date and time operations

Current time filtering

Duration-based filtering

Numeric operations

Statistical analysis

Financial calculations

String operations

Text processing pipeline

String validation chain

Array operations

Data processing pipeline

Unique values analysis

Array flattening

Object operations

Key-value analysis

Value extraction

Advanced math operations

Modulo operations

Quotient and remainder

Object functions

Contains key

Containment checks

String inside

String functions

Advanced string matching

Pattern matching

Text analysis

Array to string conversion

Utility operations

Empty value detection

Tagged literals

Date literals

UUID literals

Complex real-world examples

E-commerce order processing

IoT sensor data analysis

Log analysis and alerting