2 Star 12 Fork 23

巨轮/LearnKafka

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
image
src/main/java/com/lun/kafka
consumer
interceptor
CounterInterceptor.java
TimeInterceptor.java
producer
README.md
StartKafka.py3
StartKafkaCluster.py3
pom.xml
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
TimeInterceptor.java 914 Bytes
一键复制 编辑 原始数据 按行查看 历史
巨轮 提交于 5年前 . First commit
package com.lun.kafka.interceptor;
import java.util.Map;
import org.apache.kafka.clients.producer.ProducerInterceptor;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
public class TimeInterceptor implements ProducerInterceptor<String, String> {
@Override
public void configure(Map<String, ?> configs) {
}
@Override
public ProducerRecord<String, String> onSend(ProducerRecord<String, String> record) {
// 创建一个新的 record,把时间戳写入消息体的最前部
return new ProducerRecord(record.topic(), record.partition(), record.timestamp(), record.key(),
"TimeInterceptor: " + System.currentTimeMillis() + "," + record.value().toString());
}
@Override
public void close() {
}
@Override
public void onAcknowledgement(RecordMetadata metadata, Exception exception) {
// TODO Auto-generated method stub
}
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/jallenkwong/LearnKafka.git
git@gitee.com:jallenkwong/LearnKafka.git
jallenkwong
LearnKafka
LearnKafka
master

搜索帮助