[jira] [Created] (KAFKA-8641) Invalid value ogg_kafka_test_key for configuration value.deserializer: Class ogg_kafka_test_key could not be found.

[chen qiang (JIRA)]

chen qiang created KAFKA-8641:
---------------------------------

             Summary: Invalid value ogg_kafka_test_key for configuration 
value.deserializer: Class ogg_kafka_test_key could not be found.
                 Key: KAFKA-8641
                 URL: https://issues.apache.org/jira/browse/KAFKA-8641
             Project: Kafka
          Issue Type: Bug
            Reporter: chen qiang


Invalid value ogg_kafka_test_key for configuration value.deserializer: Class 
ogg_kafka_test_key could not be found.

 

at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:715)
 at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:460)
 at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:453)
 at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62)
 at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:75)
 at 
org.apache.kafka.clients.consumer.ConsumerConfig.<init>(ConsumerConfig.java:481)
 at 
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:635)
 at 
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:617)
 at 
cc.ewell.datatools.consumer.ConsumerInitRunnable.<init>(ConsumerInitRunnable.java:59)
 at 
cc.ewell.datatools.consumer.ConsumerGroup.addInitConsumer(ConsumerGroup.java:80)
 at 
cc.ewell.datatools.service.impl.DataPushLinkServiceImpl.init(DataPushLinkServiceImpl.java:618)
 at 
cc.ewell.datatools.controller.DataPushLinkController.init(DataPushLinkController.java:180)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:497)

for (int i = 0; i < 10; i++) {
 CacheUtils.consumerGroup().push("CONSUMER_" + topic + "_" + i, 
consumerInitThread);
 new Thread(consumerInitThread, "CONSUMER_" + topic + "_" + i).start();
}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)