我有一个使用Spring-Kafka的Spring Boot应用程序，我使用docker中的landoop's fast-data-dev作为我的kafka集群。但是，当我进入快速数据开发ui时，我可以看到我的模式已注册，我的消息仍然显示为Data type: binary，而不是'avro‘，因此它们<em
浏览 33提问于2019-05-06得票数 0
1回答
我正试图在docker映像Landoop/fast-data-dev中使用kafka，我运行了以下命令docker run --rm -it -p 2183:2181 -p 3030:3030 -p 8081:8081 -p 8082:8082 -p 8083:8083 -p 9093:9092 -e ADV_HOST=127.0.0.1 landoop/fast-data-devdocker run --rm -it --
浏览 1提问于2018-10-27得票数 1
1个容器:收集器(它收集站点上的页面视图并发送到kafka clucster)我写了docker-compose文件： image: landoop/fast-data-dev:cp3.3.0cluster starts faster
por
浏览 2提问于2020-03-17得票数 0
volumes: ui:在完成干净的安装之后，我尝试在浏览器中打开landoop/kafka-topics-ui，但是请求失败了，我注意到在docker日志中显示了以下错误：
2
浏览 2提问于2019-07-22得票数 2
回答已采纳
我试图连接卡夫卡-用localhost:3030连接到本地的mssql，当我尝试为mssql建立一个新的连接时，我会收到这个错误。在centos 7(linux)中。Mssql数据来自外部IP(windows)，我的使用者在linux环境中。
我在/opt/connectors/kafka-connect-jdbc/下添加了&
浏览 3提问于2019-12-05得票数 1
我使用的是最新的landoop/fast-data-dev镜像(但是Kafka cli工具和upstream一样) 在容器中尝试此命令时： root@fast-data-dev / $ ./opt/landoop/kafka/bin/kafka-topics --bootstrap-server hostname
浏览 86提问于2020-11-27得票数 2
回答已采纳
4回答
kafka-cluster: environment: ports: - 3030:3030 # Landoop-9585:9581-9585 # JMX Ports
- 909
浏览 18提问于2022-02-11得票数 1
我已经把我的windows OS 10从Home更新到Pro了。我已经在我的机器上安装了windows docker工具箱。我尝试使用以下命令在docker中运行apache kafka： -p 2181:2181 -p 3030:3030 -p 8081:8081 \-p 8082:8082 -p 8083:8083 -p 9092:9092 \ landoop/fas
浏览 0提问于2017-05-18得票数 1
我刚刚开始使用Kafka和Spring Boot &我想发送和消费JSON对象。当我尝试消费来自Kafka主题的消息时，收到以下错误：
org.apache.kafka.common.errors.SerializationException: Error deserializingkey/value for partition dev.orders-0 at offset 9903.$2600(Fetcher.ja
浏览 0提问于2018-05-10得票数 7
1回答
我使用Spring和@EmbeddedKafka注释来启动嵌入的Kafka实例。}我的问题是我不正确地使用了Spring。我使用嵌入的Kafka配置进行了自定义注释。问题是，我在复合注释中设置了@ActiveProfiles("
浏览 1提问于2019-04-10得票数 4
回答已采纳
以下是几个步骤：2)在终端中运行bash命令: Doneroot@fast-data-dev / $ kafka-topics --create --zookeeper localhost:2181 --replication-factor:238)
at kafk
浏览 4提问于2020-03-20得票数 0
但是，即使使用postgres 11和标准插件，我也得到了以下错误: org.apache.kafka.connect.errors.ConnectException: org.postgresql.util.PSQLException: error:未能访问文件"decoderbufs"：没有这样的文件或目录 # this is our kafka<
浏览 5提问于2020-01-30得票数 17
回答已采纳
1回答
我使用Kafka实现微服务之间的Asyng调用，使用Spring进行日志记录。日志记录是正常的，但是当有消息从Microservice1到Microservice2时，日志记录的消息具有不同的跟踪ID。难道他们不需要有相同的追踪Id但有不同的SpanId吗？有没有特殊的配置？
浏览 2提问于2016-12-02得票数 4
回答已采纳
Spring Cloud Contract是否支持Spring Kafka消息开箱即用的contract验证？
浏览 1提问于2017-02-16得票数 1
我已经完成了下面的配置和java代码来向kafka主题发送一条消息。我只想发信息。
<parent>
<groupId>org.springframework.boot</artifact
浏览 3提问于2021-11-28得票数 0
在我的开发环境中，我在Kafka主题中收到了来自未知来源的消息，它把事情搞砸了。我猜是我们的配置造成的，但我不确定。在工作中，我们在不同的环境中共享相同的主题名称和使用者组ID，因此在prod中我们有bootstrap服务器aws.our-prod.com，在dev中我们有aws.our-dev.com。所以基本上是两个不相连的
浏览 0提问于2021-06-09得票数 0
2回答
我遇到了一些问题，试图使用Spring将Kafka消息反序列化为POJO。我希望使用消息的键和值部分来构造POJO。如何使java应用程序适当地将kafka消息反序列化为POJO？(g
浏览 3提问于2020-03-05得票数 2
回答已采纳
1回答
我试图映射到application.properties文件中，这样消费者就可以接收生产者发送的消息。Integer sensor_id;// getters and setters我的生产者的application.propertiesspring.kafka.producer.properties.spring.json.type
浏览 2提问于2021-12-02得票数 2
回答已采纳
我有一个spring引导应用程序，我使用AggregatingKafkaReplyingTemplate与另一个下游服务一起使用请求应答模式。目前，我正在对本地运行的Spring引导生成器应用程序和本地Kafka Ui进行测试，后者在知道请求消息已在生产者主题上发送之后，将消息发送回手动完成的应答主题。有没有办法在Spring应用程序本身(可能是日志)中记录/知道由Kafka</e
浏览 8提问于2022-09-15得票数 1
3回答
向hawq插入流数据
、、、
之后，我用flume测试了向hdfs写入数据，并在hawq中创建了外部表，但是hawq在flume关闭文件之前无法读取数据。问题是，如果我设置水槽文件滚动非常低(1分钟)，在几天后，文件数量上升，这是不好的hdfs。第三种解决方案是hbase，但是由于我的大多数查询都是聚集在许多数据上的，所以hbase不是一个很好的解决方案(hbase很适合获取单个数据)。那么，有了这些约束，用hawq在线查询流式数据的好解决方案是什么？
浏览 8提问于2016-08-17得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
