updated producer to take all kafka producer options
update tests to reflect serializer class change
added consumer_id group options
added consumer_id group options