【发布时间】:2021-11-05 21:02:07
【问题描述】:
您好,我正在尝试开发一个应用程序 (EAR) 以将其部署在 WebSphere 应用程序服务器上。
目标是部署后,程序需要自动运行。不需要 Web UI,我该如何实现?下面是代码。它只是一个简单的消费者,监听 kafka 主题并打印消息。
//创建名为“SimpleProducer”的java类 公共类 SimpleConsumer{
public static void main(String[] args) throws Exception {
/*
* // Check arguments length value if(args.length == 0){
* System.out.println("Enter topic name"); return; }
*/
Logger logger = LoggerFactory.getLogger(SimpleConsumer.class);
// Assign topicName to string variable
String topicName = "first_topic";
// create instance for properties to access producer configs
Properties props = new Properties();
// Assign localhost id
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka165.harishfysx.com:9092");
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG , StringDeserializer.class.getName());
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-fourth-applicaiton");
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG , "earliest");
// Create Consumer
KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
// Subscribe
consumer.subscribe(Collections.singleton(topicName));
//Poll data
while(true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records) {
logger.info( "Value :" + record.value());
logger.info("Offset :" + record.offset());
}
}
}
}
【问题讨论】:
标签: java spring apache-kafka websphere ear