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

Broker.<init>介绍

暂无

代码示例

代码示例来源：origin: linkedin/kafka-monitor

private List<Broker> brokers(int brokerCount) {
 List<Broker> brokers = new ArrayList<>();
 for (int i = 0; i < brokerCount; i++) {
  brokers.add(new Broker(i, "", -1, null, SecurityProtocol.PLAINTEXT));
 }
 return brokers;
}

代码示例来源：origin: linkedin/camus

private TopicMetadataResponse mockTopicMetaDataResponse() {
 PartitionMetadata pMeta = EasyMock.createMock(PartitionMetadata.class);
 mocks.add(pMeta);
 EasyMock.expect(pMeta.errorCode()).andReturn((short)0).anyTimes();
 Broker broker = new Broker(0, "localhost", 2121);
 EasyMock.expect(pMeta.leader()).andReturn(broker).anyTimes();
 EasyMock.expect(pMeta.partitionId()).andReturn(PARTITION_1_ID).anyTimes();
 List<PartitionMetadata> partitionMetadatas = new ArrayList<PartitionMetadata>();
 partitionMetadatas.add(pMeta);    
 TopicMetadata tMeta = EasyMock.createMock(TopicMetadata.class);
 mocks.add(tMeta);
 EasyMock.expect(tMeta.topic()).andReturn(TOPIC_1).anyTimes();
 EasyMock.expect(tMeta.errorCode()).andReturn((short)0).anyTimes();
 EasyMock.expect(tMeta.partitionsMetadata()).andReturn(partitionMetadatas).anyTimes();
 List<TopicMetadata> topicMetadatas = new ArrayList<TopicMetadata>();
 topicMetadatas.add(tMeta);
 TopicMetadataResponse metadataResponse = EasyMock.createMock(TopicMetadataResponse.class);
 mocks.add(metadataResponse);
 EasyMock.expect(metadataResponse.topicsMetadata()).andReturn(topicMetadatas).anyTimes();
 return metadataResponse;
}

代码示例来源：origin: stackoverflow.com

def setup() {

  broker = new Broker();
  def brokerOptions = new BrokerOptions()

  File file = new File(qpidHomeDir)
  String homePath = file.getAbsolutePath();
  log.info(' qpid home dir=' + homePath)
  log.info(' qpid work dir=' + tmpFolder.absolutePath)

  brokerOptions.setConfigProperty('qpid.work_dir', tmpFolder.absolutePath);

  brokerOptions.setConfigProperty('qpid.amqp_port',"${amqpPort}")
  brokerOptions.setConfigProperty('qpid.http_port', "${httpPort}")
  brokerOptions.setConfigProperty('qpid.home_dir', homePath);

  brokerOptions.setInitialConfigurationLocation(homePath + configFileName)
  broker.startup(brokerOptions)
  log.info('broker started')
}

代码示例来源：origin: com.ebay.jetstream/jetstream-messaging

private Broker getLeader() {
  try {
    Map<String, Object> state = m_zkConnector.readJSON(m_pstatePath);
    Integer brokerId = ((Number) state.get("leader")).intValue();
    Map<String, Object> brokerData = m_zkConnector
        .readJSON(brokerPath(brokerId));
    if (brokerData == null)
      throw new RuntimeException("Broker info not found for "
          + m_clientId);
    String host = (String) brokerData.get("host");
    Integer port = ((Number) brokerData.get("port")).intValue();
    return new Broker(brokerId, host, port);
  } catch (RuntimeException e) {
    throw e;
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: apache/crunch

EndPoint endPoint = new EndPoint(brokerHostPort[0], Integer.parseInt(brokerHostPort[1]),
   ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT), SecurityProtocol.PLAINTEXT);
 brokers.add(new Broker(0, JavaConversions.asScalaBuffer(Arrays.asList(endPoint)),
   Option.<String>empty()));
} catch (NumberFormatException e) {

代码示例来源：origin: stackoverflow.com

public class BrokerTestMain {
  public static void main(String... args) {
    Broker broker = new Broker();
    broker.add(new Component());

    broker.publish("Hello");
    broker.publish(new Date());
    broker.publish(3.1415);
  }
}

class Component {
  @Subscription
  public void onString(String s) {
    System.out.println("String - " + s);
  }

  @Subscription
  public void onDate(Date d) {
    System.out.println("Date - " + d);
  }

  @Subscription
  public void onDouble(Double d) {
    System.out.println("Double - " + d);
  }
}

代码示例来源：origin: stackoverflow.com

@Rule
private static final ExternalResource embeddedAMQPBroker = new ExternalResource() {
  Broker broker;

  @Override
  protected void before() throws Throwable {
    BrokerOptions brokerOptions = new BrokerOptions();
    brokerOptions.setConfigProperty("qpid.amqp_port", "55672");
    broker = new Broker();
    broker.startup(brokerOptions);
  }

  @Override
  protected void after() {
    broker.shutdown();
  }
};

代码示例来源：origin: apache/crunch

ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT), SecurityProtocol.PLAINTEXT);
Broker leader = new Broker(0, JavaConversions.asScalaBuffer(Arrays.asList(endPoint)),
  Option.<String>empty());