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%)