将制片人连接到Kafka主题
我有一个服务器a，在服务器a中，我安装了kafka并启动了kafka和Zookeeper。我还创建了一个主题作为my_topic。现在我有一个应用程序B运行在服务器B中，应用程序B有一些数据，我想把这些数据推送到服务器A中的my_topic。我是否也需要在服务器B中安装kafka并在服务器B中创建一个生产者？如果是，如何将来自服务器B的消息推送到服务器A中的主题？介质是什么？
共有1个答案
Java应用程序使用org.apache.Kafka.clients.producer.KafkaProducer将数据写入Kafka主题。
为了指定要将数据发送给哪个Kafka，您应该将其属性“bootstrap.servers”设置为您的Kafka服务器地址。
您可以在KafkaProducer文档中找到一个代码示例
-
我在一个视频教程中看到，当制作人发布消息时，Kafka Broker支持3种类型的确认。 0-开火并忘记 1-领导确认 2-确认所有经纪人 我正在使用Kafka的Java API发布消息。这是必须为每个使用服务器的代理设置的吗。每个经纪人的特定属性，还是必须由制作人设定？如果必须由制作人设置，请解释如何使用Java API设置。
-
我正在使用Spring-Cloud-sleuth-stream和Spring-Cloud-starter-stream-kafka发送跨度到kafka，异常发生在连接中。SR1 192.168.1.177是我的localhost 初始化连接 重试例外 我不明白为什么，主机更改为，以及如何修复它
-
假设我有多个设备。每个设备都有不同类型的传感器。现在我要把每个传感器的每个设备的数据发送给Kafka。但我对Kafka的主题感到困惑。用于处理此实时数据 null 情况2：向一个主题发送数据 设备1（传感器A,B,C）,设备2（传感器A,B,C）...设备....->主题 > 这不是数据瓶颈吗。因为它将表现为队列，来自某个传感器的数据将在队列中落后，并且不会被实时处理。 设备1 ->传感器A-TO
-
下面是/etc/kafka/connect-MongoDB-source.properties中的MongoDB配置 但是低于误差 以独立模式运行连接器。 我在debezium-debezium-连接器-mongob-1.0.0/debezium-connector-mongodb-1.0.0.Final.jar 类路径的设置如下 使用插件路径，我看到它能够注册和加载所有必需的插件。 但最后还是同
-
我正在尝试将 kafka 与 windows 上的 mysql 连接起来。我没有使用汇合。我的 kafka 版本是 2.12 我已经启动了动物园管理员、Kafka、生产者和消费者，这一切都很好用。 我的MysQL版本是8.0.15 我已经在libs文件夹中复制了这3个jar文件 我的源代码quickstart mysql。属性文件代码为 当我运行命令时 我在控制台上收到此错误 请帮助我。 我也试过
-
我想使用spring cloud stream framework创建一个kafkaendpoint，它将有一个http post api到。如何动态更改属性 我可以使用实现来实现上述功能，但不知道是否有可能在Spring中开发此功能。