Statements (33)
| Predicate | Object |
|---|---|
| gptkbp:instanceOf |
gptkb:software
|
| gptkbp:hasMethod |
gptkb:center
gptkb:survey subscribe seek commitAsync commitSync |
| https://www.w3.org/2000/01/rdf-schema#label |
KafkaConsumer
|
| gptkbp:implementedIn |
gptkb:Java
gptkb:Python |
| gptkbp:introducedIn |
Apache Kafka 0.9.0.0
|
| gptkbp:parameter |
auto.offset.reset
bootstrap.servers enable.auto.commit group.id key.deserializer value.deserializer |
| gptkbp:partOf |
gptkb:Apache_Kafka
|
| gptkbp:provides |
kafka-clients library
kafka-python library |
| gptkbp:replacedBy |
SimpleConsumer
|
| gptkbp:supports |
polling messages
subscribing to topics automatic offset management committing offsets manual offset management |
| gptkbp:threadSafe |
false
|
| gptkbp:usedFor |
consuming messages from Kafka topics
|
| gptkbp:usedIn |
stream processing
event-driven architectures data pipelines |
| gptkbp:bfsParent |
gptkb:Kafka_consumer_API
|
| gptkbp:bfsLayer |
8
|