Skip to content

Instantly share code, notes, and snippets.

@barruumrex

barruumrex/kafka_ex_error

Last active February 6, 2016 22:44
Show Gist options
  • Save barruumrex/5e0cbb6329fac61f1c1c to your computer and use it in GitHub Desktop.
Save barruumrex/5e0cbb6329fac61f1c1c to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka_ex_error
[debug] Shutting down worker :Worker5
[error] GenServer :Worker5 terminating
** (FunctionClauseError) no function clause matching in KafkaEx.Protocol.Fetch.parse_response/1
(kafka_ex) lib/kafka_ex/protocol/fetch.ex:23: KafkaEx.Protocol.Fetch.parse_response(nil)
(kafka_ex) lib/kafka_ex/server.ex:274: KafkaEx.Server.fetch/8
(kafka_ex) lib/kafka_ex/server.ex:145: KafkaEx.Server.handle_info/2
(stdlib) gen_server.erl:615: :gen_server.try_dispatch/4
(stdlib) gen_server.erl:681: :gen_server.handle_msg/5
(stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3
Last message: {:start_streaming, "vehicle-data", 5, 443181, KafkaExHandler, true}
State: %KafkaEx.Server{brokers: [
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 0, port: 9092, socket: #Port<0.8357>},
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 0, port: 9092, socket: #Port<0.8358>},
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 0, port: 9092, socket: #Port<0.8359>}], consumer_group: "kafka_ex", consumer_group_update_interval: 30000, consumer_metadata: %KafkaEx.Protocol.ConsumerMetadata.Response{coordinator_host: "REDACTED", coordinator_id: 22, coordinator_port: 9092, error_code: 0}, correlation_id: 301, event_pid: #PID<0.301.0>, metadata: %KafkaEx.Protocol.Metadata.Response{brokers: [
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 20, port: 9092, socket: nil},
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 22, port: 9092, socket: nil},
%KafkaEx.Protocol.Metadata.Broker{host: "REDACTED", node_id: 21, port: 9092, socket: nil}], topic_metadatas:
[%KafkaEx.Protocol.Metadata.TopicMetadata{error_code: 0, partition_metadatas:
[
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 20, partition_id: 0, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 20, partition_id: 6, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 20, partition_id: 3, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 21, partition_id: 1, replicas: [21, 20, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 21, partition_id: 7, replicas: [21, 20, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 21, partition_id: 4, replicas: [21, 22, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 5, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 2, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 8, replicas: [22, 21, 20]}], topic: "vehicle-data"}, %KafkaEx.Protocol.Metadata.TopicMetadata{error_code: 0, partition_metadatas:
[
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 0, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 6, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 24, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 33, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 42, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 15, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 39, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 30, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 12, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 3, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 48, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 21, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 18, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 9, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 27, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 21, 20], leader: 22, partition_id: 36, replicas: [22, 21, 20]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [22, 20, 21], leader: 22, partition_id: 45, replicas: [22, 20, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 19, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 28, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 1, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 37, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 10, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 34, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 25, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 43, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 7, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 16, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 31, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 22, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 4, replicas: [20, 21, 22]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 13, replicas: [20, 22, 21]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 22, 21], leader: 20, partition_id: 49, replicas: [20, 22, ...]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, 22], leader: 20, partition_id: 40, replicas: [20, ...]},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [20, 21, ...], leader: 20, partition_id: 46, ...},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [21, ...], leader: 21, ...},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, isrs: [...], ...},
%KafkaEx.Protocol.Metadata.PartitionMetadata{error_code: 0, ...},
%KafkaEx.Protocol.Metadata.PartitionMetadata{...}, ...], topic: "__consumer_offsets"}, %KafkaEx.Protocol.Metadata.TopicMetadata{error_code: 0, partition_metad (truncated)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment