3

私はカフカに書くことができます。ただし、消費は機能しません

kafka = KafkaClient(kafka_host_list)
consumer = SimpleConsumer(kafka,'topic-test-development','topic-test-development')

No handlers could be found for logger "kafka.conn"
Traceback (most recent call last):
  File "/home/ubuntu/workspace/feed-tests/tests/kafka_consumer.py", line 44, in <module>
    consumer = SimpleConsumer(kafka,'topic-test-development','topic-test-development')
  File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/simple.py", line 126, in __init__
    auto_commit_every_t=auto_commit_every_t)
  File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/base.py", line 75, in __init__
    self.fetch_last_known_offsets(partitions)
  File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/base.py", line 101, in fetch_last_known_offsets
    check_error(resp)
  File "/usr/local/lib/python2.7/dist-packages/kafka/common.py", line 230, in check_error
    raise response
kafka.common.FailedPayloadsError
4

1 に答える 1

2

ノート No handlers could be found for logger "kafka.conn"

ロガーのコードを追加: 

logging.basicConfig(
    format='%(asctime)s.%(msecs)s:%(name)s:%(thread)d:%(levelname)s:%(process)d:%(message)s',
    level=logging.DEBUG
)

実行して詳細情報を出力します：

2015-07-13 15：26：32,158.158.83088119：kafka.conn：14024790979795584：Debug：17035：Host01：9092 2015-07-13 15：9092 2015-07-13 15：26：32,221.221.3.3551507 :17035: host01:9092 で kafkaブローカーに接続できません

于 2015-07-13T07:41:25.043 に答える