小编Ank*_*kit的帖子

我做了Apache Kafka 0.10.1.0的全新安装.

我能够在命令提示符下发送/接收消息.

使用Producer/Consumer Java示例时,我无法知道Consumer Example上的group.id参数.

让我知道如何解决这个问题.

以下是我用过的消费者示例:

public static void main(String[] args) {
             Properties props = new Properties();
             props.put("bootstrap.servers", "localhost:9092");
             props.put("group.id", "my-topic");
             props.put("enable.auto.commit", "true");
             props.put("auto.commit.interval.ms", "1000");
             props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
             props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
             KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
             try {
                 consumer.subscribe(Arrays.asList("my-topic"));

                     ConsumerRecords<String, String> records = consumer.poll(100);
                     System.err.println("records size=>"+records.count());
                     for (ConsumerRecord<String, String> record : records) 
                         System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());



              }
             catch (Exception ex){
                 ex.printStackTrace();
             }
            finally {
                 consumer.close();
            }
        }

在为消费者运行命令之后,我可以看到生产者发布的消息(在控制台上).但无法从java程序中看到消息 …

我是 Spring Boot 和MapStruct Tool的新手。

早些时候，一个项目（由其他团队使用这些技术编写）没有启动。然后，我在 Mapper Abstract Class 中做了一些更改，但现在 mapper 对象在应用程序启动时变为 null。

映射器抽象类：

@Mapper(componentModel = "spring")
public abstract class UserAndEmployeeMapper {

    public UserAndEmployeeMapper INSTANCE = Mappers.getMapper( UserAndEmployeeMapper.class );

    @Mapping(source = "username", target = "name")
    @Mapping(source = "ssn", target = "ssn", defaultValue = "xxxxxx" )
    @Mapping(target = "salary", constant = "34.67")
    @Mapping(target = "dob", dateFormat = "dd/MM/yyyy", constant = "10/12/2002")
    public abstract Employee mapToEmployee(User user);

    public abstract List<Employee> mapToEmployee(List<User> users);

    @Mapping(source = "name", target = "username")
    public abstract User …

我试图使用Streams API在HashMap中过滤条目,但是在最后一次方法调用中停留了Collectors.toMap.所以,我没有实现toMap方法的线索

    public void filterStudents(Map<Integer, Student> studentsMap){
            HashMap<Integer, Student> filteredStudentsMap = studentsMap.entrySet().stream().
            filter(s -> s.getValue().getAddress().equalsIgnoreCase("delhi")).
            collect(Collectors.toMap(k , v));
    }

public class Student {

        private int id;

        private String firstName;

        private String lastName;

        private String address;
    ...

    }

有什么建议？

我无法在JBOSS EAP 7服务器上部署我的Spring BOOT REST应用程序。

但是，在Apache Tomcat 8服务器上部署后，它运行良好。

应用主类：

@SpringBootApplication(scanBasePackages= {"org.nic"})
@PropertySource(value="classpath:database.properties")
public class PopulationApplication extends SpringBootServletInitializer {

    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(PopulationApplication.class);
    }

    public static void main(String[] args) throws Exception {
        SpringApplication.run(PopulationApplication.class, args);
    }

}

pom.xml

  <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <start-class>org.nic.PopulationApplication</start-class>
        </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-tomcat</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

         <dependency>
            <groupId>org.postgresql</groupId>
            <artifactId>postgresql</artifactId>
        </dependency>  


        <!-- <dependency>
            <groupId>org.springframework.boot</groupId> …

我在 html 中声明了 5 个带有 name 和 id 属性的复选框：

<input type="checkbox" name="category" value="One" id=11>One<br/> 
<input type="checkbox" name="category" value="Two" id=12>Two<br/> 
<input type="checkbox" name="category" value="Three" id=13>Three<br/> 
<input type="checkbox" name="category" value="Four" id=14>Four<br/>

声明后，我想运行一个 javascript 来启用 checkbox1 使用该复选框 id。

让我知道澄清一些事情。

我对checked exception class在java中创建感到困惑.

许多文章都说可以创建自定义异常

class MyException extends Exception
{
  //constructor defined
}

由于RuntimeException也是从Exception类继承的.

是否无法创建仅涵盖Checked Exceptions的类？

或者我需要指定已检查异常的列表

class MyException extends IOException
    {
      //constructor defined
    }

在上面的代码中,可能存在我会错过某些已检查异常的情况.