• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java CachedSchemaRegistryClient类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient的典型用法代码示例。如果您正苦于以下问题:Java CachedSchemaRegistryClient类的具体用法?Java CachedSchemaRegistryClient怎么用?Java CachedSchemaRegistryClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



CachedSchemaRegistryClient类属于io.confluent.kafka.schemaregistry.client包,在下文中一共展示了CachedSchemaRegistryClient类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: configureKafkaProducer

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
@Override public KafkaProducer configureKafkaProducer(Properties producerProps) {
  String schemaRegistryUrl;
  Integer identityMapCapacity;

  if (producerProps.containsKey(KAFKA_SCHEMA_REGISTRY_URL_FIELD)) {
    schemaRegistryUrl = (String) producerProps.get(KAFKA_SCHEMA_REGISTRY_URL_FIELD);
  }
  else {
    throw new IllegalArgumentException("Field " + KAFKA_SCHEMA_REGISTRY_URL_FIELD + " required.");
  }

  if (producerProps.containsKey(KAFKA_SCHEMA_REGISTRY_IDENTITY_MAP_CAPACITY_FIELD)) {
    identityMapCapacity = (Integer) producerProps.get(KAFKA_SCHEMA_REGISTRY_IDENTITY_MAP_CAPACITY_FIELD);
  }
  else {
    identityMapCapacity = 100;
  }

  CachedSchemaRegistryClient client = new CachedSchemaRegistryClient(schemaRegistryUrl, identityMapCapacity);
  KafkaAvroSerializer serializer = new KafkaAvroSerializer(client);
  return new KafkaProducer<Object, Object>(producerProps, serializer, serializer);
}
 
开发者ID:verisign,项目名称:storm-graphite,代码行数:23,代码来源:SchemaRegistryKafkaReporter.java


示例2: AvroSchemaHelper

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
/**
 * AvroSchemaHelper constructor. DataFactory settings should be passed in for parsing.
 * @param settings DataFactory settings.
 */
public AvroSchemaHelper(DataFactory.Settings settings) {
  final List<String> schemaRepoUrls = settings.getConfig(SCHEMA_REPO_URLS_KEY);
  final Object schemaSource = settings.getConfig(SCHEMA_SOURCE_KEY);
  final boolean registerSchema = settings.getConfig(REGISTER_SCHEMA_KEY);
  final boolean schemaFromRegistry =
      schemaSource == DestinationAvroSchemaSource.REGISTRY ||
      schemaSource == OriginAvroSchemaSource.REGISTRY;

  // KafkaTargetConfig passes schema repo URLs in SCHEMA_REPO_URLS_KEY regardless of whether they are
  // for schema source or schema registration, since the two are mutually exclusive
  if ((schemaFromRegistry || registerSchema) && !schemaRepoUrls.isEmpty()) {
    registryClient = new CachedSchemaRegistryClient(schemaRepoUrls, 1000);
  } else {
    registryClient = null;
  }

  // Small cache to avoid going to Schema repository all the time
  schemaIdCache = CacheBuilder.newBuilder()
    .maximumSize(100)
    .build();
}
 
开发者ID:streamsets,项目名称:datacollector,代码行数:26,代码来源:AvroSchemaHelper.java


示例3: deserialize

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
@Override
public String deserialize(byte[] message) {
    if (kafkaAvroDecoder == null) {
        SchemaRegistryClient schemaRegistry = new CachedSchemaRegistryClient(this.schemaRegistryUrl, this.identityMapCapacity);
        this.kafkaAvroDecoder = new KafkaAvroDecoder(schemaRegistry);
    }
    return this.kafkaAvroDecoder.fromBytes(message).toString();
}
 
开发者ID:seanpquig,项目名称:flink-streaming-confluent,代码行数:9,代码来源:ConfluentAvroDeserializationSchema.java


示例4: KafkaRegistry

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
public KafkaRegistry() {
    super();
    
    // get properties
    PropertyManagement properties = PropertyManagement.getProperties();
    targetURL = properties.getProperty(KafkaPublisherPropertyValues.KAFKA_REGISTRY_URL, "http://localhost:8081");
    maxSchemas = properties.asInt(KafkaPublisherPropertyValues.KAFKA_REGISTRY_MAX_SCHEMAS, "1000");
    magic_byte = (byte)(properties.asInt(KafkaPublisherPropertyValues.KAFKA_REGISTRY_MAGIC_BYTE, "0"));
    idSize = properties.asInt(KafkaPublisherPropertyValues.KAFKA_REGISTRY_ID_SIZE, "4");
    
    client = new CachedSchemaRegistryClient(targetURL, maxSchemas);    
}
 
开发者ID:oracle,项目名称:bdglue,代码行数:13,代码来源:KafkaRegistry.java


示例5: configure

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
@Override
public void configure(Map<String, String> properties) {
  SchemaRegistrySchemaRetrieverConfig config =
      new SchemaRegistrySchemaRetrieverConfig(properties);
  schemaRegistryClient =
      new CachedSchemaRegistryClient(config.getString(config.LOCATION_CONFIG), 0);
  avroData = new AvroData(config.getInt(config.AVRO_DATA_CACHE_SIZE_CONFIG));
}
 
开发者ID:wepay,项目名称:kafka-connect-bigquery,代码行数:9,代码来源:SchemaRegistrySchemaRetriever.java


示例6: AvroProducer

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
public AvroProducer(KsqlConfig ksqlConfig) {
  if (ksqlConfig.getString(KsqlConfig.SCHEMA_REGISTRY_URL_PROPERTY) == null) {
    throw new KsqlException("Schema registry url is not set.");
  }
  this.ksqlConfig = ksqlConfig;
  this.schemaRegistryClient = new CachedSchemaRegistryClient(ksqlConfig.getString(KsqlConfig
                                                                                      .SCHEMA_REGISTRY_URL_PROPERTY), 100);
}
 
开发者ID:confluentinc,项目名称:ksql,代码行数:9,代码来源:AvroProducer.java


示例7: SecorSchemaRegistryClient

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
public SecorSchemaRegistryClient(SecorConfig config) {
    try {
        Properties props = new Properties();
        props.put("schema.registry.url", config.getSchemaRegistryUrl());
        schemaRegistryClient = new CachedSchemaRegistryClient(config.getSchemaRegistryUrl(), 30);
        init(config);
    } catch (Exception e){
        LOG.error("Error initalizing schema registry", e);
        throw new RuntimeException(e);
    }
}
 
开发者ID:pinterest,项目名称:secor,代码行数:12,代码来源:SecorSchemaRegistryClient.java


示例8: ConfluentKafkaSchemaRegistry

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
public ConfluentKafkaSchemaRegistry(Properties props) {
  this(props, new CachedSchemaRegistryClient(props.getProperty(KAFKA_SCHEMA_REGISTRY_URL),
      Integer.parseInt(props.getProperty(CONFLUENT_MAX_SCHEMAS_PER_SUBJECT, String.valueOf(Integer.MAX_VALUE)))));
}
 
开发者ID:apache,项目名称:incubator-gobblin,代码行数:5,代码来源:ConfluentKafkaSchemaRegistry.java


示例9: KsqlEngine

import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; //导入依赖的package包/类
public KsqlEngine(final KsqlConfig ksqlConfig, final KafkaTopicClient topicClient) {

    this(ksqlConfig, topicClient, new CachedSchemaRegistryClient((String) ksqlConfig.get(KsqlConfig.SCHEMA_REGISTRY_URL_PROPERTY), 1000));
  }
 
开发者ID:confluentinc,项目名称:ksql,代码行数:5,代码来源:KsqlEngine.java



注:本文中的io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java VCFHeaderVersion类代码示例发布时间:2022-05-22
下一篇:
Java OverlayItem类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap