@@ -1133,28 +1133,3 @@ def _set_consumer_timeout(self):
1133
1133
if self .config ['consumer_timeout_ms' ] >= 0 :
1134
1134
self ._consumer_timeout = time .time () + (
1135
1135
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