Merge pull request #79 from replicase/fix/fix-nil-pulsar-client-issue

Author: benjamin99

pkg/source/pulsar.go

@@ -178,6 +178,7 @@ func (p *PulsarConsumerSource) getConsumerName() (string, error) {
 	if p.ConsumerName != "" {
 		return p.ConsumerName, nil
 	}
+
 	hostname, err := os.Hostname()
 	if err != nil {
 		return "", err
@@ -191,6 +192,11 @@ func (p *PulsarConsumerSource) Capture(cp cursor.Checkpoint) (changes chan Chang
 		return nil, err
 	}
 
+	p.client, err = pulsar.NewClient(p.PulsarOption)
+	if err != nil {
+		return nil, err
+	}
+
 	p.consumer, err = p.client.Subscribe(pulsar.ConsumerOptions{
 		Name:                       consumerName,
 		Topic:                      p.PulsarTopic,