기사 출처 python apache-kafka

아래 코드를 사용하여 주제에서 메시지를 읽습니다. 메시지를 읽은 후 어떻게 삭제합니까?
 

from kafka import KafkaConsumer


    consumer = KafkaConsumer('my-topic',
                             group_id='my-group',
                             bootstrap_servers=['localhost:9092'])
    for message in consumer:
        # message value and key are raw bytes -- decode if necessary!
        # e.g., for unicode: `message.value.decode('utf-8')`
        print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
                                              message.offset, message.key,
                                              message.value))

답

kafka에서 특정 메시지를 삭제하는 방법은 없습니다. kafka는 단순히 그렇게하도록 설계되지 않았습니다. 메시지를 삭제하는 유일한 방법은 kafka의 log.retention.hours에서 config/server.properties를 원하는 값으로 설정하는 것입니다. 기본값은 168입니다. 즉, 168 시간 후에 메시지가 보관되지 않습니다.

대신 특정 오프셋에서 메시지를 읽는 방법을 찾고 있다면 (즉, 처음부터 읽을 수없는 경우) 여기 http://kafka-python.readthedocs.org/en/master/apidoc/KafkaConsumer.html를보십시오.
commit()-kafka에 읽기 오프셋 커밋
seek_to_end()-새로 도착한 메시지 만 사용하도록 빨리 감기
seek()-지정된 오프셋으로 이동 (kafka가 아닌 다른 곳에 저장되어 있음)