.PHONY: build_connector

env:
	python3 -m venv env
	env/bin/pip3 install -r requirements.txt

connect:
	docker build --no-cache . --target connect -t kafka-connect-dynamodb-source

up:
	docker compose up -d --build --remove-orphans

down:
	docker-compose down

clean:
	rm -rf env

logs: ## View logs
	@docker-compose logs -f

shell: ## Spawn shell inside docker
	@docker-compose exec connect /bin/bash


create_topic:
	docker compose exec broker \
	  kafka-topics --create \
		--topic dynamodb-qa_pp_identity \
		--bootstrap-server broker:29092 \
		--replication-factor 1 \
		--partitions 1

list_topics:
	docker run --tty \
           --network dynamodb_source_default \
           confluentinc/cp-kafkacat:7.0.3 \
           kafkacat -b broker:29092 \
                    -L