kafka(2).zip

资源文件列表(大概)

文件名

大小

kafka/

kafka/.idea/

kafka/.idea/compiler.xml

637B

kafka/.idea/libraries/

kafka/.idea/libraries/Maven__com_github_luben_zstd_jni_1_5_0_2.xml

541B

kafka/.idea/libraries/Maven__org_apache_kafka_kafka_clients_3_0_0.xml

562B

kafka/.idea/libraries/Maven__org_lz4_lz4_java_1_7_1.xml

491B

kafka/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_30.xml

513B

kafka/.idea/libraries/Maven__org_xerial_snappy_snappy_java_1_1_8_1.xml

566B

kafka/.idea/misc.xml

366B

kafka/.idea/modules.xml

257B

kafka/.idea/workspace.xml

24.53KB

kafka/kafka.iml

1.36KB

kafka/pom.xml

665B

kafka/src/

kafka/src/main/

kafka/src/main/java/

kafka/src/main/java/com/

kafka/src/main/java/com/gansu/

kafka/src/main/java/com/gansu/kafka/

kafka/src/main/java/com/gansu/kafka/producter/

kafka/src/main/java/com/gansu/kafka/producter/CustomProducerParameters.java

1.85KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducerTransactions.java

1.89KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducter.java

1.19KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducterAcks.java

1.67KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducterCallbacck.java

2.04KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducterCallbackPartitions.java

2.3KB

kafka/src/main/java/com/gansu/kafka/producter/CustomProducterSycn.java

1.5KB

kafka/src/main/java/com/gansu/kafka/producter/MyPartitioner.java

1.4KB

kafka/src/main/resources/

kafka/src/test/

kafka/src/test/java/

kafka/target/

kafka/target/classes/

kafka/target/classes/com/

kafka/target/classes/com/gansu/

kafka/target/classes/com/gansu/kafka/

kafka/target/classes/com/gansu/kafka/producter/

kafka/target/classes/com/gansu/kafka/producter/CustomProducerParameters.class

1.8KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducerTransactions.class

2.22KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducter.class

1.78KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterAcks.class

1.92KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterCallbacck$1.class

1.38KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterCallbacck.class

2.02KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterCallbackPartitions$1.class

1.42KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterCallbackPartitions.class

2.07KB

kafka/target/classes/com/gansu/kafka/producter/CustomProducterSycn.class

1.92KB

kafka/target/classes/com/gansu/kafka/producter/MyPartitioner.class

1.29KB

kafka/target/generated-sources/

kafka/target/generated-sources/annotations/

资源内容介绍

kafka(2).zip

package com.gansu.kafka.producter;import org.apache.kafka.clients.producer.*;import org.apache.kafka.common.serialization.StringSerializer;import java.util.Properties;public class CustomProducterCallbackPartitions { public static void main(String[] args) throws InterruptedException { // 1. 创建kafka生产者的配置对象 Properties properties = new Properties(); // 2. 给kafka配置对象添加配置信息：bootstrap.servers properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.10.102:9092"); //关联添加自定义分区器 properties.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, "com.gansu.kafka.producter.MyPartitioner"); // key,value序列化（必须）：key.serializer，value.serializer properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName()); // 3. 创建kafka生产者对象 KafkaProducer<String, String> kafkaProducer = new KafkaProducer<>(properties); // 4. 调用send方法,发送消息 for (int i = 0; i < 3; i++) { // 指定数据发送到1号分区，key为空（IDEA中ctrl + p查看参数） // 依次指定key值为a,b,f ，数据key的hash值与3个分区求余，分别发往1、2、0 kafkaProducer.send(new ProducerRecord<String,String>("first","root001"+i) // 添加回调 , new Callback(){ // 该方法在Producer收到ack时调用，为异步调用 @Override public void onCompletion(RecordMetadata metadata, Exception exception) { if(exception == null){ // 没有异常,输出信息到控制台 System.out.println("主题是"+metadata.topic()+",分区是"+metadata.partition()); }else{ // 出现异常打印 exception.printStackTrace(); } } }); // 延迟一会会看到数据发往不同分区 // Thread.sleep(10); } // 5. 关闭资源 kafkaProducer.close(); }}

用户评论 (0)

发表评论

您的昵称:

评分

评论内容:

验证码:

kafka(2).zip

资源文件列表(大概)

资源内容介绍

用户评论 (0)

发表评论

相关资源

Flux Modelscope 本地部署

library demo - OUC c#大作业

车险索赔预测-可使用数据集

springboot集成neo4j，使用继承Neo4jRepository的方式来实现对数据的操作