Java? ???? Apache Kafka ???? ???? ???? ??? ??? ? ??? API? ???? ???? ?? ????? ???? ????. 1. ?? Kafka ????? ???? ???? ??? ????? ????????. 2. ???? ??? ? Bootstrap.servers, key.serializer and value.serializer? ???? ???? ??? ?? Kafkaproducer ????? ???? ??? ?? ??? ?? ?????? ??????. 3. ???? ????? Group.id, Deserializer ?? ?? ? ? Kafkaconsumer? ???? ??? ???? ??? ???? ???? ???? ???? ?????????. 4. ???? ???? Group.ID ??, ???? ???? ?? ? ??? ??? ?? ?? ?????. ?? ?? ??? ???? ?? ????? ????? ?? ????.

??? Java?? Apache Kafka ???? ???? ???? ?? ??? ????. ??? Kafka? ?? ??? ???? ??? ? ??? API? ??? ????? ? ????. ??? ???? ?? ?? ??? ??? ? ??? ??? ? ??? ?? ?? ? ? ????.

Kafka ???? ??????

?? ??? ???? ?? Kafka? ????? ?????? ????? ???????. Maven? ???? ?? pom.xml ? ?? ???? ?? ? ? ????.

 <???>
    <groupid> org.apache.kafka </groupid>
    <artifactid> kafka-clients </artifactid>
    <??> 3.6.0 </??>
</???>

? ??? ??? ??? ??? ??????. ?? Kafka ???? ??? ???? ?? ????? ??? ??? ?? ????.

Kafka ????? ??????

????? ??? Kafka ??? ???? ??? ????. ?? ???? ?? ??, ??? ???? ??, ??? ??? ?? ? ??? ?????.

?? ?? ??? ??? ????.

• bootstrap.servers : Kafka ??? ??
• key.serializer ? value.serializer : ?? ?? ??? ??? ??????. StringSerializer ????? ?????.

?? ??? ??? ????.

 ?? propss = ??? ?? ();
props.put ( "bootstrap.servers", "localhost : 9092");
props.put ( "key.serializer", "org.apache.kafka.common.serialization.stringserializer");
props.put ( "value.serializer", "org.apache.kafka.common.serialization.stringserializer");

Producer <String, String> Producer = New Kafkaproducer <> (Props);
ProduceRrecord <string, String> record = new ProducerRecord <> ( "my-topic", "key", "value");

Producer.Send (???);
Producer.Close ();

????? ? :

• ?? ??? ??? ?? ??? ? close() ???? ?? ?? ????.
• ??? ?? ??? ????? ?? ??? ?? ? ? ???? .send .send(record, callback)
• ?? ??? ? ?? ?? ?? ? ? ????.

??? ???? ??????

???? Kafka ???? ???? ?? ??? ????. ???? ??? ? ???? ??? ???? ????? ???? ??? ?? ?? ????? ??? ?? ? ?????.

?? ???? ??? ?????.

• bootstrap.servers : ??? ??? ?????
• group.id : ??? ?? ID, ???????. ??? ??? ?? ??????.
• key.deserializer and value.deserializer : ????? StringDeserializer ???? Deserializer

??? ??? ????? ??? ????.

 ?? propss = ??? ?? ();
props.put ( "bootstrap.servers", "localhost : 9092");
props.put ( "group.id", "test-group");
props.put ( "key.deserializer", "org.apache.kafka.common.serialization.stringdeserializer");
props.put ( "value.deserializer", "org.apache.kafka.common.serialization.stringdeserializer");

Kafkaconsumer <String, String> Consumer = New Kafkaconsumer <> (props);
??? .subscribe (collections.singletonlist ( "my-topic"));

while (true) {
    ConsidErrecords <String, String> Records = Consumer.poll (duration.ofmillis (100));
    for (considerRecord <string, String> ??? : ???) {
        System.out.println ( "?? :"record.value ());
    }
}

??:

• poll() ???? ??? ??? ??? ??? ?????.
• ?? ? ???? ???? ?? ?? ????. ?? ?? ???? ??? ? ????.
• ? ?? ?? ? ?? ????? ?? ? ??? ?? ? ????.

?? ?? ??? ?? ??

??? ???? ???? ???? ????? ?????? ????, ?? ????? ??? ?? ??? ?? ?????.

• ??? ??. ID ?? ?? ?? ??
• ??? ???? ???? ???? ?? ??? ?? ????.
• ??? ?? ???? ???? ???? ??? ???? ?? ??????.
• Kafka Broker? ???? ???? ????? ???? ?? ????.

?? ?? ?? ?? ??? ??? ?? ? ?? ????? ???? ?? ????.

????? ?? ??. Java?? Kafka? ???? ??? ???? ??? ???, Group.id ? ?? ??? ?? ?? ?? ??? ???? ????. ?? ? ???????? ???? ? ??? ??? ? ????.

? ??? Java? ?? Apache Kafka? ???? ???? ???? ???? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!