@@ -1133,28 +1133,3 @@ def _set_consumer_timeout(self):
11331133 if self .config ['consumer_timeout_ms' ] >= 0 :
11341134 self ._consumer_timeout = time .time () + (
11351135 self .config ['consumer_timeout_ms' ] / 1000.0 )
1136-
1137- # Old KafkaConsumer methods are deprecated
1138- def configure (self , ** configs ):
1139- raise NotImplementedError (
1140- 'deprecated -- initialize a new consumer' )
1141-
1142- def set_topic_partitions (self , * topics ):
1143- raise NotImplementedError (
1144- 'deprecated -- use subscribe() or assign()' )
1145-
1146- def fetch_messages (self ):
1147- raise NotImplementedError (
1148- 'deprecated -- use poll() or iterator interface' )
1149-
1150- def get_partition_offsets (self , topic , partition ,
1151- request_time_ms , max_num_offsets ):
1152- raise NotImplementedError (
1153- 'deprecated -- send an OffsetRequest with KafkaClient' )
1154-
1155- def offsets (self , group = None ):
1156- raise NotImplementedError ('deprecated -- use committed(partition)' )
1157-
1158- def task_done (self , message ):
1159- raise NotImplementedError (
1160- 'deprecated -- commit offsets manually if needed' )
0 commit comments