@Bean
public ProducerFactory<String, String> producerStringFactory() {
Map<String, Object> config = new HashMap<>();
// the server name
config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "152.225.215.185:9092");
// the key type
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
// the value type
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
return new DefaultKafkaProducerFactory<String, String>(config);
}
// code
private static final String TOPIC = "testTopic1";
//code
@GetMapping("/publish/{message}")
public String postString(@PathVariable String message) {
kafkaStringTemplate.send(TOPIC, "This is a message sent to the " + TOPIC + " topic");
return "Published: " + message;
}
2021-04-17 12:20:01.986 INFO 2520 --- [nio-8080-exec-1] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = 1
batch.size = 16384
bootstrap.servers = [152.255.215.185:9092]
2021-04-17 12:20:06.591 WARN 2520 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
nano /usr/local/kafka/config/server.properties
advertised.listeners=PLAINTEXT://152.255.215.185:9092
zookeeper.connect=152.255.215.185:2181
问题内容: 在我的java应用程序中,如果用户输入IP,我们需要显示主机名,如果给出了主机名,那么我们需要显示主机的IP。 例如,如果用户输入IP地址,则应显示应用程序,反之亦然。 有可用的工具来执行此操作吗? 问题答案: 如果您使用Java进行编码,请尝试使用
这可能是愚蠢的,但我使用XAMPP在本地主机上使用MySQL,而且我已经完成了我的应用程序并购买了服务器,所以我如何才能上传我的本地主机数据库到服务器?
本文向大家介绍Python将主机名转换为IP地址的方法,包括了Python将主机名转换为IP地址的方法的使用技巧和注意事项,需要的朋友参考一下 关于主机名转IP地址只记住两点即可: 1、英特网协议一直都是用4字节的IP将包转发给目的地; 2、至于主机名是如何转换成IP地址的,这是操作系统关心的事情; 输出: 以上这篇Python将主机名转换为IP地址的方法就是小编分享给大家的全部内容了,希望能给大
当我在Eclipse中的服务器上运行我的应用程序时,我会得到这样的消息:“Tomcat V8.0服务器在localhost上所需的端口8080已经在使用中。该服务器可能已经在另一个进程中运行,或者某个系统进程正在使用该端口。要启动该服务器,您需要停止其他进程或更改端口号”。其他项目关闭。有人能帮我解决这个问题吗?我是爪哇初学者。
1)我在机器上启动Kafka 2)我用配置启动Spring Boot服务器: 1)为什么会发生这种情况? 2)我必须创建吗?为什么不需要本地Kafka? 埃德迪特
我正在用Jax-rs框架在eclipse中开发一个web应用程序,并在TomEE plus服务器上运行它。我之所以使用TomEE Plus而不是标准tomcat,是因为我想用jax rs编写我的应用程序,而jax rs不受标准tomcat的支持,每次运行应用程序时都会出现404。我下载了TomEE-Plus-9.0.0-M7,并将其添加到eclipse中,方法是将类型设置为Tomcat v10.0