You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
new PulsarKafkaProducer<>(
props, new StringSerializer(), new StringSerializer<>());
fails with
org.apache.kafka.common.config.ConfigException: Missing required configuration "key.serializer" which has no default value.
Similarly, PulsarKafkaConsumer fails with missing key.deserializer/value.serializer.
To Reproduce
import java.util.Properties;
import org.apache.kafka.clients.producer.PulsarKafkaProducer;
import org.apache.kafka.common.serialization.StringSerializer;
public class ReproducePulsarBug {
public static void main(String[] args) {
Properties props = new Properties();
props.put("bootstrap.servers", "pulsar://localhost:49377");
// Only works if below two lines are commented in:
// props.put("key.serializer", StringSerializer.class.getName());
// props.put("value.serializer", StringSerializer.class.getName());
new PulsarKafkaProducer<>(
props, new StringSerializer(), new StringSerializer());
}
}
Describe the bug
fails with
Similarly, PulsarKafkaConsumer fails with missing
key.deserializer/value.serializer
.To Reproduce
Additional context
The text was updated successfully, but these errors were encountered: