主页 / user-7769052

banan3'14's questions

Martin Hope
banan3'14
Asked: 2024-04-17 17:47:01 +0800 CST
  • 8

我一直认为mainJava中的方法一定是在类的内部，但这里它是在接口的内部

public interface Main {
  static void main(String[] args){
    System.out.println("HelloWorld");
  }
}

它编译并运行没有问题

$ javac Main.java 
$ java Main
HelloWorld
$ java -version
openjdk version "17.0.8" 2023-07-18
OpenJDK Runtime Environment (Alibaba Dragonwell Standard Edition)-17.0.7.0.7+7-GA (build 17.0.8+7)
OpenJDK 64-Bit Server VM (Alibaba Dragonwell Standard Edition)-17.0.7.0.7+7-GA (build 17.0.8+7, mixed mode, sharing)

那么它也可以是一个接口吗？

java
Martin Hope
banan3'14
Asked: 2024-02-11 11:00:05 +0800 CST
  • 6

我在 Java 中有一个原子布尔属性

private AtomicBoolean endOfInputDataSet;

该属性的正确 getter 和 setter 是什么？每个选择的后果是什么？AtomicBoolean我可以直接退货

public AtomicBoolean getEndOfInputDataSet() {
    return this.endOfInputDataSet;
}

public void setEndOfInputDataSet(AtomicBoolean endOfInputDataSet) {
    this.endOfInputDataSet = endOfInputDataSet;
}

或者我可以退回未包装的boolean：

public boolean getEndOfInputDataSet() {
    return this.endOfInputDataSet.get();
}

public void setEndOfInputDataSet(boolean endOfInputDataSet) {
    this.endOfInputDataSet.set(endOfInputDataSet);
}

我认为后一种解决方案只是让客户端使用起来更简单、更干净，但是为什么 IntelliJ 生成 getter 和 setter 时不是默认的呢？

java
Martin Hope
banan3'14
Asked: 2023-09-17 10:08:49 +0800 CST
  • 5

我将 Spring Kafka 添加到我的 Spring 应用程序中并期望它能够工作，但是我得到了

INFO     [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.4.1
INFO --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 8a516edc2755df89
INFO --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1694915576434
INFO --- [| adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient clientId=adminclient-1] Node -1 disconnected.
WARN --- [| adminclient-1] org.apache.kafka.clients.NetworkClient   : [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established.

我将其添加到我的pom.xml

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>3.0.9</version>
</dependency>

并配置它

@Bean
public KafkaAdmin kafkaAdmin() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
    return new KafkaAdmin(configs);
}

@Bean
public NewTopic checkInTopic() {
    return new NewTopic(checkInTopicName, 1, (short) 1);
}

其中bootstrapAddress通过以下方式配置application.yml：

spring:  
  kafka:
    bootstrap-servers: localhost:9092

我还有一个生产者配置：

@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

@Bean
public ProducerFactory<String, String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(Map.of(
            ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress,
            ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class,
            ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class
    ));
}

怎么了？我应该以某种方式在本地主机端口上手动运行 Kafka 吗9092？我假设它是由 Spring 框架自动完成的，就像我不必将它部署在 tomcat 上一样，因为它是捆绑的。它启动 Kafka 服务还是我应该自己启动？

apache-kafka