Updates to readme and python files

samples/kafka/python/README.md

@@ -4,8 +4,6 @@ One of the key benefits of using Kafka is the number of ecosystems it can connec
 
 This tutorial will show how to connect Confluent's Apache Kafka Python client to Kafka-enabled Event Hubs without changing your protocol clients or running your own clusters. Azure Event Hubs for Apache Kafka Ecosystems supports [Apache Kafka version 1.0.](https://kafka.apache.org/10/documentation.html)
 
-***This sample is still a work in progress. Your mileage may vary, and your feedback is appreciated!***
-
 ## Prerequisites
 
 If you don't have an Azure subscription, create a [free account](https://azure.microsoft.com/free/?ref=microsoft.com&utm_source=microsoft.com&utm_medium=docs&utm_campaign=visualstudio) before you begin.
@@ -59,4 +57,4 @@ python consumer.py <your-consumer-group> <topic.1> <topic.2> ... <topic.n>
 
 * [Confluent's Apache Kafka Python client](https://github.com/confluentinc/confluent-kafka-python)
 	* This repo's producer is based on [Confluent's samples](https://github.com/confluentinc/confluent-kafka-python/tree/master/examples)
-* [librdkafka](https://github.com/edenhill/librdkafka)
+* [librdkafka](https://github.com/edenhill/librdkafka)

samples/kafka/python/consumer.py

@@ -62,7 +62,6 @@ def print_usage_and_exit(program_name):
         'group.id': group,
         'client.id': 'python-example-consumer',
         'request.timeout.ms': 60000,
-        'session.timeout.ms': 6000,
         'default.topic.config': {'auto.offset.reset': 'smallest'}
     }
 
@@ -117,9 +116,6 @@ def print_assignment(consumer, partitions):
                     raise KafkaException(msg.error())
             else:
                 # Proper message
-                sys.stderr.write('%% %s [%d] at offset %d with key %s:\n' %
-                                 (msg.topic(), msg.partition(), msg.offset(),
-                                  str(msg.key())))
                 print(msg.value())
 
     except KeyboardInterrupt:

samples/kafka/python/producer.py

@@ -63,3 +63,4 @@ def delivery_callback (err, msg):
     #Wait until all messages have been delivered
     sys.stderr.write ('%% Waiting for %d deliveries\n' % len (p))
     p.flush ()
+