In [1]:

    

from kafka import KafkaConsumer, KafkaProducer


    

In [2]:

    

servers = '192.168.99.100:9092'


    

In [3]:

    

producer = KafkaProducer(bootstrap_servers=servers)


    

    




WARNING:kafka.cluster:No broker metadata found in MetadataResponse
WARNING:kafka.conn:Kafka 0.8.2 quirk -- GroupCoordinatorResponse coorelation id does not match request. This should go away once at least one topic has been initialized on the broker

In [4]:

    

producer.config


    

    
Out[4]:





{'acks': 1,
 'api_version': (0, 8, 2),
 'batch_size': 16384,
 'bootstrap_servers': '192.168.99.100:9092',
 'buffer_memory': 33554432,
 'client_id': 'kafka-python-producer-1',
 'compression_type': None,
 'connections_max_idle_ms': 600000,
 'key_serializer': None,
 'linger_ms': 0,
 'max_block_ms': 60000,
 'max_in_flight_requests_per_connection': 5,
 'max_request_size': 1048576,
 'metadata_max_age_ms': 300000,
 'partitioner': <kafka.partitioner.default.DefaultPartitioner at 0x1066d5898>,
 'receive_buffer_bytes': None,
 'reconnect_backoff_ms': 50,
 'request_timeout_ms': 30000,
 'retries': 0,
 'retry_backoff_ms': 100,
 'send_buffer_bytes': None,
 'value_serializer': None}

In [5]:

    

for i in range(100):
    producer.send('test', key=b'foo', value=b'bar')


    

In [6]:

    

producer.close()


    

In [3]:

    

consumer = KafkaConsumer('feed_items', bootstrap_servers=servers)


    

In [ ]:

    

for msg in consumer:
    print(msg)


    

In [ ]: