@@ -1090,28 +1090,3 @@ def _set_consumer_timeout(self):
10901090 if self .config ['consumer_timeout_ms' ] >= 0 :
10911091 self ._consumer_timeout = time .time () + (
10921092 self .config ['consumer_timeout_ms' ] / 1000.0 )
1093-
1094- # Old KafkaConsumer methods are deprecated
1095- def configure (self , ** configs ):
1096- raise NotImplementedError (
1097- 'deprecated -- initialize a new consumer' )
1098-
1099- def set_topic_partitions (self , * topics ):
1100- raise NotImplementedError (
1101- 'deprecated -- use subscribe() or assign()' )
1102-
1103- def fetch_messages (self ):
1104- raise NotImplementedError (
1105- 'deprecated -- use poll() or iterator interface' )
1106-
1107- def get_partition_offsets (self , topic , partition ,
1108- request_time_ms , max_num_offsets ):
1109- raise NotImplementedError (
1110- 'deprecated -- send an OffsetRequest with KafkaClient' )
1111-
1112- def offsets (self , group = None ):
1113- raise NotImplementedError ('deprecated -- use committed(partition)' )
1114-
1115- def task_done (self , message ):
1116- raise NotImplementedError (
1117- 'deprecated -- commit offsets manually if needed' )
0 commit comments