Início / user-7769052

banan3'14's questions

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

Sempre pensei que o mainmétodo deveria estar dentro de uma classe em Java, mas aqui está dentro de uma interface

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

e compila e roda sem problemas

$ 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)

Pode ser uma interface também?

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

Eu tenho uma propriedade booleana atômica em Java

private AtomicBoolean endOfInputDataSet;

Quais são os getter e setter adequados desta propriedade e quais as consequências de cada escolha? Eu posso devolver o AtomicBooleandiretamente

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

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

ou posso devolver o desembrulhado boolean:

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

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

Acho que a última solução é apenas mais simples para uso pelo cliente e mais limpa, mas por que ela não é padrão quando o IntelliJ gera o getter e o setter?

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

Adicionei Spring Kafka ao meu aplicativo Spring e esperava que funcionasse, mas consegui

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.

Eu adicionei ao meupom.xml

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

e configurei-o

@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);
}

onde bootstrapAddressé configurado via application.yml:

spring:  
  kafka:
    bootstrap-servers: localhost:9092

e também tenho uma configuração de produtor:

@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
    ));
}

O que está errado? Devo executar o Kafka manualmente na porta localhost 9092? Presumo que isso seja feito automaticamente pelo framework Spring, assim como não preciso implantá-lo no Tomcat porque ele está empacotado. Isso inicia o serviço Kafka ou devo fazer isso sozinho?

apache-kafka