Charles Hunt CharlesAHunt

## gist:fef763c7e395c028bb9c93fae5a21f45
### Keybase proof

I hereby claim:

  * I am charlesahunt on github.
  * I am charleshunt (https://keybase.io/charleshunt) on keybase.
  * I have a public key ASAf2sF41LjIJQwLsmBL1sALyUSKehSx8hLXWCU8k-qi_Ao

To claim this, I am signing this object:

## test.py
from airflow.operators.python_operator import PythonOperator
from airflow import DAG
from datetime import datetime, timedelta


default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2019, 1, 1),
    'email': ['support@tg.com'],

## KafkaConsumer.scala

import collection.JavaConverters._
object KafkaConsumer {

  val topicName = "yourTopicName"
  val partitionNumber = 1
  val offsetOnPoll = 10
  val topicPartition = new TopicPartition(topicName, partitionNumber)

  def main(args: Array[String]): Unit = {

## gist:b30487cdceb5ab43d9005964b47f262c
### Keybase proof

I hereby claim:

  * I am charlesahunt on github.
  * I am charlesahunt (https://keybase.io/charlesahunt) on keybase.
  * I have a public key ASDXn8Qb6gHbrcyr_Q0PERArlHwoG6IR9Gpz0Cu0IfM_Fgo

To claim this, I am signing this object:
	### Keybase proof

	I hereby claim:

	* I am charlesahunt on github.
	* I am charleshunt (https://keybase.io/charleshunt) on keybase.
	* I have a public key ASAf2sF41LjIJQwLsmBL1sALyUSKehSx8hLXWCU8k-qi_Ao

	To claim this, I am signing this object:
	from airflow.operators.python_operator import PythonOperator
	from airflow import DAG
	from datetime import datetime, timedelta


	default_args = {
	'owner': 'airflow',
	'depends_on_past': False,
	'start_date': datetime(2019, 1, 1),
	'email': ['support@tg.com'],

	import collection.JavaConverters._
	object KafkaConsumer {

	val topicName = "yourTopicName"
	val partitionNumber = 1
	val offsetOnPoll = 10
	val topicPartition = new TopicPartition(topicName, partitionNumber)

	def main(args: Array[String]): Unit = {