26
4
Just getting started with Apache Kafka (v 3.5.1), using only console for the moment.
刚刚开始使用ApacheKafka(v3.5.1)，目前只使用控制台。
So, I've created a topic with 3 partitions,
所以，我创建了一个带有3个分区的主题，
kafka-topics.sh --topic t_3 --create --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1
Kafka-topics.sh--主题t_3--创建--引导--服务器本地主机：9092--分区3--复制因子1
Then created three consumers in the same group:
然后在同一组中创建了三个消费者：
kafka-console-consumer.sh --topic t_3 --bootstrap-server localhost:9092 --group group_one
Kafka-Console-Consumer er.sh--主题t_3--引导-服务器本地主机：9092--group group_one
Then created producer:
然后创建了制片人：
kafka-console-producer.sh --topic t_3 --bootstrap-server localhost:9092
Kafka-控制台-Producer.sh--主题t_3--引导-服务器本地主机：9092
But the group isn't balanced, as it was expected. When I produce messages, they all go to one consumer. When I stop one of the consumers, messages start to go to both consumers that are left, I mean every message received by both consumers.
但这一群体并不像预期的那样平衡。当我产生信息时，它们都会流向一个消费者。当我阻止其中一个消费者时，消息开始发送给剩下的两个消费者，我是说两个消费者收到的每条消息。
I thought in this case, each consumer should receive message only from its own partition, and producer must write messages to partions by round-robin. What do I do wrong?
我认为在这种情况下，每个消费者应该只从自己的分区接收消息，而生产者必须以循环的方式向分区写入消息。我做错了什么？
P.S. In Kafka log I see this phrase when adding new consumer: rebalance failed due to MemberIdRequiredException. But I can't figure out, what do I do wrong, cause all the docs and answers and videos tell, that expected behaviour with default configurations is just as what I thought it should be.
附注：在Kafka日志中，我在添加新的消费者时看到这样一句话：由于MemberIdRequiredException，重新平衡失败。但我不知道我做错了什么，因为所有的文档、答案和视频都告诉我，默认配置的预期行为与我想象的一样。
producer must write messages to partions by round-robin
How old are the docs / videos you're seeing? StickyPartitioner was added around v2.4, which changed how records are batched together in a producer , and only get sent to one partition, rather than having each message being round robined. This ultimately results in less network requests being spread out over the whole cluster. From a consumer perspective, this should be transparent as all brokers should be considered equal.
你看到的文档/视频有多老？StickyPartitioner是在v2.4左右添加的，它改变了记录在生产者中批量处理的方式，并且只发送到一个分区，而不是让每个消息都进行循环。这最终会导致更少的网络请求分布在整个集群上。从消费者的角度来看，这应该是透明的，因为所有经纪人都应该被视为平等的。
If data is only produced to one partition (you could check that too), then only that assigned consumer would read that (it shouldn't go to multiple partitions without multiple batches).
如果数据只生成到一个分区(您也可以检查这一点)，那么只有分配的使用者才会读取该数据(它不应该在没有多个批处理的情况下访问多个分区)。
In other words, consumers in a group are rarely truly "balanced" since data is only ever written to a leader partition, and that partition could have more data sent to it than others.
换句话说，组中的消费者很少是真正“平衡”的，因为数据只被写入引导者分区，而该分区可能比其他分区发送到它的数据更多。
26
4
0
我想编写一个 linq 表达式，该表达式将返回不包含特定值的 ID。例如，我想返回所有不具有 Value = 30 的不同 ID。 ID, Value 1, 10 1, 20 1, 30 2,
我正在尝试使用 Regexp 匹配 Nmap 命令的输出。可以有两种不同的格式。 第一种格式(当 nmap 可以找到主机名时) Nmap scan report for 2u4n32t-n4 (192
我正在 Visual Studio 2012 上使用 C# 开发一个软件。我使用 MySQL Connector 6.9.1 进行 MySQL 连接。我的软件在我的操作系统(Win8 x64)上运行顺
在 Django 中(使用 django.contrib.auth 时)我可以添加一个 Group到另一个 Group ?即一个Group成为另一个成员(member) Group ? 如果是这样，我
我试图通过使用动态组参数对数据进行分组来循环。 我们可以在循环的 WHERE 条件上使用动态查询，但我不知道是否可以在组条件中使用动态字符串。 以下是用户决定按哪个字段分组，然后根据决定放置其他逻辑的
我有这样的字符串 s = 'MR1|L2-S1x' 模式总是相同的:一个或两个字符，在 [|.+:x-] 中可选地后跟一个数字和一个分隔符。此模式可以重复 6 次。 所以匹配模式很明确。 p = r'
我有一个带有时间戳字段“bar”的表“foo”。如何仅获取查询的最旧时间戳，例如: SELECT foo.bar from foo？我尝试执行以下操作: SELECT MIN(foo.bar) fro
在我的 Django 项目中，我有一个 user_manage 应用程序。 我在 user_manage 应用的 model.py 中创建了一个名为 UserManage 的模型: from djan
所以我有这样的输入: 还有一个模板指令，例如: 看来我只获得了 foo 和 bar 的组。 (为什么？我预计我可能会得到第三组 current-group-key() = '')。
我正在尝试扩展 django.contrib.auth 并遇到将用户添加到组中的情况，这可以通过两种方式完成。我只是想知道为什么会这样，以及其中一种相对于另一种的优势是什么。 最佳答案 他们做完全相同
我使用的是旧的 PHP 脚本，并且此查询有错误。由于我没有使用 mysql 的经验，因此无法修复它。 "SELECT COUNT(p.postid) AS pid, p.*, t.* FROM ".T
我有几行 Objective-C 代码，例如: ABAddressBookRef addressBook; CFErrorRef error = NULL; addressBook = ABAddre
我正在使用 MariaDB IMDB 电影数据集，我试图解决以下问题。电影表包含 id、名称、排名和年份列 A decade is a sequence of 10 consecutive years
让我从数据开始，以便更好地描述我的需求。我有一个名为 SUPERMARKET 的表，其中包含以下字段: Field 1: StoreID Field 2: ProductCategory Field
你好我有这个查询: SELECT DISTINCT a.id, a.runcd, (SELECT SUM(b.CALVAL) FROM GRS b WHERE b.PCode=11000 AND a.
我想在 xquery 中使用 Group By。有人可以告诉我如何在 Marklogic 中使用 Group By 吗？ 最佳答案 或者，您可以使用 xdmp:xslt-invoke 调用 XSLT或
因此，当通过 from sequelize 请求组时，如下所示: return models.WorkingCalendar .findAll({
我希望我解释正确。 我有 2 个表，有 第一个表(table1) +------------+------+-------+-------+ | Date | Item | Block |
我的表 MYTABLE 有 2 列:A 和 B 我有以下代码片段: SELECT MYTABLE.A FROM MYTABLE HAVING SUM(MYTABLE.B) > 100
我有一个简单的行分组查询，需要 0.0045 秒。 300.000 行 从表 GROUP BY cid 中选择 cid 当我添加 MAX() 进行查询时，需要 0.65 秒才能返回。 从表 GROUP
个人中心
文章发布
退出
我是一名优秀的程序员,十分优秀！