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

[chen qiang (JIRA)]

    [ 
https://issues.apache.org/jira/browse/KAFKA-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881094#comment-16881094
 ] 

chen qiang commented on KAFKA-8641:
-----------------------------------

我开启了10个消费者的线程，做为初始化的线程。调用这个方法时，报错了以上的错误。请问有关于多线程消费的配置吗

> 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
>            Priority: Major
>
> 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)