sautran opened a new issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362 I am using kafka api, the topic is persistent and partitioned topic, in the java consumer, the consumer.poll method throws the following exception java.lang.IllegalArgumentException: Illegal base64 character 2d at java.util.Base64$Decoder.decode0(Base64.java:714) at java.util.Base64$Decoder.decode(Base64.java:526) at java.util.Base64$Decoder.decode(Base64.java:549) at org.apache.kafka.clients.consumer.KafkaConsumer.getKey(KafkaConsumer.java:364) In the producer, the key is "tenant-4", final ProducerRecord<String, byte[]> data = new ProducerRecord<>( "persistent://public/default/abc", "tenant-4", outStream.toByteArray()); In the pulsar admin api /pulsar-client consume, the message is displayed.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
