antunesleo

import json
import sys

from kafka import KafkaProducer

from outboxexample import settings

import signal

producer = KafkaProducer(bootstrap_servers=[settings.KAFKA_HOST])

antunesleo

import json

from kafka import KafkaConsumer

from outboxexample import settings

print("starting consumer", settings.KAFKA_HOST)

NOTES_TOPIC = "notes"

antunesleo

version: '3.7'

networks:
  my_network:

services:
  zookeeper:
    image: confluentinc/cp-zookeeper:latest
    hostname: zookeeper
    environment:

antunesleo

mkdir django-jaiminho-outbox-example
cd django-jaiminho-outbox-example
pip install django==4.2
django-admin startproject outboxexample .
python manage.py startapp notes

antunesleo

├── notes
│   ├── admin.py
│   ├── apps.py
│   ├── __init__.py
│   ├── kafka_producer.py
│   ├── migrations
│   │   ├── 0001_initial.py
│   │   ├── __init__.py
│   ├── models.py
│   ├── tests.py

antunesleo

touch requirements.txt

antunesleo

docker-compose up

antunesleo

relayer:
  build: .
  command: python manage.py events_relay --run-in-loop
  volumes:
    - .:/app
  env_file:
    - .env
  depends_on:
    kafka:
      condition: service_healthy

antunesleo

python manage.py migrate

antunesleo

from jaiminho.constants import PublishStrategyType

JAIMINHO_CONFIG = {
   "PUBLISH_STRATEGY": PublishStrategyType.KEEP_ORDER,
}