我希望flink发现每个密钥的所有kafka分区。我有30个分区和12个任务。我通过用户id "keyby“我的数据。我认为每个任务的flink只能发现特定的kafka分区&我不能在一个任务中检测到每个用户的所有数据。
浏览 29提问于2019-10-07得票数 0
我想有一个带有事件名称的主题，并捕获用户的所有事件流。现在，我希望将活动记录到专用分区上的每个用户，该特定用户的事件将转到该分区。现在，如果用户数量超过10000，该怎么办？我是否可以通过添加另一个代理来增加分区的数量，或者这种方法根本不可行。如果高度赞赏，请回复。谢谢
浏览 2提问于2015-08-25得票数 0
我有一个带有多个分区的kafka主题。
我想将主题转储到一个文件中来进行一些分析，因此我认为最简单的方法就是使用kafka-控制台用户。我的问题是，kafka-控制台-使用者是否能够读取所有主题分区，还是将其分配给单个分区？如果不是，如何将kafka-控制台-消费者分配到特定的分区，因此一个将不得不启动与分区一样多的kafka-控制台-消费者。
浏览 4提问于2015-08-27得票数 0
回答已采纳
2回答
我正在考虑Kafka从后端到前端应用程序的更新。数据流是特定于用户请求的，因此每个请求都会在后端生成一个流。-每个用户将有多个并发请求。一对多的关系，即用户和流在网上阅读时，我看到了一些帖子，其中提到了在userid上分区的一个主题。如果对userid进行分区是可行的，那么使用者将收到不同请求的更新(来自该用户)，这将导致问题。我需要能够处理一个流，直到
浏览 1提问于2018-02-19得票数 1
回答已采纳
设置： self._on_revoke)
问题:在我启动的120个用户中，只有84个(与最大主题的分区数相同)获得分区分配--其他用户
浏览 5提问于2020-06-23得票数 0
回答已采纳
1回答
您好，有没有可能告诉一个用户只读一个特定的分区？
到目前为止，从我所读到的和看到的情况来看，似乎不是这样的，还是我错过了什么？
浏览 12提问于2017-01-10得票数 0
回答已采纳
我们正在开发一个基于kafka的流系统，在该系统中，生产者将在其主题中生成多个分区，而单个用户将从该主题中消费。我知道kafka在分区内维护消息顺序，但是我们能在主题中的分区之间维护全局消息顺序吗？
浏览 8提问于2016-04-21得票数 7
回答已采纳
1回答
为此，我使用docker image confluentinc/cp-kafka:5.3.2。
我想给它添加更多的分区。可以让我知道confluentinc/cp-kafka:5.3.2中是否有配置或env来更改分区大小吗
浏览 0提问于2020-02-14得票数 0
我正在使用kafka流的网页访问事件的网站用户到一个分析服务。每个事件将包含消费者的下列详细信息：
在这个用例中，分区键是动态的，所以在创建主题时预先指定分区的数量。可以用动态分区计数在<
浏览 4提问于2015-09-24得票数 25
我使用Kafka在我的AI代理之间分配负载，但是我的服务器有不同的配置和不同的速率来处理输入数据，其中一些仍然是空闲的，而另一些则落后。这是因为现在Kafka的算法为每个消费者分配相同数量的分区，例如，如果我的主题有4个分区，而我有2个消费者，每个用户订阅2个分区。我知道我可以将用户分配给，但我不想将配置限制在这个范围内。是否有一种方法可以限制使用者可以订阅多少分区而不指定确切的分区？
我的使用者是使用kafka-p
浏览 3提问于2022-07-24得票数 0
回答已采纳
1回答
考虑到您的生产者为系统的用户创建消息，并且这些消息的顺序在用户级别很重要。我的生产者将消息添加到有两个分区的主题中，我使用针对user_id的散列将每个用户的所有消息放在相同的分区中，以保证顺序。 如何在保持消息顺序的同时，扩展系统并向主题添加更多分区？Kafka如何处理分区前已经生成的消息？消费但未提交回Kafka以更新偏移量的消息会发生什么？
浏览 14提问于2019-03-18得票数 2
1回答
我使用星火流从Kafka读取数据(使用)。
有多少卡夫卡消费者被实例化为一个流？卡夫卡消费者的数量是否等于执行者的数量？每个执行者是否实例化一个Kafka使用者(具有相同的组id)？
浏览 2提问于2017-06-21得票数 3
回答已采纳
在我重新启动了Kafka集群之后，我的Kafka流应用程序没有收到来自输入主题的消息，我得到了一个exception of "can׳t create internal topic"。经过一些研究后，我用卡夫卡工具(对于输入主题和应用程序)重新设置了工具Kafka-streams-application-reset.sh。
浏览 2提问于2018-04-11得票数 0
1回答
分区的数量对Kafka中的生产者吞吐量有影响吗？(我知道分区的数量是消费者侧并行度的上限，但它会影响生产者的性能吗？)我使用了Kafka中的生产者性能工具，在AWS上的Kafka集群设置上测试了这一点。我观察到，对于3、6和20个分区，集群中的聚合吞吐量大致相同(约200 MB/s )。
浏览 5提问于2017-08-08得票数 4
我知道每个分区都分配给一个Kafka消费者(在一个消费者组中)，但是一个Kafka消费者可以同时使用多个分区。如果每个分区都有一个打开的连接，那么我可以想象每个用户打开了数万个连接。如果这是真的，那么在决定分区的数量时，这似乎是值得注意的事情，不是吗？
浏览 3提问于2018-05-31得票数 3
回答已采纳
除了一个分区上的消息外，它正常工作。我在这个主题上有9个分区。如果我发送1000条信息，我只收到其中的890条。我已经向kafka- console --使用分区键(我知道我的samza作业没有处理)检查过，控制台使用者确实看到了消息，所以我知道它被写到了主题上，并且至少有一个普通的用户可以看到它。我已经在samza上启用了调试日志记录，并且有许多来自org.apache.samza.checkpoint.kafka.KafkaCheckpointManager的消息说：
为offse
浏览 2提问于2016-04-25得票数 2
回答已采纳
它们是32个Kafka分区和32个使用者(按照Direct )。但是32位消费者的数据处理速度比Kafka慢(1.5倍)，这在Kafka中造成了大量的数据积压。我希望增加每个使用者接收的Dstream分区的数量。
我希望解决方案能够在消费者身上增加分区，而不是在Kafka中增加分区。
浏览 0提问于2018-08-22得票数 0
回答已采纳
背景时不时地，我们的Flink不能处理突发信息。如果我们使用常规的Kafka用户，那么就像添加一个用户一样简单(假设我们有足够的Kafka分区)，并且Kafka将在所有用户之间重新分配主题分区。Flink Kafka消费者自己管理分区分配和偏移量，这允许只有一次语义(我们不需要它
浏览 27提问于2019-11-14得票数 1
kafka流如何保证由kafka broker分配给它的分区与分配给其他主题的分区匹配？好像需要协调一下吗？而且，卡夫卡流总是从一开始就阅读压缩的主题，还是从最新的偏移量中读取？
浏览 2提问于2020-07-31得票数 0
回答已采纳
我没有对拓扑做任何更改，也没有在任何内部主题上设置分区大小。
我所做的唯一改变就是流线程的数量(NUM_STREAM_THREADS_CONFIG)从10到50。将其设置为10没有解决这个问题。Use 'kafka.tools.StreamsResetter' tool to clean up invalid topics before processing.
浏览 0提问于2021-10-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
