我正在尝试弄清楚如何在服务描述符中重写Kafka topicId。我的客户有一个用于DEV和QA的Kafka集群。但是Kafka主题id是硬编码在服务描述符中的。因此，本主题中应用程序的所有开发和QA实例都会发布事件。
有没有办法在application.conf中定义主题id并使用它服务描述符？
浏览 1提问于2019-12-11得票数 0
kafka中的数据如下所示：它自然不像json类型；而且用逗号分隔的每个字段很可能没有相同的长度那么，如何将这些日志消息转换为结构
浏览 2提问于2016-10-24得票数 0
1回答
我正在构建一个由微服务组成的系统，其中一些微服务需要“缓存”其他微服务拥有的数据--这是一种经典的数据去规范化方案。拥有数据的microservice将状态更改事件发布到Kafka主题，以便其他微服务可以使用以保持其缓存的更新。然而，这种方法存在一些挑战，例如: Kafka主题中的数据保存时间有限(7天)，几周后部署的新消费微服务仍然需要一种从头构建缓存的方法。我已经研究过解决这个
浏览 7提问于2022-04-18得票数 0
2回答
前期:我已经阅读了一些关于Kafka与微服务相结合的文章，并且了解到有多种方法可以使用它。比方说，当我必须坚持一个新的博客文章，我有一个userId，但我也想存储用户名与博客帖子。我们显然不想对用户服务进行同步调用，所以我们寻找另一种解决方案，在这种情况下使用Kafka。如果我做对了，当用户在db中更新时，用户服务应该总是发布对Kafka队列的更新，我仍然不确定博客服务将如何从队列中提取最新的用户名。另一件事，我看到
浏览 6提问于2022-08-31得票数 1
如何向Hive表订阅Apache Kafka主题和流主题数据？
Kafka主题将实时更新。
浏览 1提问于2017-11-29得票数 0
1回答
我们通过DCOS运行Kafka。我们有一个主题，它似乎有一些错误的数据。我想删除这个话题。尝试运行: kafka-topics.sh --zookeeper --delete --topicdcos kafka broker更新1 --options delete.topic.enable=tru
浏览 2提问于2016-01-12得票数 4
我正在编写一个应用程序，通过Java API对kafka主题执行一系列操作。我可以创建主题和添加分区。我需要帮助获取主题元数据(如分区，代理)和配置，并更新配置。作为参考，我想更新这里提供的主题级别配置-，如cleanup.policy、compression.type等
浏览 0提问于2016-11-21得票数 3
我是python中kafka客户机的初学者，我需要一些帮助来描述使用该客户机的主题。我能够使用以下代码列出我所有的kafka主题：-
consumer = kafka.KafkaConsumer(group_id='test', bootstrap_servers=['kafka1']
浏览 3提问于2019-05-22得票数 4
回答已采纳
1回答
在我的申请中，我设置了Kafka如下所示。为了测试事务失败时的侦听器，我创建了以下类。**最新情况：
顺便说一句，这可能是最新版本的Spring的一个bug。我降级为Kafka v2.4.1和SpringBootv2.2.7，它运行良好。我在这里报告了窃听器。如果在Kafka v2.5.0中有一些
浏览 0提问于2020-06-20得票数 1
回答已采纳
2回答
我有一些基本的Kafka流代码，可以从一个主题读取记录，进行一些处理，并将记录输出到另一个主题。如果它是多线程的，我需要了解它是如何工作的，以及如何处理资源，比如SQL数据库连接应该在不同的处理线程中共享。相对于其他选项(Spa
浏览 1提问于2016-10-12得票数 27
回答已采纳
我需要有关如何在构造函数中设置SSL参数的信息，kafka-python客户机中提供的信息描述性不够。
ssl_certfile、ssl_cafile、ssl_keyfile参数是什么。/producer/kafka.py"，第543行，在发送self._wait_on_metadata(主题，sel.config‘’max_block_ms‘/ 1000.0)文件"/usr/lib/pyt
浏览 1提问于2018-08-22得票数 4
回答已采纳
2回答
描述部署Kafka和Kafka连接内容类型: application/json“-d”{“名称”：&qu
浏览 1提问于2021-02-24得票数 1
回答已采纳
当我描述一个kafka主题时，它没有显示任何分区的日志结束偏移量，而是显示了所有其他元数据，如ISR、副本、Leader。运行这个：./kafka-topics.sh --zookeeper zk-service:2181 --describe --topic "__consumer_offsets“
输出没有偏移量列。
浏览 0提问于2019-05-20得票数 0
1回答
我正在将服务从RabbitMQ迁移到Kafka，在运行关于Zipkin主题(即kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --topic zipkin --from-beginning)的kafka-console-console. the时，我没有看到任何zipkin跟踪。指令提取依赖项之后必须进行的依赖项重写。我还看了一下的说明，我认为这部分是正确的</
浏览 0提问于2018-02-12得票数 1
回答已采纳
我是卡夫卡的新手。我创建了生产者和消费者，生产者将消息发布到一个主题中，消费者从topic.My中获取这些消息，问题是生产者如何发布更多的主题或分区，消费者如何获取它们？建议如何发布多个主题以及创建主题分区的方法。我浏览了很多网站，但是没有得到任何合适的java代码来做这些事情。
致以问候。
浏览 2提问于2018-04-17得票数 0
我正在学习如何在这个网站上使用Kafka (除了在动物园管理员中使用端口2182 )，但它显示：
环境规划署：zookeeper-3.4.10
浏览 0提问于2018-11-22得票数 67
回答已采纳
我正在尝试删除应用于我的主题的主题级配置retention.bytes。但是，当我尝试使用Kafka documentation中描述的命令删除配置时，我得到了以下消息： kafka-0:/opt/bitnami/kafka/bin$ kafka-configs.sh --Invalid config(s): retention.bytes 我已经深入研究了Kafka<
浏览 151提问于2021-03-26得票数 1
1回答
我正在开发一个java应用程序，从来源接收实时数据(Kafka/Kafka流)。在我的案例研究中，我需要过滤我列表中的名字。这份名单最初有1000万个名字。我的第一个问题是知道什么是最好的方法和/技术，以获得更高效/更快的处理时间。
第二个问题是如何更新或删除列表中的一些名称？
浏览 2提问于2020-01-25得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
