小编Kha*_*han的帖子

我想在开始生产和消费工作之前确保kafka服务器是否正在运行.它是在windows环境中,这是我的kafka服务器在eclipse中的代码...

Properties kafka = new Properties();
kafka.setProperty("broker.id", "1");
kafka.setProperty("port", "9092");
kafka.setProperty("log.dirs", "D://workspace//");
kafka.setProperty("zookeeper.connect", "localhost:2181");    
Option<String> option = Option.empty();
KafkaConfig config = new KafkaConfig(kafka);        
KafkaServer server = new KafkaServer(config, new CurrentTime(), option);
server.startup();

在这种情况下if (server != null)是不够的,因为它总是如此.那么有没有办法知道我的kafka服务器正在运行并为生产者做好准备.我有必要检查一下,因为它会导致丢失一些起始数据包.

谢谢.

我在Google Developer Console上进行了投影,我在Firebase控制台上添加了这个.现在我被迫使用Firebase Analytics而不是Google Analytics.所以我想从firebase控制台中删除/取消链接我的项目.

如果我从Firebase控制台删除项目,则项目也将从Google Developer Console中删除.有什么问题!

请提供任何解决方案.

我正在尝试创建一个新的maven模块.父项目是一个Web服务,并具有pom.xml.

如何修复此错误并创建新模块？

我正在使用以下代码构建消息...

Producer<String, String> producer = new kafka.javaapi.producer.Producer<String, String>(producerConfig);
KeyedMessage<String, String> keyedMsg = new KeyedMessage<String, String>(topic, "device-420",  "{message:'hello world'}");          
producer.send(keyedMsg);

并使用以下代码块进行消费...

//Key = topic name, Value = No. of threads for topic
Map<String, Integer> topicCount = new HashMap<String, Integer>();       
topicCount.put(topic, 1);

//ConsumerConnector creates the message stream for each topic
Map<String, List<KafkaStream<byte[], byte[]>>> consumerStreams = consumerConnector.createMessageStreams(topicCount);         

// Get Kafka stream for topic
List<KafkaStream<byte[], byte[]>> kStreamList = consumerStreams.get(topic);

// Iterate stream using ConsumerIterator
for (final KafkaStream<byte[], byte[]> kStreams : kStreamList) {
    ConsumerIterator<byte[], byte[]> …

我正在尝试为我的 eclipse 项目创建一个.jar文件。通过导出选项，我可以创建.jar，但我想使用Gradle 构建任务来做到这一点。问题是，仅此特定项目的所有任务都被禁用，如下图所示...

对于另一个项目，这些Gradle 任务运行良好。查看它的 build.gradle 文件...

apply plugin : 'eclipse'
apply plugin: 'java-library'

repositories {
    jcenter()
    mavenCentral()
}

dependencies {
    compile group:"org.apache.pdfbox", name:"pdfbox", version:"2.0.6"
    compile group:"org.apache.pdfbox", name:"pdfbox-tools", version:"2.0.6"
    compile 'com.google.code.gson:gson:2.8.2'
    compile 'org.json:json:20180130'

    api 'org.apache.commons:commons-math3:3.6.1'

    implementation 'com.google.guava:guava:21.0'

    testImplementation 'junit:junit:4.12'
}

它的 settings.gradle 文件包含一行...

rootProject.name = 'schedule-extractor'

有人可以建议我在这里缺少什么吗？

如果两次提出同样的问题被认为是垃圾邮件,我真的很抱歉,因为我已经在一小时前询问过反向计时器了.

但现在新的问题是,我再也无法引起任何人对这个问题的关注.我已经成功编码了计时器,感谢你们,但后来我试着将秒转换为hh:mm:ss格式,但它没有用.而不是继续前进到00:00:00.它只显示我编码的时间,就是这样.

这是我的代码.

import java.util.Timer;
import java.util.TimerTask;
public class countdown extends javax.swing.JFrame {


public countdown() {
    initComponents();
    Timer timer;

    timer = new Timer();
    timer.schedule(new DisplayCountdown(), 0, 1000);
}

class DisplayCountdown extends TimerTask {

      int seconds = 5;
      int hr = (int)(seconds/3600);
      int rem = (int)(seconds%3600);
      int mn = rem/60;
      int sec = rem%60;
      String hrStr = (hr<10 ? "0" : "")+hr;
      String mnStr = (mn<10 ? "0" : "")+mn;
      String secStr = (sec<10 ? "0" : "")+sec; 

      public void run() …

在java中,基本上这两个转换是如此常见和流行......

• 数组到列表

  List<String> list = Arrays.asList(array);

• 列表到数组

  String[] array = list.toArray(new String[list.size()]);

所以问题是,哪个更快,Array to List还是反向？

现在,我为什么要问这个问题？因为我要实现一个数组或列表的方法,两者都可以在参数中传递.我只需要迭代这个列表即可.所以在这里我必须决定我应该转换什么？数组列表或列表到数组!