Was ist der Unterschied zwischen einem "Kafka Spout" und einem "Kafka Consumer"?

Question

sowohl "Kafka Spout" als auch "Kafka Consumer" rufen Daten von den Kafka Brokern ab, der Auslauf, den ich kenne, dient der Kommunikation mit Storm, und der Konsument ist mit was auch immer.

-aber immer noch, was ist der Unterschied technisch?

-oder was wäre der Unterschied zwischen Wenn ich die Daten mit einem Verbraucher herausgezogen dann erhalten sie mit einem "Storm Spout" und zwischen, wenn ich nur eine "Kafka Spout" dann fügen Sie es zu meinem Storm Topology Builder setSpout(); Funktion

-und wenn Consumer oder einen Kafka Spout

Answer 1

ein/der „Kafka Spout“ zu verwenden, ist ein Sturmspezifischen Adapter Daten von Kafka in einen Sturm Topologie zu lesen. Hinter den Kulissen verwendet der Kafka-Auslauf tatsächlich Kafkas eingebauten "Kafka Consumer" -Client.

Technisch besteht der Unterschied darin, dass der Kafka-Auslauf eine Art von Storm-bewussten "Wrapper" auf Kafkas Consumer-Client ist. In Storm sollten Sie in der Regel immer den mitgelieferten Kafka-Auslauf verwenden (siehe https://github.com/apache/storm/tree/master/external/storm-kafka oder für eine Auslaufimplementierung, die Kafkas sogenannten "neuen" Kunden-Client verwendet, https://github.com/apache/storm/tree/master/external/storm-kafka-client). Es wäre ein sehr seltener Fall, einen eigenen zu implementieren - der wahrscheinlichste Fall wäre, wenn es einen Fehler im bestehenden Kafka-Auslauf gäbe, den Sie bearbeiten müssen, bis das Storm-Projekt den Fehler stromaufwärts behebt.