<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def get_kafka_producer(acks='all', value_serializer=lambda v: json.dumps(v).encode('utf-8')):
 """ Return a KafkaProducer that uses the SSLContext created with create_ssl_context. """


    producer = KafkaProducer(
        bootstrap_servers=get_kafka_brokers(),
        security_protocol='SSL',
        ssl_context=get_kafka_ssl_context(),
        value_serializer=value_serializer,
        acks=acks
    )

    return producer