Express YourSelf !

• Lambda is a special type of Python function that have limited capabilities.
• A function that will be used only once in your program. These functions are called anonymous or unbound functions.

• Lambda functions can accept zero or more arguments but only one expression
• Here return statement is implicit.
• Lambda function can be declared and invoke together also

• If it doesn’t return a value, 
• If it isn’t an expression and can’t be put into a lambda
• You can only use expressions, but not statements.
• lambda function with multiple lines/expressions/statements is not possible
• You cannot declare and use local variables.

• If you can imagine it in an assignment statement, on the right-hand side of the equals sign, it is an expression and can be put into a lambda.
• lambda can be member of list, dictionary 
• You can only use one expression.

• One can pass functions as arguments to other functions
• A function can be the return value of another function.
• The expression returns (or evaluates to) a value, whereas a statement does not. 

• Jython : Python to Java ByteCode, that runs on JVM
• IronPython : Python to .NET, that runs on CLR
• RPython to build PyPy interpreter. 
• - Python to Java Byte Code
• - Python to .NET CLR
• - Python to C
• Pyjs: Python to JavaScript
• Cython, Pyrex: Python to C
• Cython, Pythran, Shed Skin: Python to C+
• Google's Grumpy: Python to Go
• MyHDL: Python to VHDL
• Stakeless Python: CPython for coroutines
• MicroPython: Python for Microcontroller
• Unladen Swallow: Performance oriented CPython 

from time import sleep
from json import dumps, loads
from kafka import KafkaProducer, KafkaConsumer

producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                         value_serializer=lambda x: 
                         dumps(x).encode('utf-8'))

for e in range(1000):
    data = {'number' : e}
    producer.send('numtest', value=data)
    sleep(5)

consumer = KafkaConsumer(
    'numtest',
     bootstrap_servers=['localhost:9092'],
     auto_offset_reset='earliest',
     enable_auto_commit=True,
     group_id='my-group',
     value_deserializer=lambda x: loads(x.decode('utf-8'))

for message in consumer:
    message = message.value
    collection.insert_one(message)
    print('{} added to {}'.format(message, collection))