Elastic connector #2546
Elastic connector #2546
Conversation
…-pulsar into hdfs-connector
…tor-pulsar into elastic-connector
| @Test | ||
| public void testCassandraArchiveSink() throws Exception { | ||
| testSink(new CassandraSinkArchiveTester(), false); | ||
|
|
There was a problem hiding this comment.
Why did we delete the testCassandraArchiveSink test?
| } | ||
|
|
||
| private void testSink(SinkTester tester, boolean builtin) throws Exception { | ||
| private void testSink(SinkTester tester) throws Exception { |
There was a problem hiding this comment.
I think a bunch of changes were reverted from master by mistake?
|
run integration tests |
|
How do I view the actual cause of the error.. org.apache.pulsar.tests.integration.docker.ContainerExecException: /pulsar/bin/pulsar-admin sink create --tenant public --namespace default --name test-sink-connector-elastic_search-THREAD-name-exoiydod --sink-type elastic_search --sinkConfig {"elasticSearchUrl":"http://localhost:9200","indexName":"test-index"} --inputs test-sink-connector-ELASTIC_SEARCH-THREAD-input-topic-midgxwab failed on e463877cd694fe13c88a7b3695cabe3c2840fae0f25b095b1483f2c244ad1d05 with error code 1 |
…tor-pulsar into elastic-connector
Motivation
Added a sink connector that writes JSON documents into ElasticSearch
Modifications
Added new pulsar-io module and associated integration tests
Result
An ElasticSearch sink connector will be available for use.