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