Skip to content

Instantly share code, notes, and snippets.

View bsusensjackson's full-sized avatar
💭

brendan susens-jackson bsusensjackson

💭
View GitHub Profile
@bsusensjackson
bsusensjackson / kafka-cheat-sheet.md
Created February 7, 2019 20:49 — forked from ursuad/kafka-cheat-sheet.md
Quick command reference for Apache Kafka

Kafka Topics

List existing topics

bin/kafka-topics.sh --zookeeper localhost:2181 --list

Describe a topic

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic

Purge a topic

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000

... wait a minute ...

@bsusensjackson
bsusensjackson / test_dags.py
Created May 14, 2018 21:41 — forked from criccomini/test_dags.py
test_dags.py
import os
import unittest
from airflow.models import DagBag
class TestDags(unittest.TestCase):
"""
Generic tests that all DAGs in the repository should be able to pass.
"""