This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a86f8a5 [FLINK-23812][rocksdb] support configuring RocksDB logging
(#16848)
add c675f78 [FLINK-20731] Introduce new pulsar source connector for flink.
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/fetcher/SplitFetcher.java | 4 +
flink-connectors/flink-connector-pulsar/pom.xml | 214 +++++
.../common/config/ConfigurationDataCustomizer.java | 58 ++
.../pulsar/common/config/PulsarConfigUtils.java | 279 ++++++
.../pulsar/common/config/PulsarOptions.java | 353 ++++++++
.../pulsar/common/schema/PulsarSchema.java | 223 +++++
.../pulsar/common/schema/PulsarSchemaFactory.java | 44 +
.../common/schema/PulsarSchemaTypeInformation.java | 98 +++
.../common/schema/PulsarSchemaTypeSerializer.java | 204 +++++
.../pulsar/common/schema/PulsarSchemaUtils.java | 202 +++++
.../common/schema/factories/AvroSchemaFactory.java | 48 +
.../schema/factories/BaseStructSchemaFactory.java | 42 +
.../common/schema/factories/JSONSchemaFactory.java | 41 +
.../schema/factories/KeyValueSchemaFactory.java | 84 ++
.../schema/factories/PrimitiveSchemaFactory.java | 91 ++
.../factories/ProtobufNativeSchemaFactory.java | 43 +
.../schema/factories/ProtobufSchemaFactory.java | 43 +
.../schema/factories/StringSchemaFactory.java | 48 +
.../pulsar/common/utils/PulsarExceptionUtils.java | 83 ++
.../pulsar/common/utils/PulsarJsonUtils.java | 113 +++
.../pulsar/common/utils/PulsarSerdeUtils.java | 136 +++
.../common/utils/PulsarTransactionUtils.java | 118 +++
.../connector/pulsar/source/PulsarSource.java | 211 +++++
.../pulsar/source/PulsarSourceBuilder.java | 616 +++++++++++++
.../pulsar/source/PulsarSourceOptions.java | 536 +++++++++++
.../pulsar/source/config/CursorVerification.java | 32 +
.../source/config/PulsarSourceConfigUtils.java | 258 ++++++
.../pulsar/source/config/SourceConfiguration.java | 193 ++++
.../source/enumerator/PulsarSourceEnumState.java | 88 ++
.../PulsarSourceEnumStateSerializer.java | 122 +++
.../source/enumerator/PulsarSourceEnumerator.java | 205 +++++
.../source/enumerator/SplitsAssignmentState.java | 243 +++++
.../source/enumerator/cursor/CursorPosition.java | 81 ++
.../source/enumerator/cursor/StartCursor.java | 79 ++
.../source/enumerator/cursor/StopCursor.java | 77 ++
.../cursor/start/MessageIdStartCursor.java | 67 ++
.../cursor/start/TimestampStartCursor.java | 39 +
.../cursor/stop/LatestMessageStopCursor.java | 52 ++
.../cursor/stop/MessageIdStopCursor.java | 55 ++
.../enumerator/cursor/stop/NeverStopCursor.java | 33 +
.../cursor/stop/TimestampStopCursor.java | 39 +
.../enumerator/subscriber/PulsarSubscriber.java | 71 ++
.../subscriber/impl/BasePulsarSubscriber.java | 80 ++
.../subscriber/impl/TopicListSubscriber.java | 54 ++
.../subscriber/impl/TopicPatternSubscriber.java | 101 +++
.../source/enumerator/topic/TopicMetadata.java | 57 ++
.../source/enumerator/topic/TopicNameUtils.java | 45 +
.../source/enumerator/topic/TopicPartition.java | 118 +++
.../pulsar/source/enumerator/topic/TopicRange.java | 103 +++
.../enumerator/topic/range/FullRangeGenerator.java | 40 +
.../enumerator/topic/range/RangeGenerator.java | 57 ++
.../topic/range/UniformRangeGenerator.java | 53 ++
.../source/reader/PulsarSourceReaderFactory.java | 142 +++
.../deserializer/PulsarDeserializationSchema.java | 128 +++
...DeserializationSchemaInitializationContext.java | 51 ++
.../PulsarDeserializationSchemaWrapper.java | 64 ++
.../reader/deserializer/PulsarSchemaWrapper.java | 72 ++
.../deserializer/PulsarTypeInformationWrapper.java | 66 ++
.../source/reader/emitter/PulsarRecordEmitter.java | 45 +
.../reader/fetcher/PulsarFetcherManagerBase.java | 106 +++
.../fetcher/PulsarOrderedFetcherManager.java | 75 ++
.../fetcher/PulsarUnorderedFetcherManager.java | 67 ++
.../source/reader/message/PulsarMessage.java | 74 ++
.../reader/message/PulsarMessageCollector.java | 60 ++
.../reader/source/PulsarOrderedSourceReader.java | 205 +++++
.../reader/source/PulsarSourceReaderBase.java | 88 ++
.../reader/source/PulsarUnorderedSourceReader.java | 147 ++++
.../split/PulsarOrderedPartitionSplitReader.java | 98 +++
.../split/PulsarPartitionSplitReaderBase.java | 264 ++++++
.../split/PulsarUnorderedPartitionSplitReader.java | 180 ++++
.../pulsar/source/split/PulsarPartitionSplit.java | 135 +++
.../split/PulsarPartitionSplitSerializer.java | 146 +++
.../source/split/PulsarPartitionSplitState.java | 74 ++
.../pulsar/common/schema/PulsarSchemaTest.java | 125 +++
.../schema/PulsarSchemaTypeInformationTest.java | 49 ++
.../schema/PulsarSchemaTypeSerializerTest.java | 103 +++
.../common/schema/PulsarSchemaUtilsTest.java | 106 +++
.../schema/factories/AvroSchemaFactoryTest.java | 214 +++++
.../schema/factories/JSONSchemaFactoryTest.java | 71 ++
.../factories/KeyValueSchemaFactoryTest.java | 76 ++
.../factories/ProtobufNativeSchemaFactoryTest.java | 89 ++
.../factories/ProtobufSchemaFactoryTest.java | 69 ++
.../pulsar/source/PulsarSourceBuilderTest.java | 70 ++
.../pulsar/source/PulsarSourceITCase.java | 50 ++
.../PulsarSourceEnumStateSerializerTest.java | 76 ++
.../enumerator/PulsarSourceEnumeratorTest.java | 193 ++++
.../enumerator/SplitsAssignmentStateTest.java | 124 +++
.../subscriber/PulsarSubscriberTest.java | 98 +++
.../enumerator/topic/TopicNameUtilsTest.java | 71 ++
.../enumerator/topic/TopicPartitionTest.java | 40 +
.../source/enumerator/topic/TopicRangeTest.java | 58 ++
.../PulsarDeserializationSchemaTest.java | 135 +++
.../split/PulsarPartitionSplitSerializerTest.java | 50 ++
.../source/split/PulsarPartitionSplitTest.java | 54 ++
.../pulsar/testutils/PulsarContainerContext.java | 126 +++
.../testutils/PulsarContainerContextFactory.java | 45 +
.../testutils/PulsarContainerEnvironment.java | 132 +++
.../pulsar/testutils/PulsarContainerOperator.java | 228 +++++
.../testutils/PulsarPartitionDataWriter.java | 57 ++
.../pulsar/testutils/PulsarTestSuiteBase.java | 115 +++
.../connector/pulsar/testutils/SampleData.java | 415 +++++++++
.../cases/MultipleTopicConsumingContext.java | 112 +++
.../cases/SingleTopicConsumingContext.java | 112 +++
.../test/resources/containers/txnStandalone.conf | 980 +++++++++++++++++++++
.../src/test/resources/log4j2-test.properties | 35 +
.../test/resources/protobuf/sample_message.proto | 45 +
flink-connectors/pom.xml | 1 +
.../environment/MiniClusterTestEnvironment.java | 2 +-
.../org/apache/flink/util/DockerImageVersions.java | 2 +
pom.xml | 1 +
110 files changed, 12989 insertions(+), 1 deletion(-)
create mode 100644 flink-connectors/flink-connector-pulsar/pom.xml
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/ConfigurationDataCustomizer.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarOptions.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeInformation.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeSerializer.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/AvroSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/BaseStructSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/JSONSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/KeyValueSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/PrimitiveSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufNativeSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/StringSchemaFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarExceptionUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarJsonUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarSerdeUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumState.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/SplitsAssignmentState.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/CursorPosition.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/TimestampStartCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/LatestMessageStopCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/NeverStopCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/TimestampStopCursor.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/PulsarSubscriber.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/BasePulsarSubscriber.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicListSubscriber.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicPatternSubscriber.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicMetadata.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/FullRangeGenerator.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/RangeGenerator.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/UniformRangeGenerator.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceReaderFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchema.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaInitializationContext.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaWrapper.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarSchemaWrapper.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarTypeInformationWrapper.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/emitter/PulsarRecordEmitter.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/fetcher/PulsarFetcherManagerBase.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/fetcher/PulsarOrderedFetcherManager.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/fetcher/PulsarUnorderedFetcherManager.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/message/PulsarMessage.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/message/PulsarMessageCollector.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/source/PulsarOrderedSourceReader.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/source/PulsarSourceReaderBase.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/source/PulsarUnorderedSourceReader.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarOrderedPartitionSplitReader.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarUnorderedPartitionSplitReader.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitSerializer.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitState.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeInformationTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeSerializerTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaUtilsTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/factories/AvroSchemaFactoryTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/factories/JSONSchemaFactoryTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/factories/KeyValueSchemaFactoryTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufNativeSchemaFactoryTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufSchemaFactoryTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilderTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializerTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumeratorTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/SplitsAssignmentStateTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/PulsarSubscriberTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtilsTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartitionTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRangeTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitSerializerTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitTest.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarContainerContext.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarContainerContextFactory.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarContainerEnvironment.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarContainerOperator.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarPartitionDataWriter.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarTestSuiteBase.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/SampleData.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/cases/MultipleTopicConsumingContext.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/cases/SingleTopicConsumingContext.java
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/resources/containers/txnStandalone.conf
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/resources/log4j2-test.properties
create mode 100644
flink-connectors/flink-connector-pulsar/src/test/resources/protobuf/sample_message.proto
