本文整理了Java中org.apache.kafka.connect.errors.ConnectException.getMessage()方法的一些代码示例，展示了ConnectException.getMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ConnectException.getMessage()方法的具体详情如下：
包路径：org.apache.kafka.connect.errors.ConnectException
类名称：ConnectException
方法名：getMessage

ConnectException.getMessage介绍

暂无

代码示例

代码示例来源：origin: qubole/streamx

public void close(Collection<TopicPartition> partitions) {
 // Close any writers we have. We may get assigned the same partitions and end up duplicating
 // some effort since we'll have to reprocess those messages. It may be possible to hold on to
 // the TopicPartitionWriter and continue to use the temp file, but this can get significantly
 // more complex due to potential failures and network partitions. For example, we may get
 // this close, then miss a few generations of group membership, during which
 // data may have continued to be processed and we'd have to restart from the recovery stage,
 // make sure we apply the WAL, and only reuse the temp file if the starting offset is still
 // valid. For now, we prefer the simpler solution that may result in a bit of wasted effort.
 for (TopicPartition tp: assignment) {
  try {
   topicPartitionWriters.get(tp).close();
  } catch (ConnectException e) {
   log.error("Error closing writer for {}. Error: {}", tp, e.getMessage());
  } finally {
   topicPartitionWriters.remove(tp);
  }
 }
}

代码示例来源：origin: salesforce/mirus

@Override
public void run() {
 logger.info("Starting a task monitor thread...");
 Runtime.getRuntime().addShutdownHook(shutdownHook);
 while (!shutdown.get()) {
  try {
   herder.connectors(this::onConnectors);
   try {
    boolean isCountZero = countDownLatch.await(pollingIntervalMillis, TimeUnit.MILLISECONDS);
    shutdown.set(isCountZero);
   } catch (InterruptedException e) {
    logger.info("Exiting TaskMonitor thread...");
   }
  } catch (ConnectException e) {
   logger.warn(
     "TaskMonitor thread will continue to execute despite exception. Caught exception: {}",
     e.getMessage());
  }
 }
}