Aplicar os conceitos do curso Kafka utilizando outra linguagem

Olá, Edmar! Entendo sua preocupação e é completamente válida. Embora o curso esteja voltado para exemplos em Java, os conceitos principais do Kafka são aplicáveis a qualquer linguagem.

No caso do Python, você pode usar a biblioteca confluent-kafka-python, que é uma implementação do Apache Kafka que oferece uma interface de alto nível para o produtor, consumidor e administrador do Kafka.

Para implementar paralelismo em Python, você pode usar o módulo concurrent.futures. Aqui está um exemplo de como você pode implementar um consumidor Kafka com paralelismo:

from concurrent.futures import ThreadPoolExecutor
from confluent_kafka import Consumer, KafkaException

def process_message(msg):
    # Insira aqui o código para processar a mensagem
    pass

def consume_messages(consumer, executor):
    while True:
        msg = consumer.poll(1.0)
        if msg is None:
            continue
        if msg.error():
            if msg.error().code() == KafkaException._PARTITION_EOF:
                continue
            else:
                print(msg.error())
                break
        executor.submit(process_message, msg)

def main():
    consumer = Consumer({
        'bootstrap.servers': 'localhost:9092',
        'group.id': 'my-group',
        'auto.offset.reset': 'earliest',
    })
    consumer.subscribe(['my-topic'])

    executor = ThreadPoolExecutor(max_workers=5)
    consume_messages(consumer, executor)

if __name__ == '__main__':
    main()

Neste exemplo, estamos usando um ThreadPoolExecutor para processar as mensagens em paralelo. A função consume_messages recebe as mensagens e as envia para o executor para processamento.

Lembre-se de que este é apenas um exemplo e pode não funcionar perfeitamente em todos os casos, pois depende do seu caso de uso específico.

Espero ter ajudado e bons estudos!