You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/23 16:50:58 UTC
[pulsar] branch master updated (3a1e8da -> bfb5782)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 3a1e8da [Broker] Fix create the dynamic configuration resource if not exist (#13420)
add bfb5782 Enable CheckStyle Plugin in Pulsar Io (#13413)
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/pulsar/suppressions.xml | 37 +++++++
.../pulsar/io/aerospike/AerospikeAbstractSink.java | 9 +-
.../pulsar/io/aerospike/AerospikeSinkConfig.java | 5 +-
.../pulsar/io/aerospike/AerospikeStringSink.java | 2 +-
.../apache/pulsar/io/aerospike/package-info.java} | 15 +--
.../apache/pulsar/io/aws/AbstractAwsConnector.java | 22 ++--
.../pulsar/io/aws/AwsCredentialProviderPlugin.java | 5 +-
.../io/aws/AwsDefaultProviderChainPlugin.java | 3 +-
.../pulsar/io/aws/STSAssumeRoleProviderPlugin.java | 5 +-
.../org/apache/pulsar/io/aws/package-info.java} | 15 +--
.../BatchDataGeneratorPrintSink.java | 3 +-
.../BatchDataGeneratorPushSource.java | 9 +-
.../BatchDataGeneratorSource.java | 9 +-
.../io/batchdatagenerator/package-info.java} | 15 +--
.../pulsar/io/batchdiscovery/CronTriggerer.java | 9 +-
.../io/batchdiscovery/ImmediateTriggerer.java | 5 +-
.../pulsar/io/batchdiscovery/package-info.java} | 15 +--
.../pulsar/io/canal/CanalAbstractSource.java | 20 ++--
.../apache/pulsar/io/canal/CanalByteSource.java | 5 +-
.../apache/pulsar/io/canal/CanalSourceConfig.java | 5 +-
.../apache/pulsar/io/canal/CanalStringSource.java | 9 +-
.../org/apache/pulsar/io/canal/MessageUtils.java | 12 +--
.../org/apache/pulsar/io/canal/package-info.java} | 15 +--
.../pulsar/io/cassandra/CassandraAbstractSink.java | 4 +-
.../pulsar/io/cassandra/CassandraSinkConfig.java | 5 +-
.../apache/pulsar/io/cassandra/package-info.java} | 15 +--
.../org/apache/pulsar/io/common/IOConfigUtils.java | 14 +--
.../org/apache/pulsar/io/common/package-info.java} | 15 +--
.../org/apache/pulsar/io/core/BatchPushSource.java | 7 +-
.../org/apache/pulsar/io/core/BatchSource.java | 4 +-
.../java/org/apache/pulsar/io/core/PushSource.java | 5 +-
.../main/java/org/apache/pulsar/io/core/Sink.java | 2 +-
.../org/apache/pulsar/io/core/SinkContext.java | 4 +-
.../java/org/apache/pulsar/io/core/Source.java | 2 +-
.../org/apache/pulsar/io/core/SourceContext.java | 10 +-
.../pulsar/io/core/annotations/package-info.java} | 15 +--
.../org/apache/pulsar/io/core/package-info.java} | 15 +--
.../io/datagenerator/DataGeneratorPrintSink.java | 3 +-
.../io/datagenerator/DataGeneratorSource.java | 5 +-
.../datagenerator/DataGeneratorSourceConfig.java | 7 +-
.../org/apache/pulsar/io/datagenerator/Person.java | 3 +-
.../pulsar/io/datagenerator/package-info.java} | 15 +--
.../apache/pulsar/io/debezium/DebeziumSource.java | 7 +-
.../pulsar/io/debezium/PulsarDatabaseHistory.java | 19 ++--
.../apache/pulsar/io/debezium/package-info.java} | 15 +--
.../io/debezium/mongodb/DebeziumMongoDbSource.java | 5 +-
.../pulsar/io/debezium/mongodb/package-info.java} | 15 +--
.../io/debezium/mssql/DebeziumMsSqlSource.java | 3 +-
.../pulsar/io/debezium/mssql/package-info.java} | 15 +--
.../io/debezium/mysql/DebeziumMysqlSource.java | 3 +-
.../pulsar/io/debezium/mysql/package-info.java} | 15 +--
.../io/debezium/oracle/DebeziumOracleSource.java | 3 +-
.../pulsar/io/debezium/oracle/package-info.java} | 15 +--
.../debezium/postgres/DebeziumPostgresSource.java | 3 +-
.../pulsar/io/debezium/postgres/package-info.java} | 15 +--
.../pulsar/io/docs/ConnectorDocGenerator.java | 5 +-
.../org/apache/pulsar/io/docs/package-info.java} | 15 +--
.../apache/pulsar/io/dynamodb/DynamoDBSource.java | 33 +++---
.../pulsar/io/dynamodb/DynamoDBSourceConfig.java | 44 ++++----
.../apache/pulsar/io/dynamodb/StreamsRecord.java | 5 +-
.../pulsar/io/dynamodb/StreamsRecordProcessor.java | 5 +-
.../io/dynamodb/StreamsRecordProcessorFactory.java | 2 -
.../apache/pulsar/io/dynamodb/package-info.java} | 15 +--
.../io/elasticsearch/ElasticSearchClient.java | 115 ++++++++++-----------
.../io/elasticsearch/ElasticSearchConfig.java | 9 +-
.../pulsar/io/elasticsearch/ElasticSearchSink.java | 34 +++---
.../io/elasticsearch/ElasticSearchSslConfig.java | 3 +-
.../pulsar/io/elasticsearch/JsonConverter.java | 84 +++++++++------
.../RandomExponentialBackoffPolicy.java | 11 +-
.../io/elasticsearch/RandomExponentialRetry.java | 13 +--
.../apache/pulsar/io/file/FileConsumerThread.java | 1 -
.../java/org/apache/pulsar/io/file/FileRecord.java | 2 -
.../java/org/apache/pulsar/io/file/FileSource.java | 1 -
.../apache/pulsar/io/file/FileSourceConfig.java | 4 +-
.../org/apache/pulsar/io/file/utils/GZipFiles.java | 2 -
.../org/apache/pulsar/io/flume/FlumeConfig.java | 7 +-
.../org/apache/pulsar/io/flume/FlumeConnector.java | 18 ++--
.../flume/node/AbstractConfigurationProvider.java | 87 ++++++++--------
.../AbstractZooKeeperConfigurationProvider.java | 8 +-
.../apache/pulsar/io/flume/node/Application.java | 19 ++--
.../io/flume/node/EnvVarResolverProperties.java | 3 +-
.../io/flume/node/MaterializedConfiguration.java | 15 ++-
...PollingPropertiesFileConfigurationProvider.java | 12 +--
.../PollingZooKeeperConfigurationProvider.java | 4 +-
.../node/PropertiesFileConfigurationProvider.java | 1 -
.../node/SimpleMaterializedConfiguration.java | 4 +-
.../apache/pulsar/io/flume/node/package-info.java} | 15 +--
.../org/apache/pulsar/io/flume/package-info.java} | 15 +--
.../apache/pulsar/io/flume/sink/AbstractSink.java | 9 +-
.../apache/pulsar/io/flume/sink/SourceOfFlume.java | 17 ++-
.../apache/pulsar/io/flume/sink/package-info.java} | 15 +--
.../io/flume/source/AbstractSinkOfFlume.java | 3 +-
.../pulsar/io/flume/source/AbstractSource.java | 13 ++-
.../apache/pulsar/io/flume/source/SinkOfFlume.java | 18 ++--
.../pulsar/io/flume/source/package-info.java} | 15 +--
.../org/apache/pulsar/io/hbase/package-info.java} | 15 +--
.../pulsar/io/hbase/sink/HbaseAbstractSink.java | 22 ++--
.../io/hbase/sink/HbaseGenericRecordSink.java | 5 +-
.../pulsar/io/hbase/sink/HbaseSinkConfig.java | 11 +-
.../apache/pulsar/io/hbase/sink/package-info.java} | 15 +--
.../apache/pulsar/io/hdfs2/AbstractHdfsConfig.java | 2 -
.../pulsar/io/hdfs2/AbstractHdfsConnector.java | 2 -
.../org/apache/pulsar/io/hdfs2/SecurityUtil.java | 1 -
.../pulsar/io/hdfs2/sink/HdfsAbstractSink.java | 1 -
.../pulsar/io/hdfs2/sink/HdfsSinkConfig.java | 3 -
.../pulsar/io/hdfs2/sink/HdfsSyncThread.java | 1 -
.../sink/seq/HdfsAbstractSequenceFileSink.java | 1 -
.../io/hdfs2/sink/seq/HdfsSequentialTextSink.java | 1 -
.../pulsar/io/hdfs2/sink/seq/HdfsTextSink.java | 1 -
.../hdfs2/sink/text/HdfsAbstractTextFileSink.java | 1 -
.../apache/pulsar/io/hdfs3/AbstractHdfsConfig.java | 2 -
.../pulsar/io/hdfs3/AbstractHdfsConnector.java | 2 -
.../org/apache/pulsar/io/hdfs3/SecurityUtil.java | 1 -
.../pulsar/io/hdfs3/sink/HdfsAbstractSink.java | 1 -
.../pulsar/io/hdfs3/sink/HdfsSinkConfig.java | 3 -
.../pulsar/io/hdfs3/sink/HdfsSyncThread.java | 1 -
.../sink/seq/HdfsAbstractSequenceFileSink.java | 1 -
.../io/hdfs3/sink/seq/HdfsSequentialTextSink.java | 1 -
.../pulsar/io/hdfs3/sink/seq/HdfsTextSink.java | 1 -
.../hdfs3/sink/text/HdfsAbstractTextFileSink.java | 1 -
.../org/apache/pulsar/io/influxdb/BatchSink.java | 11 +-
.../io/influxdb/InfluxDBGenericRecordSink.java | 5 +-
.../apache/pulsar/io/influxdb/package-info.java} | 15 +--
.../io/influxdb/v1/InfluxDBAbstractSink.java | 12 +--
.../pulsar/io/influxdb/v1/InfluxDBBuilderImpl.java | 3 +-
.../io/influxdb/v1/InfluxDBGenericRecordSink.java | 11 +-
.../pulsar/io/influxdb/v1/InfluxDBSinkConfig.java | 7 +-
.../pulsar/io/influxdb/v1/package-info.java} | 15 +--
.../io/influxdb/v2/InfluxDBClientBuilderImpl.java | 5 +-
.../apache/pulsar/io/influxdb/v2/InfluxDBSink.java | 12 +--
.../pulsar/io/influxdb/v2/InfluxDBSinkConfig.java | 8 +-
.../pulsar/io/influxdb/v2/package-info.java} | 15 +--
.../org/apache/pulsar/io/jdbc/package-info.java} | 15 +--
.../pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java | 7 +-
.../apache/pulsar/io/jdbc/JdbcAbstractSink.java | 10 +-
.../org/apache/pulsar/io/jdbc/JdbcSinkConfig.java | 5 +-
.../java/org/apache/pulsar/io/jdbc/JdbcUtils.java | 4 -
.../org/apache/pulsar/io/jdbc/package-info.java} | 15 +--
.../org/apache/pulsar/io/jdbc/package-info.java} | 15 +--
.../org/apache/pulsar/io/jdbc/package-info.java} | 15 +--
.../org/apache/pulsar/io/jdbc/package-info.java} | 15 +--
.../kafka/connect/AbstractKafkaConnectSource.java | 25 ++---
.../pulsar/io/kafka/connect/KafkaConnectSink.java | 27 +++--
.../io/kafka/connect/KafkaConnectSource.java | 16 +--
.../kafka/connect/PulsarIOSourceTaskContext.java | 3 +-
.../connect/PulsarKafkaConnectSinkConfig.java | 5 +-
.../kafka/connect/PulsarKafkaSinkTaskContext.java | 28 +++--
.../io/kafka/connect/PulsarKafkaWorkerConfig.java | 4 +-
.../pulsar/io/kafka/connect/package-info.java} | 15 +--
.../io/kafka/connect/schema/KafkaConnectData.java | 17 ++-
.../connect/schema/KafkaSchemaWrappedSchema.java | 7 +-
.../connect/schema/PulsarSchemaToKafkaSchema.java | 23 +++--
.../io/kafka/connect/schema/package-info.java} | 15 +--
.../apache/pulsar/io/kafka/AvroSchemaCache.java | 9 +-
.../pulsar/io/kafka/ByteBufferSchemaWrapper.java | 5 +-
.../pulsar/io/kafka/BytesWithKafkaSchema.java | 3 +-
.../apache/pulsar/io/kafka/KafkaAbstractSink.java | 9 +-
.../pulsar/io/kafka/KafkaAbstractSource.java | 31 +++---
.../apache/pulsar/io/kafka/KafkaBytesSource.java | 21 ++--
.../apache/pulsar/io/kafka/KafkaSinkConfig.java | 14 ++-
.../apache/pulsar/io/kafka/KafkaSourceConfig.java | 5 +-
.../apache/pulsar/io/kafka/KafkaStringSource.java | 7 +-
...BytesWithKafkaSchema.java => package-info.java} | 15 +--
.../io/kinesis/AwsDefaultProviderChainPlugin.java | 3 +-
.../java/org/apache/pulsar/io/kinesis/Backoff.java | 26 -----
.../pulsar/io/kinesis/BaseKinesisConfig.java | 5 +-
.../apache/pulsar/io/kinesis/KinesisRecord.java | 9 +-
.../pulsar/io/kinesis/KinesisRecordProcessor.java | 12 +--
.../io/kinesis/KinesisRecordProcessorFactory.java | 8 +-
.../org/apache/pulsar/io/kinesis/KinesisSink.java | 33 +++---
.../pulsar/io/kinesis/KinesisSinkConfig.java | 11 +-
.../apache/pulsar/io/kinesis/KinesisSource.java | 13 +--
.../pulsar/io/kinesis/KinesisSourceConfig.java | 18 ++--
.../io/kinesis/STSAssumeRoleProviderPlugin.java | 3 +-
.../java/org/apache/pulsar/io/kinesis/Utils.java | 17 ++-
.../apache/pulsar/io/kinesis/package-info.java} | 15 +--
.../org/apache/pulsar/io/mongodb/MongoConfig.java | 19 ++--
.../org/apache/pulsar/io/mongodb/MongoSink.java | 39 ++++---
.../org/apache/pulsar/io/mongodb/MongoSource.java | 17 +--
.../org/apache/pulsar/io/netty/NettySource.java | 1 -
.../apache/pulsar/io/netty/NettySourceConfig.java | 2 -
.../io/netty/http/NettyHttpServerHandler.java | 4 -
.../apache/pulsar/io/netty/server/NettyServer.java | 20 ++--
.../io/netty/tcp/NettyTCPChannelInitializer.java | 2 +-
.../pulsar/io/netty/tcp/NettyTCPServerHandler.java | 14 ++-
.../pulsar/io/netty/udp/NettyUDPServerHandler.java | 17 ++-
.../java/org/apache/pulsar/io/nsq/NSQSource.java | 10 +-
.../org/apache/pulsar/io/nsq/NSQSourceConfig.java | 26 ++---
.../org/apache/pulsar/io/nsq/package-info.java} | 15 +--
pulsar-io/pom.xml | 18 ++++
.../pulsar/io/rabbitmq/RabbitMQAbstractConfig.java | 3 +-
.../apache/pulsar/io/rabbitmq/RabbitMQSink.java | 8 +-
.../pulsar/io/rabbitmq/RabbitMQSinkConfig.java | 9 +-
.../apache/pulsar/io/rabbitmq/RabbitMQSource.java | 8 +-
.../pulsar/io/rabbitmq/RabbitMQSourceConfig.java | 11 +-
.../apache/pulsar/io/rabbitmq/package-info.java} | 15 +--
.../pulsar/io/redis/RedisAbstractConfig.java | 5 +-
.../org/apache/pulsar/io/redis/RedisSession.java | 10 +-
.../org/apache/pulsar/io/redis/package-info.java} | 15 +--
.../org/apache/pulsar/io/redis/sink/RedisSink.java | 28 ++---
.../pulsar/io/redis/sink/RedisSinkConfig.java | 9 +-
.../apache/pulsar/io/redis/sink/package-info.java} | 15 +--
.../apache/pulsar/io/solr/SolrAbstractSink.java | 13 ++-
.../pulsar/io/solr/SolrGenericRecordSink.java | 3 +-
.../org/apache/pulsar/io/solr/SolrSinkConfig.java | 12 +--
.../org/apache/pulsar/io/solr/package-info.java} | 15 +--
.../apache/pulsar/io/twitter/TwitterFireHose.java | 6 +-
.../pulsar/io/twitter/TwitterFireHoseConfig.java | 3 -
.../pulsar/io/twitter/data/TwitterRecord.java | 3 +-
.../twitter/endpoint/SampleStatusesEndpoint.java | 1 -
210 files changed, 882 insertions(+), 1540 deletions(-)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => aerospike/src/main/java/org/apache/pulsar/io/aerospike/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => aws/src/main/java/org/apache/pulsar/io/aws/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => batch-data-generator/src/main/java/org/apache/pulsar/io/batchdatagenerator/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => batch-discovery-triggerers/src/main/java/org/apache/pulsar/io/batchdiscovery/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => canal/src/main/java/org/apache/pulsar/io/canal/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => cassandra/src/main/java/org/apache/pulsar/io/cassandra/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => common/src/main/java/org/apache/pulsar/io/common/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => core/src/main/java/org/apache/pulsar/io/core/annotations/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => core/src/main/java/org/apache/pulsar/io/core/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => data-generator/src/main/java/org/apache/pulsar/io/datagenerator/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/core/src/main/java/org/apache/pulsar/io/debezium/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/mssql/src/main/java/org/apache/pulsar/io/debezium/mssql/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/mysql/src/main/java/org/apache/pulsar/io/debezium/mysql/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/oracle/src/main/java/org/apache/pulsar/io/debezium/oracle/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => debezium/postgres/src/main/java/org/apache/pulsar/io/debezium/postgres/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => docs/src/main/java/org/apache/pulsar/io/docs/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => flume/src/main/java/org/apache/pulsar/io/flume/node/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => flume/src/main/java/org/apache/pulsar/io/flume/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => flume/src/main/java/org/apache/pulsar/io/flume/sink/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => flume/src/main/java/org/apache/pulsar/io/flume/source/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => hbase/src/main/java/org/apache/pulsar/io/hbase/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => hbase/src/main/java/org/apache/pulsar/io/hbase/sink/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => influxdb/src/main/java/org/apache/pulsar/io/influxdb/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => jdbc/postgres/src/main/java/org/apache/pulsar/io/jdbc/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => jdbc/sqlite/src/main/java/org/apache/pulsar/io/jdbc/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/package-info.java} (71%)
copy pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/{BytesWithKafkaSchema.java => package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => kinesis/src/main/java/org/apache/pulsar/io/kinesis/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => nsq/src/main/java/org/apache/pulsar/io/nsq/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => redis/src/main/java/org/apache/pulsar/io/redis/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => redis/src/main/java/org/apache/pulsar/io/redis/sink/package-info.java} (71%)
copy pulsar-io/{kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java => solr/src/main/java/org/apache/pulsar/io/solr/package-info.java} (71%)