《中邮消费金融》专题
-
Kafka主题的多重消费者
然而，当在我的环境中测试此示例时，我得到了一个异常。
-
Kafka消费者再平衡算法
有人能告诉我Kafka消费者的再平衡算法是什么吗？我想了解分区计数和消费者线程是如何影响这一点的。 非常感谢。
-
春云流生产消费同题
我试图改变生产者和消费者配置的顺序，但没有帮助。 编辑：我已经添加了完整的application.yml。当我第一次引导服务时，这个主题在Kafka中是不存在的。 它感觉在生产者和消费者配置之间有冲突，我认为它说有3个分区的原因是消费者中的并发性是3，所以它首先创建有3个分区的主题，然后当它移动到生产者配置时，它不调整分区计数。
-
Apache Flume：kafka.consumer.消费者时间异常
我正在尝试使用Apache Flume构建管道：Spooldir- 事件毫无问题地进入kafka主题，我可以使用kafkacat请求看到它们。但是kafka通道无法通过接收器将文件写入hdfs。错误是： 等待来自 Kafka 的数据时超时 完整日志： 2016-02-26 18：25：17，125 （SinkRunner-PollingRunner-DefaultSinkProcessor-Sen
-
Kafka消费者Vs阿帕奇·Flink
我做了一个poc，其中我使用spark流从Kafka读取数据。但我们的组织要么使用ApacheFlink，要么使用Kafka消费者从ApacheKafka读取数据，作为标准流程。所以我需要用Kafka消费者或ApacheFlink替换Kafka流媒体。在我的应用程序用例中，我需要从kafka读取数据，过滤json数据并将字段放入cassandra中，因此建议使用kafka consumer而不是f
-
pact-jvm消费者协议测试
我是新来的。我的项目是Java项目。我通读了pact文档，找到了github项目https://github.com/dius/pact-jvm/tree/master/pact-jvm-consumer-junit，我将其导入到eclipse IDE中。我被困在这里了。1.首先运行哪个测试。ExampleJavaConsumerPactRuleTest还是ExampleJavaConsumerP
-
KafkaMirrorMaker2自动消费偏移同步我正在使用镜像制作器 2 进行灾难恢复。 Kafka 2.7 应支持自动消费者偏移同步 下面是我正在使用的yaml文件(我使用strimzi来创建它) 所有源群集主题都在目标群集中复制。还有…检查点。内部主题是在包含所有同步的源集群偏移量的目标集群中创建的，但我没有看到这些偏移量被转换为目标集群_consumer_offsets主题，这意味着当我在目标集群中启动消费者（同一消费者组）时，它将从一开
-
Kafka仅有一次消费保证
我在一些关于堆栈溢出的答案中看到，通常在web中也看到，Kafka不支持消费确认，或者消费一次就很难实现。 在以下作为示例的条目中，有没有理由使用RabbitMQ而不是Kafka？，我可以读到以下语句： RabbitMQ将保留已消耗/已确认/未确认消息的所有状态，而Kafka则不保留 或 有人能解释一下为什么Kafka的“一次消费保证”很难实现吗？这与Kafka和RabbitMQ等其他更传统的消息
-
Kafka Rest代理消费者创建
假设我有一个服务，它通过kafka-rest-proxy来消费消息，并且总是在同一个消费者组上。我们还可以说，它正在消耗一个有一个分区的主题。当服务启动时，它在kafka-rest-proxy中创建一个新的使用者，并使用生成的使用者url，直到服务关闭。当服务重新启动时，它将在kafka-rest-proxy中创建一个新的消费者，并使用新的url（和新的消费者）进行消费。 > 因为kafka每个分
-
apache kafka消费者退避策略
当对骆驼使用Kafka组件时，从Kafka消费时有两种方法可以重试： null org.apache.kafka.clients.Consumer.internals.AbstractCoordinator[Consumer ClientID=Consumer-1,GroupID=2862121D-DDC9-4111-A96A-41BA376C0143]此成员将离开组，因为使用者轮询超时已过期。这
-
Kafka消费者获取键值对我目前正在与Kafka和Flink合作，我有kafka在我的本地PC上运行，我创建了一个正在消费的主题。 桌面\kafka\bin\windows 有没有办法进一步了解这条消息的细节？比如说时间？钥匙我查看了Kafka的文档，但没有找到关于这个主题的内容
-
Kafka-主题、分区和消费者
假设我有一个名为“MyTopic”的主题，它有3个分区P0、P1和P2。这些分区中的每一个都有一个leader，并且本主题的数据（消息）分布在这些分区中。 1.Producer将始终根据代理上的负载以循环方式写到分区的领导者。对吗？ 2.制作人如何认识隔断的首领？
-
java 8 java.util.function。消费者Rest[重复]
for循环和foreach可以使用break指令。而是Java8消费者。
-
新的 Kafka Consumer（消费者）集成
这部分包含新的 Apache Kafka consumer API. 兼容性 Apache Kafka 版本 0.10+ 写入Kafka 您可以通过创建 org.apache.storm.kafka.bolt.KafkaBolt 实例并将其作为组件附加到您的topology.如果您使用 trident ,您可以通过使用以下对象完成 org.apache.storm.kafka.trident.Tr
-
5.2会员消费积分/赠券
说明 此协议用于微信会员消费上传进行积分或赠券。具体是执行积分、赠券，由营销活动中进行设置。 请求地址 http://api.dc78.cn/Api/mb_points 请求方式 GET 请求参数 参数 参数名称 必填 描述 范例 mbno 卡号 输入或扫码 id 会员卡id id和mbno两个可选其中之一 amt 可积分消费金额 可用于积分的消费金额 amt可积分消费金额建议可按结账科目进行设置