当前位置: 首页 > 知识库问答 >
问题:

Kafka自动将服务器ip转换为本地主机

上官凯歌
2023-03-14
    @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.

共有1个答案

晋坚
2023-03-14
 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