frankjkelly commented on issue #3115:
URL: https://github.com/apache/pulsar/issues/3115#issuecomment-696708072
@sijie I am using 2.6.1 Client with 2.6.1 Server
When I use the code as follows
```
private Producer<SignalEvent> getSignalProducer(String tenant) throws
PulsarClientException {
if (signalProducer.get(tenant) == null) {
signalProducer.put(tenant,
client.newProducer(Schema.JSON(SignalEvent.class))
.topic(createTopicUri(tenant, Topic.SIGNAL))
.create());
}
return signalProducer.get(tenant);
}
```
I get the error
```
Unknown type: T
org.apache.avro.AvroTypeException: Unknown type: T
at
org.apache.avro.specific.SpecificData.createSchema(SpecificData.java:410)
at
org.apache.avro.reflect.ReflectData.createSchema(ReflectData.java:663)
at
org.apache.avro.reflect.ReflectData.createFieldSchema(ReflectData.java:759)
at
org.apache.avro.reflect.ReflectData$AllowNull.createFieldSchema(ReflectData.java:86)
at
org.apache.avro.reflect.ReflectData.createSchema(ReflectData.java:615)
at
org.apache.avro.specific.SpecificData$3.computeValue(SpecificData.java:335)
at
org.apache.avro.specific.SpecificData$3.computeValue(SpecificData.java:332)
at java.base/java.lang.ClassValue.getFromHashMap(ClassValue.java:226)
at java.base/java.lang.ClassValue.getFromBackup(ClassValue.java:208)
at java.base/java.lang.ClassValue.get(ClassValue.java:114)
at
org.apache.avro.specific.SpecificData.getSchema(SpecificData.java:346)
at
org.apache.pulsar.client.impl.schema.StructSchema.extractAvroSchema(StructSchema.java:174)
at
org.apache.pulsar.client.impl.schema.StructSchema.createAvroSchema(StructSchema.java:161)
at
org.apache.pulsar.client.impl.schema.StructSchema.parseSchemaInfo(StructSchema.java:187)
at
org.apache.pulsar.client.impl.schema.JSONSchema.of(JSONSchema.java:96)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.apache.pulsar.client.internal.DefaultImplementation.lambda$newJSONSchema$26(DefaultImplementation.java:242)
at
org.apache.pulsar.client.internal.ReflectionUtils.catchExceptions(ReflectionUtils.java:35)
at
org.apache.pulsar.client.internal.DefaultImplementation.newJSONSchema(DefaultImplementation.java:239)
at org.apache.pulsar.client.api.Schema.JSON(Schema.java:260)
at
com.cogito.library.eventmanager.PulsarEventBroker.getSignalProducer(PulsarEventBroker.java:106)
at
com.cogito.library.eventmanager.PulsarEventBroker.sendEvent(PulsarEventBroker.java:184)
```
but this code works fine
```
private Producer<String> getSignalProducer(String tenant) throws
PulsarClientException {
if (signalProducer.get(tenant) == null) {
signalProducer.put(tenant, client.newProducer(Schema.STRING)
.topic(createTopicUri(tenant, Topic.SIGNAL))
.create());
}
return signalProducer.get(tenant);
}
```
Thanks!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
