V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX  ›  BBCCBB  ›  全部回复第 65 页 / 共 116 页
回复总数  2317
1 ... 61  62  63  64  65  66  67  68  69  70 ... 116  
2020-08-21 12:43:55 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
im 推消息, 量小, 所以还不想做路由中心. 所以采用广播.
2020-08-21 12:42:59 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@j2gg0s 业务场景你都不清楚你瞎 bb 个毛.
2020-08-21 11:37:57 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@yangbonis 是需要同一个服务不同实例都收到, 你说的这个大概是不同服务.
2020-08-21 11:32:54 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@mosesyou 我们将 docker 镜像上传到云上, 然后后续的流程我得研究一下, 问一下我们负责这一块的同事, 如果可行的话这得确是一个好办法. 多谢.
2020-08-21 11:13:58 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@zardly666 这个倒是可以做, 类似 snowflake 算法 workid 的生成. 但相对较麻烦, 老哥但还有没有简单点的解决办法啊 😿
@wisej consumergroup 堆积就是监控上看着有点慌. 磁盘会占用.
@sonice 额, 我们多个实例发布的时候重启, 那就会一次性有多个 old consumerGroup, 监控上看着蛇皮的很, 比较难搞.
@kifile 是, 这是一种方案, 但开发没有 KafkaAdmin 的权限, 所以代码里删除不掉, 只能手动了.... 哈哈


谢谢各位, 期待更好的方案 🐶
2020-08-21 10:19:32 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@mosesyou 这个业务场景需要同一个服务里的不同实例全都消费到每个 MQ
2020-08-21 10:08:29 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@SingeeKing 都是同一个服务, 不同实例,这个不方便给每个实例加环境变量, 哈哈

@hustmisa 可以丢弃, 因为应用上有 ack 超时重试机制, 要命的是重启后老的 groupId 不会自动心跳超时消失, 会在监控上看到消息不断堆积. 其实我想实现的就是 rocketmq 的广播的功能.. 但我们使用 kafka.
2020-08-21 09:53:11 +08:00
回复了 BBCCBB 创建的主题 Kafka [Kafka] 求助, 同一个服务如何组播消费 kafka 某个 topic 的消息呢?
@useben 这个在固定机器上是可以的, 但我们这里 docker 镜像每次都不知道到哪个机器上了. 😢
2020-08-18 20:04:32 +08:00
回复了 qiyue0726 创建的主题 Java JDK(EE)真的有人用吗
你要用额外的 jar 包才能用 servlet 啊. 那就是 java ee 的内容
2020-08-18 09:26:29 +08:00
回复了 swikis 创建的主题 职场话题 六个月试用期加试用期百分之八十工资的 offer 能接吗
不能..

6 个月肯定不打折才行.
我很少遇到试用期要打折的公司了...
2020-08-17 14:37:27 +08:00
回复了 rqxiao 创建的主题 Java 请教一般后端发送给前端消息该怎么实现
场景简单的话 server sent events 应该是简单靠谱的方案. 好像 twitter 都在用.
2020-08-17 14:32:14 +08:00
回复了 herozzm 创建的主题 健康 尿结石发了
笔误, 前几年.
2020-08-17 14:32:05 +08:00
回复了 herozzm 创建的主题 健康 尿结石发了
我前几天疼的时候, 10 多分钟就疼死了.. 去医院躺着碎结石, 碎着碎着躺上面就睡着了, 睡醒了就碎完了. 碎的过程一点都不疼..
2020-08-17 14:30:43 +08:00
回复了 herozzm 创建的主题 健康 尿结石发了
去医院吧, 分分钟就碎了..
2020-08-17 13:16:58 +08:00
回复了 amiwrong123 创建的主题 Java FutureTask 里使用普通语义而不是 CAS 写的原因是?
@amiwrong123 就我了解来说, 你的理解是对的, 这也是一个捎带同步的技巧..

你可以去看 happens before 规则里对 volatile 变量部分的描述.
2020-08-17 08:32:14 +08:00
回复了 amiwrong123 创建的主题 Java FutureTask 里使用普通语义而不是 CAS 写的原因是?
2020-08-17 08:31:43 +08:00
回复了 amiwrong123 创建的主题 Java FutureTask 里使用普通语义而不是 CAS 写的原因是?
手里的 jdk11 实现已经不是这个 putOrderedInt 了.
不过我感觉套路都差不多, 就是要么是在加锁里面执行的, 要么是有 volatile 字段更新, 捎带就把他的缓存给清了.
2020-08-14 15:26:31 +08:00
回复了 liubx 创建的主题 Java springcloud 服务下线,有什么好方法吗?
http://www.appblog.cn/2019/11/21/Spring%20Boot%202.0%20%E4%B9%8B%E4%BC%98%E9%9B%85%E5%81%9C%E6%9C%BA/

参考这个呢, 先从 eureka 下线, 再把 servlet 容器暂停, 等处理完剩下的请求就可以销毁了.
1 ... 61  62  63  64  65  66  67  68  69  70 ... 116  
关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   945 人在线   最高记录 6679   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 30ms · UTC 21:28 · PVG 05:28 · LAX 13:28 · JFK 16:28
Developed with CodeLauncher
♥ Do have faith in what you're doing.