Skip to content

Instantly share code, notes, and snippets.

@slashmili

slashmili/broadway_kafka_producer_state.exs Secret

Created May 6, 2022 22:09
Show Gist options
  • Save slashmili/93b1fd245e65b630bb875ebed8935f10 to your computer and use it in GitHub Desktop.
Save slashmili/93b1fd245e65b630bb875ebed8935f10 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
broadway_kafka_producer_state.exs
{:status, #PID<0.574.0>, {:module, :gen_server},
[
[
{:"$ancestors",
[MyApp.Broadway.Broadway.ProducerSupervisor,
MyApp.Broadway.Broadway.Supervisor, MyApp.Broadway, MyApp.Supervisor,
#PID<0.415.0>]},
{9, []},
{8, []},
{7, []},
{6, []},
{5, []},
{4, []},
{3, []},
{2, []},
{1, []},
{:"$initial_call", {GenStage, :init, 1}},
{0, []}
],
:running,
#PID<0.573.0>,
[],
[
header: 'Status for generic server Elixir.MyApp.Broadway.Broadway.Producer_0',
data: [
{'Status', :running},
{'Parent', #PID<0.573.0>},
{'Logged events', []}
],
data: [
{'State',
%{
consumers: [
{#PID<0.591.0>, #Reference<0.386645222.1352925190.104003>},
{#PID<0.590.0>, #Reference<0.386645222.1352925190.104002>},
{#PID<0.589.0>, #Reference<0.386645222.1352925190.104001>},
{#PID<0.588.0>, #Reference<0.386645222.1352925190.104000>},
{#PID<0.587.0>, #Reference<0.386645222.1352925190.103999>},
{#PID<0.586.0>, #Reference<0.386645222.1352925190.103998>},
{#PID<0.585.0>, #Reference<0.386645222.1352925190.103997>},
{#PID<0.584.0>, #Reference<0.386645222.1352925190.103996>},
{#PID<0.583.0>, #Reference<0.386645222.1352925190.103995>},
{#PID<0.582.0>, #Reference<0.386645222.1352925190.103991>}
],
module: BroadwayKafka.Producer,
module_state: %{
acks: %{
{35, "event.foo", 0} => {[18798, 18799, 18800, 18801, 18802,
18803, 18804, 18805, 18806, 18807, 18808, 18809, 18810, 18811,
18812, 18813, 18814, 18815, 18816, 18817, 18818, 18819, 18820,
18821, 18822, 18823, 18824, 18825, 18826, ...], 18898, []},
{35, "event.foo", 1} => {[], 18520, []},
{35, "event.foo", 2} => {[], 18260, []},
{35, "event.foo", 3} => {[], 18536, []},
{35, "event.foo", 4} => {[], 18578, []},
{35, "event.foo", 5} => {[], 18654, []},
{35, "event.foo", 6} => {[], 18599, []},
{35, "event.foo", 7} => {[], 18634, []},
{35, "event.foo", 8} => {[], 18403, []},
{35, "event.foo", 9} => {[], 28592, []},
{35, "event.foo", 10} => {[], 18737, []},
{35, "event.foo", 11} => {[], 18521, []},
{35, "event.foo", 12} => {[], 18381, []},
{35, "event.foo", 13} => {[], 18508, []},
{35, "event.foo", 14} => {[], 18566, []},
{35, "event.foo", 15} => {[], 18387, []},
{35, "event.foo", 16} => {[], 18221, []},
{35, "event.foo", 17} => {[], 18555, []},
{35, "event.foo", 18} => {[], 18434, []},
{35, "event.foo", 19} => {[], 18691, []}
},
allocator_names: {0, [MyApp.Broadway.Allocator_processor_default],
[]},
buffer: {[
{{35, "event.foo", 19},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18691}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 100",
metadata: %{
headers: [],
key: "E7B536E2BE96740BD6E05F04009723CA",
offset: 18691,
partition: 19,
topic: "event.foo",
ts: 1651874029369
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18692}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 137",
metadata: %{
headers: [],
key: "61A2E656627E58150C724BB94AD3ABDE",
offset: 18692,
partition: 19,
topic: "event.foo",
ts: 1651874029404
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18693}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 142",
metadata: %{
headers: [],
key: "34B5E63FDBDA60D4C21407F046ED3532",
offset: 18693,
partition: 19,
topic: "event.foo",
ts: 1651874029408
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18694}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 172",
metadata: %{
headers: [],
key: "E8368FA9A0CBD1F9CC19A5F2F030E6B7",
offset: 18694,
partition: 19,
topic: "event.foo",
ts: 1651874029433
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18695}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 178",
metadata: %{
headers: [],
key: "10AF7DF2DF0F6A1AE6E5227C0BB5D994",
offset: 18695,
partition: 19,
topic: "event.foo",
ts: 1651874029437
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18696}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 182",
metadata: %{
headers: [],
key: "1156AD973E10178578D4FD08FCBAE262",
offset: 18696,
partition: 19,
topic: "event.foo",
ts: 1651874029440
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18697}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 183",
metadata: %{
headers: [],
key: "35FB795CA2B59D0B410B6E1D5D983445",
offset: 18697,
partition: 19,
topic: "event.foo",
ts: 1651874029441
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18698}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 202",
metadata: %{
headers: [],
key: "CE58D42808DBACD83D5F6242CD6E5E4E",
offset: 18698,
partition: 19,
topic: "event.foo",
ts: 1651874029454
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18699}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 210",
metadata: %{
headers: [],
key: "176A5124E1A1812202195CE9005C0878",
offset: 18699,
partition: 19,
topic: "event.foo",
ts: 1651874029459
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18700}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 232",
metadata: %{
headers: [],
key: "DF074BA0A128B3F7FBF4BE15F326E54F",
offset: 18700,
partition: 19,
topic: "event.foo",
ts: 1651874029475
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18701}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 251",
metadata: %{
headers: [],
key: "A748907A06D9EBA097742708770C34C7",
offset: 18701,
partition: 19,
topic: "event.foo",
ts: 1651874029489
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18702}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 259",
metadata: %{
headers: [],
key: "A1FAB8B618FD1BCDCEB735A963028819",
offset: 18702,
partition: 19,
topic: "event.foo",
ts: 1651874029495
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18703}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 284",
metadata: %{
headers: [],
key: "6B2A73B3DA98CC776A0020BE1D63B265",
offset: 18703,
partition: 19,
topic: "event.foo",
ts: 1651874029513
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18704}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 318",
metadata: %{
headers: [],
key: "1F21082E3A8B7B9B9581C94167CFDF5C",
offset: 18704,
partition: 19,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18705}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 336",
metadata: %{
headers: [],
key: "0C0B3FC01A307D2E268D2C5EE18D647B",
offset: 18705,
partition: 19,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18706}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 381",
metadata: %{
headers: [],
key: "383A1B779433724A18699C4E43AF791F",
offset: 18706,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 19}}, %{offset: 18707}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 385",
metadata: %{
headers: [],
key: "581B3F5B1B88EEBEB1C1D2B12EF5CF98",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18708}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 412",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18709}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 449",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18710}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
data: "body 460",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 19},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 18},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18434}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 90",
metadata: %{
headers: [],
key: "7CADA1AA03F429E0CD275F141BB12405",
offset: 18434,
partition: 18,
topic: "event.foo",
ts: 1651874029359
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18435}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 117",
metadata: %{
headers: [],
key: "6A8A7A41286B1BE625925435C31E23C9",
offset: 18435,
partition: 18,
topic: "event.foo",
ts: 1651874029384
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18436}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 120",
metadata: %{
headers: [],
key: "3817A7FBAF8ABD1674E22A471D68D232",
offset: 18436,
partition: 18,
topic: "event.foo",
ts: 1651874029387
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18437}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 121",
metadata: %{
headers: [],
key: "CCC827CD0F1D0842EC3FAC216C2F68E0",
offset: 18437,
partition: 18,
topic: "event.foo",
ts: 1651874029388
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18438}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 170",
metadata: %{
headers: [],
key: "AB837705E27CD20447AADCA8CE79611C",
offset: 18438,
partition: 18,
topic: "event.foo",
ts: 1651874029431
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18439}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 194",
metadata: %{
headers: [],
key: "CB59899FDAB734D4CA16D20E826ED640",
offset: 18439,
partition: 18,
topic: "event.foo",
ts: 1651874029448
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18440}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 199",
metadata: %{
headers: [],
key: "11980BBA9AFFDE26E1A87560D0CFDE98",
offset: 18440,
partition: 18,
topic: "event.foo",
ts: 1651874029452
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18441}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 207",
metadata: %{
headers: [],
key: "A301FF2BE73B63B53CE566258BDF69C1",
offset: 18441,
partition: 18,
topic: "event.foo",
ts: 1651874029457
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18442}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 234",
metadata: %{
headers: [],
key: "B39CFF2D15B5B3AD57366C37A5ED0D36",
offset: 18442,
partition: 18,
topic: "event.foo",
ts: 1651874029476
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18443}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 241",
metadata: %{
headers: [],
key: "9F12C38D03832E0DFF88408C5908DC2A",
offset: 18443,
partition: 18,
topic: "event.foo",
ts: 1651874029482
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18444}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 256",
metadata: %{
headers: [],
key: "DC8BCF8F980CA49F15DF6133EDA2057A",
offset: 18444,
partition: 18,
topic: "event.foo",
ts: 1651874029493
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18445}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 270",
metadata: %{
headers: [],
key: "3EA9E207D8B19BF12461F479650EC91D",
offset: 18445,
partition: 18,
topic: "event.foo",
ts: 1651874029503
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18446}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 273",
metadata: %{
headers: [],
key: "2A96ADC5634304EAF191AD8A7E6A9BA0",
offset: 18446,
partition: 18,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18447}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 279",
metadata: %{
headers: [],
key: "34E4E560DC98A1513A9ABE1FF4021924",
offset: 18447,
partition: 18,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18448}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 280",
metadata: %{
headers: [],
key: "5BC961DB453BC381E80121C87331DF15",
offset: 18448,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 18}}, %{offset: 18449}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 312",
metadata: %{
headers: [],
key: "575FDBFCF4E8923067D5CFB1D5F57C96",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18450}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 313",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18451}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 319",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18452}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
data: "body 365",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 18},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 17},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18555}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 79",
metadata: %{
headers: [],
key: "6F2CB68CBC4BBD47433B490B0D5F9A85",
offset: 18555,
partition: 17,
topic: "event.foo",
ts: 1651874029347
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18556}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 94",
metadata: %{
headers: [],
key: "4918774A42CDD2FC66757475BE769890",
offset: 18556,
partition: 17,
topic: "event.foo",
ts: 1651874029364
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18557}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 211",
metadata: %{
headers: [],
key: "7DF0EF69FE8BD89B29694026435B9AD9",
offset: 18557,
partition: 17,
topic: "event.foo",
ts: 1651874029460
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18558}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 239",
metadata: %{
headers: [],
key: "53EB16A21C3D484C6EFEB6E121ED1D98",
offset: 18558,
partition: 17,
topic: "event.foo",
ts: 1651874029480
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18559}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 254",
metadata: %{
headers: [],
key: "405CE890DB9D89DB1F34F100471F9EC9",
offset: 18559,
partition: 17,
topic: "event.foo",
ts: 1651874029491
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18560}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 299",
metadata: %{
headers: [],
key: "0E2A09DD8A0094CA8CCE210A7392908E",
offset: 18560,
partition: 17,
topic: "event.foo",
ts: 1651874029523
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18561}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 304",
metadata: %{
headers: [],
key: "0826A3D716CBC07E15C3A10652A27548",
offset: 18561,
partition: 17,
topic: "event.foo",
ts: 1651874029526
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18562}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 321",
metadata: %{
headers: [],
key: "F43907D840078F2155F14086C2725F63",
offset: 18562,
partition: 17,
topic: "event.foo",
ts: 1651874029538
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18563}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 328",
metadata: %{
headers: [],
key: "A82478A7173A86035386CFB9266521E2",
offset: 18563,
partition: 17,
topic: "event.foo",
ts: 1651874029543
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18564}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 341",
metadata: %{
headers: [],
key: "8353AEA601A524E50904F7131C41E50C",
offset: 18564,
partition: 17,
topic: "event.foo",
ts: 1651874029552
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18565}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 367",
metadata: %{
headers: [],
key: "C40FA229DE87A1E3B69209BC26150D7C",
offset: 18565,
partition: 17,
topic: "event.foo",
ts: 1651874029570
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18566}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 405",
metadata: %{
headers: [],
key: "3525245A88FF89083FD67A905361F827",
offset: 18566,
partition: 17,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18567}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 407",
metadata: %{
headers: [],
key: "65E6EB6CEB304DDF2103CDD0775BF9B5",
offset: 18567,
partition: 17,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18568}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 435",
metadata: %{
headers: [],
key: "C8AED92684D3F0825117F89D74107269",
offset: 18568,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 17}}, %{offset: 18569}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 445",
metadata: %{
headers: [],
key: "E5C2531E931EE49C9CFA7715621736D7",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18570}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 468",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18571}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 474",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18572}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
data: "body 475",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 17},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 16},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18221}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 128",
metadata: %{
headers: [],
key: "D5D7AFBF28B698EAD1AC38E8E2A7F18C",
offset: 18221,
partition: 16,
topic: "event.foo",
ts: 1651874029397
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18222}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 133",
metadata: %{
headers: [],
key: "893C1DE4575D12D4D36B786CA919A0A5",
offset: 18222,
partition: 16,
topic: "event.foo",
ts: 1651874029401
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18223}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 138",
metadata: %{
headers: [],
key: "702559ACB3CE4E66142E067D50C78D23",
offset: 18223,
partition: 16,
topic: "event.foo",
ts: 1651874029405
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18224}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 140",
metadata: %{
headers: [],
key: "9FD92F1C656450956D971C4A629E1D33",
offset: 18224,
partition: 16,
topic: "event.foo",
ts: 1651874029407
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18225}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 159",
metadata: %{
headers: [],
key: "C46EA2CEABC33AF6A7255DAA094056CE",
offset: 18225,
partition: 16,
topic: "event.foo",
ts: 1651874029423
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18226}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 161",
metadata: %{
headers: [],
key: "987BF11AD942C52DF7A377AF447FF940",
offset: 18226,
partition: 16,
topic: "event.foo",
ts: 1651874029425
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18227}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 193",
metadata: %{
headers: [],
key: "7C94D82C8130806B6AF9E10B2F43F637",
offset: 18227,
partition: 16,
topic: "event.foo",
ts: 1651874029447
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18228}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 221",
metadata: %{
headers: [],
key: "EC4542CE62E98131197BA621F25CBDCB",
offset: 18228,
partition: 16,
topic: "event.foo",
ts: 1651874029467
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18229}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 229",
metadata: %{
headers: [],
key: "A5E3B1F3BA5CDF7E46655BBA21DF5416",
offset: 18229,
partition: 16,
topic: "event.foo",
ts: 1651874029473
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18230}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 242",
metadata: %{
headers: [],
key: "3F006BDEC25354C07504D79F3E8AD058",
offset: 18230,
partition: 16,
topic: "event.foo",
ts: 1651874029482
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18231}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 276",
metadata: %{
headers: [],
key: "AD6DE4234EBFD289DB4A6DB2E68702DA",
offset: 18231,
partition: 16,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18232}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 282",
metadata: %{
headers: [],
key: "AA6814E633BC9CF27E21995CD0680BA5",
offset: 18232,
partition: 16,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18233}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 286",
metadata: %{
headers: [],
key: "03DA116A53C5FFAE7B9B7105EFC988D7",
offset: 18233,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 16}}, %{offset: 18234}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 331",
metadata: %{
headers: [],
key: "09CF44F4C09BA67BBDE1010EB92C61B1",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18235}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 351",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18236}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 361",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18237}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
data: "body 369",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 16},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 15},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18387}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 108",
metadata: %{
headers: [],
key: "9C162AD465BEBCC349501BCBBA62773A",
offset: 18387,
partition: 15,
topic: "event.foo",
ts: 1651874029375
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18388}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 136",
metadata: %{
headers: [],
key: "811774677B2A54B136E5D8F392CA3E7B",
offset: 18388,
partition: 15,
topic: "event.foo",
ts: 1651874029404
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18389}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 176",
metadata: %{
headers: [],
key: "78EEA65D14619EA8B80896447D1762D5",
offset: 18389,
partition: 15,
topic: "event.foo",
ts: 1651874029436
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18390}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 181",
metadata: %{
headers: [],
key: "923A7E2B15C738377995988538742564",
offset: 18390,
partition: 15,
topic: "event.foo",
ts: 1651874029439
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18391}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 185",
metadata: %{
headers: [],
key: "BBE1A7F79B6A7C82489AE97385E1AD98",
offset: 18391,
partition: 15,
topic: "event.foo",
ts: 1651874029442
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18392}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 196",
metadata: %{
headers: [],
key: "7E83D3ED0310235AD48B894426178B86",
offset: 18392,
partition: 15,
topic: "event.foo",
ts: 1651874029450
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18393}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 200",
metadata: %{
headers: [],
key: "73CDD5962942DF4DE721C5A4594D9194",
offset: 18393,
partition: 15,
topic: "event.foo",
ts: 1651874029452
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18394}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 214",
metadata: %{
headers: [],
key: "9EC8D7727D6666FA82D834577274B650",
offset: 18394,
partition: 15,
topic: "event.foo",
ts: 1651874029462
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18395}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 217",
metadata: %{
headers: [],
key: "51288A5B7927D48E0BBAB433B9982AEC",
offset: 18395,
partition: 15,
topic: "event.foo",
ts: 1651874029464
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18396}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 222",
metadata: %{
headers: [],
key: "42ABDE66DD55541E58195088A6308677",
offset: 18396,
partition: 15,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18397}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 255",
metadata: %{
headers: [],
key: "19A553528465A084455BA025ADA2899F",
offset: 18397,
partition: 15,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18398}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 268",
metadata: %{
headers: [],
key: "CA497E23B042527EA46ECD960487EAA2",
offset: 18398,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 15}}, %{offset: 18399}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 272",
metadata: %{
headers: [],
key: "C5BA557B1AA8DD5E64CB7F2664A2FDCD",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18400}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 322",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18401}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 357",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18402}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
data: "body 359",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 15},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 14},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18566}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 64",
metadata: %{
headers: [],
key: "FAE2CE49CBDBC3016A7ABEFECF0B84E3",
offset: 18566,
partition: 14,
topic: "event.foo",
ts: 1651874029336
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18567}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 77",
metadata: %{
headers: [],
key: "1EACBB09CA582EBE71BF1192CEB381CF",
offset: 18567,
partition: 14,
topic: "event.foo",
ts: 1651874029346
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18568}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 88",
metadata: %{
headers: [],
key: "FB67B875C7CCEE251461A70739A8AEAC",
offset: 18568,
partition: 14,
topic: "event.foo",
ts: 1651874029358
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18569}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 89",
metadata: %{
headers: [],
key: "4DB45ECB2862EB5557682ACC62AD4691",
offset: 18569,
partition: 14,
topic: "event.foo",
ts: 1651874029359
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18570}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 123",
metadata: %{
headers: [],
key: "AA6DC3D02393DB4A534F358B1C7842C0",
offset: 18570,
partition: 14,
topic: "event.foo",
ts: 1651874029390
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18571}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 135",
metadata: %{
headers: [],
key: "A1F6A583F4DD3EDF422DA0D66BB4AE45",
offset: 18571,
partition: 14,
topic: "event.foo",
ts: 1651874029403
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18572}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 143",
metadata: %{
headers: [],
key: "7016784542D460B8D3FA8015677E57C6",
offset: 18572,
partition: 14,
topic: "event.foo",
ts: 1651874029409
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18573}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 146",
metadata: %{
headers: [],
key: "F0AD6A89DE162933CE89D27C9F833EA4",
offset: 18573,
partition: 14,
topic: "event.foo",
ts: 1651874029411
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18574}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 148",
metadata: %{
headers: [],
key: "5B1200CF4BD0E04520125FA16C4B075A",
offset: 18574,
partition: 14,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18575}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 153",
metadata: %{
headers: [],
key: "D915246F14FF20B3A72CE42A739DE573",
offset: 18575,
partition: 14,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18576}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 187",
metadata: %{
headers: [],
key: "2C95EB986B960D5311B81942EC6156FF",
offset: 18576,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 14}}, %{offset: 18577}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 228",
metadata: %{
headers: [],
key: "24F21608F5246187133F847C13F52818",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18578}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 237",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18579}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 244",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18580}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
data: "body 294",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 14},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 13},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18508}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 44",
metadata: %{
headers: [],
key: "4AC60085503BD71B890B8FF525541B17",
offset: 18508,
partition: 13,
topic: "event.foo",
ts: 1651874029320
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18509}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 49",
metadata: %{
headers: [],
key: "B6FDD49CC9C0555AAEC014636432B40A",
offset: 18509,
partition: 13,
topic: "event.foo",
ts: 1651874029324
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18510}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 57",
metadata: %{
headers: [],
key: "15E8FF09EC54001BB9C40EABC99B8D59",
offset: 18510,
partition: 13,
topic: "event.foo",
ts: 1651874029330
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18511}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 68",
metadata: %{
headers: [],
key: "3F3CEB71F57B24F74FC239710F9D5436",
offset: 18511,
partition: 13,
topic: "event.foo",
ts: 1651874029339
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18512}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 74",
metadata: %{
headers: [],
key: "3AD8923D3467926752D161FB86748D4D",
offset: 18512,
partition: 13,
topic: "event.foo",
ts: 1651874029344
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18513}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 95",
metadata: %{
headers: [],
key: "A3B3071D5D04C37E58A6D2F76E994BB0",
offset: 18513,
partition: 13,
topic: "event.foo",
ts: 1651874029365
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18514}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 98",
metadata: %{
headers: [],
key: "4AE313FEF3B680657F414874E57D5995",
offset: 18514,
partition: 13,
topic: "event.foo",
ts: 1651874029367
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18515}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 103",
metadata: %{
headers: [],
key: "045807D4A8594AAB23A88E7328EDDBC5",
offset: 18515,
partition: 13,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18516}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 162",
metadata: %{
headers: [],
key: "0AB33B09D54933BCEE1E02874FDADECF",
offset: 18516,
partition: 13,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18517}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 250",
metadata: %{
headers: [],
key: "0E45F8A86E9FE4401CA9A5285555988F",
offset: 18517,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 13}}, %{offset: 18518}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 271",
metadata: %{
headers: [],
key: "EBEC829EF77099BB63E036A9287C4E87",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18519}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 290",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18520}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 291",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18521}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
data: "body 307",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 13},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 12},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18381}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 86",
metadata: %{
headers: [],
key: "F6C62A7BED8584A6195D638AAF57CD4F",
offset: 18381,
partition: 12,
topic: "event.foo",
ts: 1651874029356
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18382}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 96",
metadata: %{
headers: [],
key: "4011D0856B172068527E689892F82D61",
offset: 18382,
partition: 12,
topic: "event.foo",
ts: 1651874029366
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18383}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 105",
metadata: %{
headers: [],
key: "B0203F6E09921EC57105F8D4B2A36F0B",
offset: 18383,
partition: 12,
topic: "event.foo",
ts: 1651874029373
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18384}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 124",
metadata: %{
headers: [],
key: "DA6555901A1A0D9323F6E404A218D5FC",
offset: 18384,
partition: 12,
topic: "event.foo",
ts: 1651874029393
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18385}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 157",
metadata: %{
headers: [],
key: "AE45488B1D249229B75AE6BAC0AA8025",
offset: 18385,
partition: 12,
topic: "event.foo",
ts: 1651874029421
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18386}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 158",
metadata: %{
headers: [],
key: "A1E9CB51B4CFFC1B2AC0FF96727F8B62",
offset: 18386,
partition: 12,
topic: "event.foo",
ts: 1651874029422
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18387}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 164",
metadata: %{
headers: [],
key: "76CE218BE35AC06610A170BADEBD7DBB",
offset: 18387,
partition: 12,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18388}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 168",
metadata: %{
headers: [],
key: "87F5E660291BB2D2C1D0AFAA47B8AB61",
offset: 18388,
partition: 12,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18389}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 173",
metadata: %{
headers: [],
key: "36A78CBFEEF211F18BFFCDB2E66C65F9",
offset: 18389,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 12}}, %{offset: 18390}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 208",
metadata: %{
headers: [],
key: "CF36F4AFD017CB60DB9F69226BB13EA3",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18391}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 248",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18392}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 253",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18393}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
data: "body 266",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 12},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 11},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18521}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 66",
metadata: %{
headers: [],
key: "30C2F2A2D740B1B66A2491E080BCD9E7",
offset: 18521,
partition: 11,
topic: "event.foo",
ts: 1651874029338
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18522}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 99",
metadata: %{
headers: [],
key: "0A5C092C8E22077B032C93CF6C58B738",
offset: 18522,
partition: 11,
topic: "event.foo",
ts: 1651874029368
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18523}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 102",
metadata: %{
headers: [],
key: "33394210B2060A02D21E2900A8182557",
offset: 18523,
partition: 11,
topic: "event.foo",
ts: 1651874029371
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18524}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 126",
metadata: %{
headers: [],
key: "ACA4ACD240D1EB53BF116CC7167C9B99",
offset: 18524,
partition: 11,
topic: "event.foo",
ts: 1651874029395
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18525}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 151",
metadata: %{
headers: [],
key: "61B1F3DF82131386392B1D8E276DBE3E",
offset: 18525,
partition: 11,
topic: "event.foo",
ts: 1651874029416
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18526}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 171",
metadata: %{
headers: [],
key: "FCD94AB9D5D0DDB07310C547AFCA803B",
offset: 18526,
partition: 11,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18527}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 174",
metadata: %{
headers: [],
key: "7807B97CBC93CAF236D97C5FE345CCDC",
offset: 18527,
partition: 11,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18528}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 180",
metadata: %{
headers: [],
key: "702A82322CB00393F50436067290C16D",
offset: 18528,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 11}}, %{offset: 18529}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 184",
metadata: %{
headers: [],
key: "ADA8E04FFA262F8D5FC719574CD18EA3",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18530}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 240",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18531}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 335",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18532}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
data: "body 386",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 11},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 10},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18737}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 38",
metadata: %{
headers: [],
key: "763A6D4D30173EDB75AC0DC8B68DD77C",
offset: 18737,
partition: 10,
topic: "event.foo",
ts: 1651874029315
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18738}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 41",
metadata: %{
headers: [],
key: "80F0ABCC2FDEF567F2C29539428612F9",
offset: 18738,
partition: 10,
topic: "event.foo",
ts: 1651874029318
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18739}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 43",
metadata: %{
headers: [],
key: "8D2461171CC29C30FF8B5EBB1566D1EC",
offset: 18739,
partition: 10,
topic: "event.foo",
ts: 1651874029319
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18740}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 97",
metadata: %{
headers: [],
key: "2F13E88E77E5B3B27F3DA1EFAC6BD4F6",
offset: 18740,
partition: 10,
topic: "event.foo",
ts: 1651874029367
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18741}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 112",
metadata: %{
headers: [],
key: "AB4587DD260CF1A57DFB9F478712C7FB",
offset: 18741,
partition: 10,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18742}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 122",
metadata: %{
headers: [],
key: "7F8F3527E32F87BC91BED0EB4B26A6E5",
offset: 18742,
partition: 10,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18743}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 141",
metadata: %{
headers: [],
key: "E9E2190264D5242427C14C72251EB10D",
offset: 18743,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 10}}, %{offset: 18744}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 147",
metadata: %{
headers: [],
key: "813AA64BFBD24AC4B999846AFA5BE27C",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18745}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 198",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18746}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 206",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18747}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
data: "body 257",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 10},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]}
],
[
{{35, "event.foo", 0},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18898}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 3907",
metadata: %{
headers: [],
key: "AEF775BB482E99B364B7FD4B172F2454",
offset: 18898,
partition: 0,
topic: "event.foo",
ts: 1651874032220
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18899}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 3923",
metadata: %{
headers: [],
key: "97A866CFBB46D3FC45AABFCE81E54DF4",
offset: 18899,
partition: 0,
topic: "event.foo",
ts: 1651874032230
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18900}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4010",
metadata: %{
headers: [],
key: "6A5868E9E3B94CFFA8806B38D46BA32E",
offset: 18900,
partition: 0,
topic: "event.foo",
ts: 1651874032288
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18901}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4045",
metadata: %{
headers: [],
key: "8054518176FAC747D914A00838D33412",
offset: 18901,
partition: 0,
topic: "event.foo",
ts: 1651874032312
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18902}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4107",
metadata: %{
headers: [],
key: "1636EF537B0778BA8A40454732410E1B",
offset: 18902,
partition: 0,
topic: "event.foo",
ts: 1651874032359
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18903}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4148",
metadata: %{
headers: [],
key: "145AA01197165411EA43C520CBF00B41",
offset: 18903,
partition: 0,
topic: "event.foo",
ts: 1651874032391
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18904}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4150",
metadata: %{
headers: [],
key: "4D07BF81D67697265273EAD45D8146C3",
offset: 18904,
partition: 0,
topic: "event.foo",
ts: 1651874032393
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18905}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4169",
metadata: %{
headers: [],
key: "36EDE54B8926E0B0E3C7067620C6B633",
offset: 18905,
partition: 0,
topic: "event.foo",
ts: 1651874032406
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18906}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4188",
metadata: %{
headers: [],
key: "B70D2ADBF0BB6391FA542996A41AFBC6",
offset: 18906,
partition: 0,
topic: "event.foo",
ts: 1651874032420
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18907}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4198",
metadata: %{
headers: [],
key: "DCB718F81E7E41297EE86760364FB1ED",
offset: 18907,
partition: 0,
topic: "event.foo",
ts: 1651874032428
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18908}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4202",
metadata: %{
headers: [],
key: "B5E414313D60D5A3E01A5283E4B0D2B3",
offset: 18908,
partition: 0,
topic: "event.foo",
ts: 1651874032431
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18909}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4206",
metadata: %{
headers: [],
key: "1E71DFDEB21CAFBAD227A694DDC13082",
offset: 18909,
partition: 0,
topic: "event.foo",
ts: 1651874032434
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18910}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4208",
metadata: %{
headers: [],
key: "E5DC4656663AB7A3E454E5922DCF5411",
offset: 18910,
partition: 0,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18911}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4248",
metadata: %{
headers: [],
key: "8C942DBA99C74B13F74AA2C4EC7C82C1",
offset: 18911,
partition: 0,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18912}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4256",
metadata: %{
headers: [],
key: "703990FE7599BF0448448A755DA2F047",
offset: 18912,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 0}}, %{offset: 18913}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4259",
metadata: %{
headers: [],
key: "2873A23D219DB112AEFD0C316D8B5ED7",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18914}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4318",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18915}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4319",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18916}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
data: "body 4337",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 0},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 1},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18520}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 14",
metadata: %{
headers: [],
key: "C8F93A41F361D5CF9627D29C7364DE2B",
offset: 18520,
partition: 1,
topic: "event.foo",
ts: 1651874029288
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18521}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 22",
metadata: %{
headers: [],
key: "D265C5E0B6435D17183D3127FCEB6D98",
offset: 18521,
partition: 1,
topic: "event.foo",
ts: 1651874029297
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18522}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 54",
metadata: %{
headers: [],
key: "7B405C262317A5A1B4ED5533AA833602",
offset: 18522,
partition: 1,
topic: "event.foo",
ts: 1651874029328
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18523}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 59",
metadata: %{
headers: [],
key: "DAB9C639ECDC715E47737E2892722D5D",
offset: 18523,
partition: 1,
topic: "event.foo",
ts: 1651874029331
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18524}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 65",
metadata: %{
headers: [],
key: "51E94A43727F1C6F11CFEDB877DAFFDE",
offset: 18524,
partition: 1,
topic: "event.foo",
ts: 1651874029337
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18525}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 67",
metadata: %{
headers: [],
key: "B5842E7A0F862BD20DF25EA14B83C458",
offset: 18525,
partition: 1,
topic: "event.foo",
ts: 1651874029338
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18526}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 93",
metadata: %{
headers: [],
key: "3C2A2ED6FF13CEABF2D5446B483D864E",
offset: 18526,
partition: 1,
topic: "event.foo",
ts: 1651874029363
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18527}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 104",
metadata: %{
headers: [],
key: "F7AB1DB0A4760B49F87F6272364DAC00",
offset: 18527,
partition: 1,
topic: "event.foo",
ts: 1651874029372
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18528}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 119",
metadata: %{
headers: [],
key: "4DC5615D697B9715462398B833D8382A",
offset: 18528,
partition: 1,
topic: "event.foo",
ts: 1651874029386
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18529}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 165",
metadata: %{
headers: [],
key: "DF606FC9F1CF6D4A82769E88867CF7A2",
offset: 18529,
partition: 1,
topic: "event.foo",
ts: 1651874029428
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18530}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 213",
metadata: %{
headers: [],
key: "068CE543E3B1A929751CA5034E77760A",
offset: 18530,
partition: 1,
topic: "event.foo",
ts: 1651874029461
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18531}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 227",
metadata: %{
headers: [],
key: "38F550BF7EABDA51E71FDB471A191B37",
offset: 18531,
partition: 1,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18532}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 314",
metadata: %{
headers: [],
key: "969E96647E59BE62A6570D091C6984B4",
offset: 18532,
partition: 1,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18533}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 317",
metadata: %{
headers: [],
key: "222711F9DF1B44F9E74951674D13B057",
offset: 18533,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 1}}, %{offset: 18534}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 320",
metadata: %{
headers: [],
key: "00C61A07D8FD616ECEC23F27176CA44D",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18535}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 346",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18536}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 374",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18537}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
data: "body 452",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 1},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 2},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18260}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 15",
metadata: %{
headers: [],
key: "5BF0B81EBFED5C097B45A39B28856665",
offset: 18260,
partition: 2,
topic: "event.foo",
ts: 1651874029289
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18261}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 17",
metadata: %{
headers: [],
key: "01F48DFFB77945C567DF2E1CD5C29A52",
offset: 18261,
partition: 2,
topic: "event.foo",
ts: 1651874029292
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18262}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 23",
metadata: %{
headers: [],
key: "77BE7E9EE82204E80392C7DABF38B98F",
offset: 18262,
partition: 2,
topic: "event.foo",
ts: 1651874029298
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18263}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 34",
metadata: %{
headers: [],
key: "C4D4B690A778930BF0E92D1C2D135E47",
offset: 18263,
partition: 2,
topic: "event.foo",
ts: 1651874029311
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18264}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 39",
metadata: %{
headers: [],
key: "9C45FE3EBF75CBA0120FBADF4188C7F1",
offset: 18264,
partition: 2,
topic: "event.foo",
ts: 1651874029316
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18265}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 47",
metadata: %{
headers: [],
key: "A824DB03D6A7F9FCE6AA5D06EDAC58E3",
offset: 18265,
partition: 2,
topic: "event.foo",
ts: 1651874029322
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18266}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 63",
metadata: %{
headers: [],
key: "8B906186BEBE5C38B32FDB84A95D9686",
offset: 18266,
partition: 2,
topic: "event.foo",
ts: 1651874029335
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18267}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 82",
metadata: %{
headers: [],
key: "69187244E4C00BD26E4CEFB5553C7BB3",
offset: 18267,
partition: 2,
topic: "event.foo",
ts: 1651874029352
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18268}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 84",
metadata: %{
headers: [],
key: "635109975ED37D0D2DC2A6F5102CCA5F",
offset: 18268,
partition: 2,
topic: "event.foo",
ts: 1651874029354
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18269}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 139",
metadata: %{
headers: [],
key: "44788FC21FC9EF10A0700D1F8D197EF6",
offset: 18269,
partition: 2,
topic: "event.foo",
ts: 1651874029406
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18270}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 190",
metadata: %{
headers: [],
key: "8BB7581FD9C7AF4C3463CA2E5691C959",
offset: 18270,
partition: 2,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18271}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 223",
metadata: %{
headers: [],
key: "BB13C2CA5F9D0300B6BA4E8ABD1D712A",
offset: 18271,
partition: 2,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18272}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 243",
metadata: %{
headers: [],
key: "DFA830409AE26C8F0A20A534E0EA95DB",
offset: 18272,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 2}}, %{offset: 18273}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 397",
metadata: %{
headers: [],
key: "62AFB04B01C5562A9657382E718E11D9",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18274}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 398",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18275}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 401",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18276}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
data: "body 423",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 2},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 3},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18536}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 9",
metadata: %{
headers: [],
key: "C72D3DF5ABC4D4238297D1495F7A158F",
offset: 18536,
partition: 3,
topic: "event.foo",
ts: 1651874029281
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18537}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 18",
metadata: %{
headers: [],
key: "A3BE8339BB7A65665515ED6C00A36DD1",
offset: 18537,
partition: 3,
topic: "event.foo",
ts: 1651874029293
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18538}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 125",
metadata: %{
headers: [],
key: "22F04D2398837A53C5FCFF4BB8862C2F",
offset: 18538,
partition: 3,
topic: "event.foo",
ts: 1651874029394
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18539}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 226",
metadata: %{
headers: [],
key: "CF42ED21E0FEB3623871AA1EE6477BE9",
offset: 18539,
partition: 3,
topic: "event.foo",
ts: 1651874029471
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18540}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 230",
metadata: %{
headers: [],
key: "098346BF526180FBEF69370BB10884A3",
offset: 18540,
partition: 3,
topic: "event.foo",
ts: 1651874029473
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18541}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 231",
metadata: %{
headers: [],
key: "E6CCE9C4237760D372E7A80C0E6109B0",
offset: 18541,
partition: 3,
topic: "event.foo",
ts: 1651874029474
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18542}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 233",
metadata: %{
headers: [],
key: "8D0DF686F431618CD1D38C00E46FF875",
offset: 18542,
partition: 3,
topic: "event.foo",
ts: 1651874029475
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18543}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 236",
metadata: %{
headers: [],
key: "0425DE5525EE86DE359ECD1136CC8052",
offset: 18543,
partition: 3,
topic: "event.foo",
ts: 1651874029478
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18544}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 247",
metadata: %{
headers: [],
key: "8975C24A205FBB1D56BBDE2AA7814085",
offset: 18544,
partition: 3,
topic: "event.foo",
ts: 1651874029486
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18545}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 281",
metadata: %{
headers: [],
key: "D5BACFEEBB8D701413729D45B783B627",
offset: 18545,
partition: 3,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18546}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 293",
metadata: %{
headers: [],
key: "B5D2153530B8CEA233798A776FF8CCA8",
offset: 18546,
partition: 3,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18547}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 311",
metadata: %{
headers: [],
key: "EA13D1FE0D4F68F8C60BADB8F2ADC250",
offset: 18547,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 3}}, %{offset: 18548}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 330",
metadata: %{
headers: [],
key: "29894D1A771CA407864DF717F52E7F31",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18549}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 342",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18550}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 380",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18551}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
data: "body 404",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 3},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 4},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18578}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 26",
metadata: %{
headers: [],
key: "B332E6B79C01FC14ECEBEC38C3E53C40",
offset: 18578,
partition: 4,
topic: "event.foo",
ts: 1651874029302
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18579}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 42",
metadata: %{
headers: [],
key: "E32E0DAE81A563183C58EE8E2FA2DEEB",
offset: 18579,
partition: 4,
topic: "event.foo",
ts: 1651874029318
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18580}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 45",
metadata: %{
headers: [],
key: "F4A5453F812FA762C06A66A00E11219B",
offset: 18580,
partition: 4,
topic: "event.foo",
ts: 1651874029320
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18581}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 46",
metadata: %{
headers: [],
key: "7E732BDC77088CE34592F0DC57B48DEB",
offset: 18581,
partition: 4,
topic: "event.foo",
ts: 1651874029321
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18582}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 50",
metadata: %{
headers: [],
key: "1F1B22BB6098377D1A3AE2BF70788533",
offset: 18582,
partition: 4,
topic: "event.foo",
ts: 1651874029325
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18583}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 55",
metadata: %{
headers: [],
key: "5DB20CB66857127DECCB37C9E4D211A7",
offset: 18583,
partition: 4,
topic: "event.foo",
ts: 1651874029328
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18584}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 71",
metadata: %{
headers: [],
key: "9D315E8612599DECEFDD24435E041634",
offset: 18584,
partition: 4,
topic: "event.foo",
ts: 1651874029342
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18585}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 85",
metadata: %{
headers: [],
key: "7605B03BCAE81BA8961069E799595A21",
offset: 18585,
partition: 4,
topic: "event.foo",
ts: 1651874029355
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18586}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 115",
metadata: %{
headers: [],
key: "B8F4620584DF63FD62C610E35CB5C54A",
offset: 18586,
partition: 4,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18587}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 116",
metadata: %{
headers: [],
key: "2D863477723AC3DAAB3255C185001138",
offset: 18587,
partition: 4,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18588}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 154",
metadata: %{
headers: [],
key: "97534DB79F25CEB8BCE2D545BA845AFA",
offset: 18588,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 4}}, %{offset: 18589}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 155",
metadata: %{
headers: [],
key: "55C3716A42437E36393FAF977CCAF79D",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18590}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 175",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18591}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 192",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18592}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
data: "body 209",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 4},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 5},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18654}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 11",
metadata: %{
headers: [],
key: "74CE9BDFFAD35C5B973ED7CCB30BA552",
offset: 18654,
partition: 5,
topic: "event.foo",
ts: 1651874029284
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18655}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 29",
metadata: %{
headers: [],
key: "765AF8171D348D1EC234034BA471A3C8",
offset: 18655,
partition: 5,
topic: "event.foo",
ts: 1651874029306
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18656}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 32",
metadata: %{
headers: [],
key: "F3814A2710018E684623B4903F488583",
offset: 18656,
partition: 5,
topic: "event.foo",
ts: 1651874029309
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18657}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 36",
metadata: %{
headers: [],
key: "1E29D66141BFDDF40E11F74F604392C4",
offset: 18657,
partition: 5,
topic: "event.foo",
ts: 1651874029313
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18658}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 87",
metadata: %{
headers: [],
key: "51320A685DA7E0005780305BE24072FE",
offset: 18658,
partition: 5,
topic: "event.foo",
ts: 1651874029356
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18659}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 92",
metadata: %{
headers: [],
key: "4D9A3F3F336553A1BD75368D37539C32",
offset: 18659,
partition: 5,
topic: "event.foo",
ts: 1651874029363
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18660}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 107",
metadata: %{
headers: [],
key: "60417DAE2A8CF8EEDDE65C0CDCC594BA",
offset: 18660,
partition: 5,
topic: "event.foo",
ts: 1651874029374
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18661}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 130",
metadata: %{
headers: [],
key: "B07BE83E37169DEFD0A2F840D8925B6F",
offset: 18661,
partition: 5,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18662}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 132",
metadata: %{
headers: [],
key: "D775082F42129CEDD94C1E7774F438B8",
offset: 18662,
partition: 5,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18663}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 160",
metadata: %{
headers: [],
key: "8627B2C7BC9590A1D6C96D46D3595115",
offset: 18663,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 5}}, %{offset: 18664}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 163",
metadata: %{
headers: [],
key: "7A40BEEAA24E470BFBD84C41E0C92231",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18665}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 169",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18666}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 179",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18667}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
data: "body 186",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 5},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 6},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18599}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 48",
metadata: %{
headers: [],
key: "42B27989F88A66B00B6A271E3EC560CF",
offset: 18599,
partition: 6,
topic: "event.foo",
ts: 1651874029323
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18600}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 76",
metadata: %{
headers: [],
key: "9D9CF4BDF8281FBB0CCCE9D739E7D2DF",
offset: 18600,
partition: 6,
topic: "event.foo",
ts: 1651874029345
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18601}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 109",
metadata: %{
headers: [],
key: "4793FBE04C4B94832D17BE6084982075",
offset: 18601,
partition: 6,
topic: "event.foo",
ts: 1651874029376
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18602}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 110",
metadata: %{
headers: [],
key: "332EF6D167FCC3EB644E9347793ED2BB",
offset: 18602,
partition: 6,
topic: "event.foo",
ts: 1651874029377
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18603}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 113",
metadata: %{
headers: [],
key: "8608C3D47A7A02B7C6978AB18B1C7170",
offset: 18603,
partition: 6,
topic: "event.foo",
ts: 1651874029379
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18604}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 118",
metadata: %{
headers: [],
key: "59CCCD80560A764EB69B63E8B99B0ECA",
offset: 18604,
partition: 6,
topic: "event.foo",
ts: 1651874029385
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18605}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 131",
metadata: %{
headers: [],
key: "B83DA33A2C3326B82D6DADEC0EB98C2F",
offset: 18605,
partition: 6,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18606}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 149",
metadata: %{
headers: [],
key: "CF2D3F26CCF5DE619AF1C4831944398B",
offset: 18606,
partition: 6,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18607}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 177",
metadata: %{
headers: [],
key: "F0B37E65131710C733D99CD66421BBA8",
offset: 18607,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 6}}, %{offset: 18608}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 188",
metadata: %{
headers: [],
key: "98AD93F45ACC4A7F8F2E3DFA5D5B6E55",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18609}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 205",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18610}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 224",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18611}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
data: "body 260",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 6},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 7},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18634}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 3",
metadata: %{
headers: [],
key: "54A88CCCF362AEB106A8A2EAD91F05B3",
offset: 18634,
partition: 7,
topic: "event.foo",
ts: 1651874029271
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18635}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 7",
metadata: %{
headers: [],
key: "0309F3DF112EA67E142FB9C2A705DBDA",
offset: 18635,
partition: 7,
topic: "event.foo",
ts: 1651874029278
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18636}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 16",
metadata: %{
headers: [],
key: "27FF700CE034CA71099913F37916A7E7",
offset: 18636,
partition: 7,
topic: "event.foo",
ts: 1651874029291
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18637}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 70",
metadata: %{
headers: [],
key: "0066E4EC367CBE880B7644D98E489407",
offset: 18637,
partition: 7,
topic: "event.foo",
ts: 1651874029341
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18638}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 78",
metadata: %{
headers: [],
key: "121DD6F96FCC9B963258CD8CE746A6EA",
offset: 18638,
partition: 7,
topic: "event.foo",
ts: 1651874029347
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18639}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 80",
metadata: %{
headers: [],
key: "2C773F793FE3DEBC431F6E3615F4A93E",
offset: 18639,
partition: 7,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18640}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 83",
metadata: %{
headers: [],
key: "19958490BB6C9E0EC64F9E05892001DA",
offset: 18640,
partition: 7,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18641}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 101",
metadata: %{
headers: [],
key: "66034AC8056F78D405BB5C23CD88CF51",
offset: 18641,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 7}}, %{offset: 18642}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 129",
metadata: %{
headers: [],
key: "82CD079421C7C07D10C2B7C362A4C895",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18643}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 144",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18644}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 150",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18645}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
data: "body 156",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 7},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 8},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18403}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 33",
metadata: %{
headers: [],
key: "D2B838FC270366DC56F8E6E86F7E78AC",
offset: 18403,
partition: 8,
topic: "event.foo",
ts: 1651874029310
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18404}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 51",
metadata: %{
headers: [],
key: "5C8F747CF0CE2BAC701C6A95F5534BFA",
offset: 18404,
partition: 8,
topic: "event.foo",
ts: 1651874029326
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18405}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 73",
metadata: %{
headers: [],
key: "88E31DCDDEC6AC9090187E9746CB496A",
offset: 18405,
partition: 8,
topic: "event.foo",
ts: 1651874029343
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18406}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 75",
metadata: %{
headers: [],
key: "8177F9E5D9B903A7EFCF6DAF7C9DFEC3",
offset: 18406,
partition: 8,
topic: "event.foo",
ts: 1651874029345
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18407}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 91",
metadata: %{
headers: [],
key: "69D555AF71DBD708BD26FFC9FA7868D8",
offset: 18407,
partition: 8,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18408}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 114",
metadata: %{
headers: [],
key: "3639ACBD11A126CC34DF59614126EAAE",
offset: 18408,
partition: 8,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18409}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 215",
metadata: %{
headers: [],
key: "71369A63D4C34C21A0E943FF7C6B3703",
offset: 18409,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 8}}, %{offset: 18410}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 219",
metadata: %{
headers: [],
key: "3BEADD60F65C9098C3D5703DAADC1E17",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 18411}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 246",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 18412}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 288",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 18413}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
data: "body 292",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 8},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]},
{{35, "event.foo", 9},
[
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28592}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 5",
metadata: %{
headers: [],
key: "F8516A51707FB30101DA6148178AB121",
offset: 28592,
partition: 9,
topic: "event.foo",
ts: 1651874029274
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28593}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 13",
metadata: %{
headers: [],
key: "D108D8B3F023E2A95FF70A2E8A2DCD8E",
offset: 28593,
partition: 9,
topic: "event.foo",
ts: 1651874029287
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28594}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 19",
metadata: %{
headers: [],
key: "D976F62A430CB48B149583F8EC0E920B",
offset: 28594,
partition: 9,
topic: "event.foo",
ts: 1651874029294
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28595}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 28",
metadata: %{
headers: [],
key: "DFFD87C06CE8AE907B21229FFC93459B",
offset: 28595,
partition: 9,
topic: "event.foo",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28596}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 58",
metadata: %{
headers: [],
key: "622750CE386F7A842B1A5D7702DD6310",
offset: 28596,
partition: 9,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28597}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 69",
metadata: %{
headers: [],
key: "370210F1F805CCCDCDC2A1CFCFB22412",
offset: 28597,
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", 9}}, %{offset: 28598}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 72",
metadata: %{
headers: [],
key: "85DE3DB81A7A9CA0BD2B6FBA43692FA1",
...
},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, "event.foo", ...}}, %{offset: 28599}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 106",
metadata: %{headers: [], ...},
status: :ok
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {35, ...}}, %{offset: 28600}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 127",
metadata: %{...},
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, {...}}, %{offset: 28601}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
data: "body 134",
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger,
{#PID<0.574.0>, ...}, %{...}},
batch_key: {"event.foo", 9},
batch_mode: :bulk,
batcher: :default,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, {...}, ...},
batch_key: {"event.foo", ...},
batch_mode: :bulk,
...
},
%Broadway.Message{
acknowledger: {BroadwayKafka.Acknowledger, ...},
batch_key: {...},
...
},
%Broadway.Message{acknowledger: {...}, ...},
%Broadway.Message{...},
...
]}
]},
client: BroadwayKafka.BrodClient,
client_id: MyApp.Broadway.Broadway.Producer_0.Client,
config: %{
client_config: [],
fetch_config: %{},
group_config: [offset_commit_policy: :commit_to_kafka_v2],
group_id: "foo_group_id2",
hosts: [{"localhost", 9092}],
offset_commit_on_ack: true,
offset_reset_policy: :latest,
receive_interval: 2000,
reconnect_timeout: 1000,
topics: ["event.foo"]
},
demand: 0,
group_coordinator: #PID<0.579.0>,
receive_interval: 2000,
receive_timer: nil,
reconnect_timeout: 1000,
revoke_caller: nil,
shutting_down?: false
},
rate_limiting: nil,
transformer: nil
}},
{'Stage', :producer},
{'Dispatcher', GenStage.PartitionDispatcher},
{'Consumers',
[#PID<0.582.0>, #PID<0.583.0>, #PID<0.584.0>, #PID<0.585.0>,
#PID<0.586.0>, #PID<0.587.0>, #PID<0.588.0>, #PID<0.589.0>,
#PID<0.590.0>, #PID<0.591.0>]},
{'Buffer size', 0}
]
]
]}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment