chore(gradle): bump com.google.protobuf:protobuf-java from 3.25.4 to 4.30.0 #72
Triggered via pull request
March 11, 2025 00:39
dependabot[bot]
dependabot[bot]
opened
#73
Status
Success
Total duration
9s
Artifacts
–
conventional-pr-check.yml
on: pull_request_target
pr-check
3s
Annotations
3 errors
|
tests/test_kafka_consumer.py.test_protobuf_spec [regular]:
tests/test_kafka_consumer/KafkaConsumerTestCase#L1
failed to consume a Kafka stream. : RuntimeError: java.lang.VerifyError: Bad type on operand stack
Traceback (most recent call last):
File "/python/deephaven/stream/kafka/consumer.py", line 258, in _consume
j_table=_JKafkaTools.consumeToTable(
RuntimeError: java.lang.VerifyError: Bad type on operand stack
Exception Details:
Location:
io/confluent/kafka/schemaregistry/protobuf/ProtobufSchema.toMessage(Lcom/google/protobuf/DescriptorProtos$FileDescriptorProto;Lcom/google/protobuf/DescriptorProtos$DescriptorProto;)Lcom/squareup/wire/schema/internal/parser/MessageElement; @734: invokestatic
Reason:
Type 'com/google/protobuf/DescriptorProtos$MessageOptions' (current frame, stack[1]) is not assignable to 'com/google/protobuf/GeneratedMessageV3$ExtendableMessage'
Current Frame:
bci: @734
flags: { }
locals: { 'com/google/protobuf/DescriptorProtos$FileDescriptorProto', 'com/google/protobuf/DescriptorProtos$DescriptorProto', 'java/lang/String', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'java/util/LinkedHashMap', 'java/util/LinkedHashMap', 'java/util/List', 'com/google/common/collect/ImmutableList$Builder' }
stack: { 'com/google/common/collect/ImmutableList$Builder', 'com/google/protobuf/DescriptorProtos$MessageOptions' }
Bytecode:
0000000: 2bb6 0112 4db2 001e 1301 132c b901 1403
0000010: 00b8 0065 4eb8 0065 3a04 b800 653a 05b8
0000020: 0065 3a06 bb00 cc59 b700 cd3a 07bb 00cc
0000030: 59b7 00cd 3a08 2bb6 0115 b900 5501 003a
0000040: 0919 09b9 0056 0100 9900 3019 09b9 0057
0000050: 0100 c001 163a 0a19 0719 0ab6 0117 b800
0000060: 65b6 0118 5719 0819 0ab6 0117 190a b601
0000070: 19b6 0118 57a7 ffcc bb01 1a59 1907 b601
0000080: 1bb7 011c 3a09 2bb6 011d b900 5501 003a
0000090: 0a19 0ab9 0056 0100 9900 5b19 0ab9 0057
00000a0: 0100 c000 ce3a 0b19 0bb6 011e 9900 3419
00000b0: 0bb6 011f 9a00 2c2a 190b 04b8 00d3 3a0c
00000c0: 1909 190b b601 20b9 0075 0200 c000 d5b9
00000d0: 00d9 0100 c000 d219 0cb6 0069 57a7 0013
00000e0: 2a19 0b03 b800 d33a 0c2d 190c b600 6957
00000f0: a7ff a12b b601 21b9 0055 0100 3a0a 190a
0000100: b900 5601 0099 0022 190a b900 5701 00c0
0000110: 0067 3a0b 2a19 0bb8 0068 3a0c 1904 190c
0000120: b600 6957 a7ff da2b b601 22b9 0055 0100
0000130: 3a0a 190a b900 5601 0099 0021 190a b900
0000140: 5701 00c0 006b 3a0b 190b b800 6c3a 0c19
0000150: 0419 0cb6 0069 57a7 ffdb 2bb6 0123 b900
0000160: 5501 003a 0a19 0ab9 0056 0100 9900 2119
0000170: 0ab9 0057 0100 c001 243a 0b19 0bb8 0125
0000180: 3a0c 1905 190c b600 6957 a7ff db2b b601
0000190: 26b9 0127 0100 3a0a 190a b900 5601 0099
00001a0: 002d 190a b900 5701 00c0 0076 3a0b bb01
00001b0: 2859 b200 4412 d819 0bb8 0129 b701 2a3a
00001c0: 0c19 0519 0cb6 0069 57a7 ffcf 2bb6 012b
00001d0: b900 5501 003a 0a19 0ab9 0056 0100 9900
00001e0: 2119 0ab9 0057 0100 c001 2c3a 0b19 0bb8
00001f0: 012d 3a0c 1906 190c b600 6957 a7ff dbb8
0000200: 0065 3a0a 2bb6 012e b601 2f99 0025 bb00
0000210: 7b59 1301 30b2 0085 2bb6 012e b601 31b8
0000220: 0087 03b7 007f 3a0b 190a 190b b600 6957
0000230: 2bb6 012e b601 3299 0024 bb00 7b59 12a2
0000240: b200 852b b601 2eb6 0133 b800 8703 b700
0000250: 7f3a 0b19 0a19 0bb6 0069 572b b601 2eb6
0000260: 0134 9900 25bb 007b 5913 0135 b200 852b
0000270: b601 2eb6 0136 b800 8703 b700 7f3a 0b19
0000280: 0a19 0bb6 0069 572b b601 2eb6 0137 9900
0000290: 172b b601 2eb6 0138 3a0b 190a 190b b800
00002a0: beb6 0069 572b b601 2eb2 0139 b601 3a99
00002b0: 0029 2bb6 012e b201 39b6 013b c000 c23a
00002c0: 0b13 013c 190b b800 c43a 0c19 0cc6 000b
00002d0: 190a 190c b600 6957 190a 2bb6 012e b800
00002e0: c5b6 00c6 572a 2bb6 013d b800 c83a 0bbb
00002f0: 013e 59b2 0044 2c12 d819 04b6 00ca 190a
0000300: b600 ca19 05b6 00ca 2db6 00ca 1909 b900
0000310: ee01 0019 08ba 013f 0000 b900 f002 00ba
0000320: 0140 0000 b900 dd02 00b8 00e0 b900 1702
0000330: 00c0 00e1 1906 b600 cab8 0004 190b b600
0000340: cab7 0141 b0
Stackmap Table:
full_frame(@65,{Object[#1419],Object[#1507],Object[#1300],Object[#1418],Object[#1418],Object[#1418],Object[#1418],Object[#1508],Object[#1508],Object[#1366]},{})
chop_frame(@120,1)
append_frame(@145,Object[#1301],Object[#1366])
append_frame(@224,Object[#1509])
chop_frame(@240,1)
chop_frame(@243,1)
append_frame(@254,Object[#1366])
chop_frame(@295,1)
append_frame(@306,Object[#1366])
chop_frame(@346,1)
append_frame(@357,Object[#1366])
chop_frame(@397,1)
append_frame(@408,Object[#1366])
chop_frame(@460,1)
append_frame(@471,Object[#1366])
chop_frame(@511,1)
append_frame(@560,Object[#1418])
same_frame(@603)
same_frame(@647)
same_frame(@677)
same_frame(@728)
at io.confluent.kafka.schemaregistry.protobuf.ProtobufSchemaProvider.parseSchemaOrElseThrow(ProtobufSchemaProvider.java:38)
at io.confluent.kafka.schemaregistry.SchemaProvider.parseSchema(SchemaProvider.java:75)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.parseSchema(CachedSchemaRegistryClient.java:301)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaByIdFromRegistry(CachedSchemaRegistryClient.java:347)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaBySubjectAndId(CachedSchemaRegistryClient.java:472)
at io.deephaven.kafka.ProtobufImpl.descriptor(ProtobufImpl.java:230)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.setDescriptor(ProtobufImpl.java:117)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.getDeserializer(ProtobufImpl.java:101)
at io.deephaven.kafka.KafkaTools.getConsumeStruct(KafkaTools.java:1257)
at io.deephaven.kafka.KafkaTools.consume(KafkaTools.java:1347)
at io.deephaven.kafka.KafkaTools.consumeToTable(KafkaTools.java:1020)
|
|
tests/test_kafka_consumer.py.test_protobuf_spec [include /foo /bar]:
tests/test_kafka_consumer/KafkaConsumerTestCase#L1
failed to consume a Kafka stream. : RuntimeError: java.lang.VerifyError: Bad type on operand stack
Traceback (most recent call last):
File "/python/deephaven/stream/kafka/consumer.py", line 258, in _consume
j_table=_JKafkaTools.consumeToTable(
RuntimeError: java.lang.VerifyError: Bad type on operand stack
Exception Details:
Location:
io/confluent/kafka/schemaregistry/protobuf/ProtobufSchema.toMessage(Lcom/google/protobuf/DescriptorProtos$FileDescriptorProto;Lcom/google/protobuf/DescriptorProtos$DescriptorProto;)Lcom/squareup/wire/schema/internal/parser/MessageElement; @734: invokestatic
Reason:
Type 'com/google/protobuf/DescriptorProtos$MessageOptions' (current frame, stack[1]) is not assignable to 'com/google/protobuf/GeneratedMessageV3$ExtendableMessage'
Current Frame:
bci: @734
flags: { }
locals: { 'com/google/protobuf/DescriptorProtos$FileDescriptorProto', 'com/google/protobuf/DescriptorProtos$DescriptorProto', 'java/lang/String', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'java/util/LinkedHashMap', 'java/util/LinkedHashMap', 'java/util/List', 'com/google/common/collect/ImmutableList$Builder' }
stack: { 'com/google/common/collect/ImmutableList$Builder', 'com/google/protobuf/DescriptorProtos$MessageOptions' }
Bytecode:
0000000: 2bb6 0112 4db2 001e 1301 132c b901 1403
0000010: 00b8 0065 4eb8 0065 3a04 b800 653a 05b8
0000020: 0065 3a06 bb00 cc59 b700 cd3a 07bb 00cc
0000030: 59b7 00cd 3a08 2bb6 0115 b900 5501 003a
0000040: 0919 09b9 0056 0100 9900 3019 09b9 0057
0000050: 0100 c001 163a 0a19 0719 0ab6 0117 b800
0000060: 65b6 0118 5719 0819 0ab6 0117 190a b601
0000070: 19b6 0118 57a7 ffcc bb01 1a59 1907 b601
0000080: 1bb7 011c 3a09 2bb6 011d b900 5501 003a
0000090: 0a19 0ab9 0056 0100 9900 5b19 0ab9 0057
00000a0: 0100 c000 ce3a 0b19 0bb6 011e 9900 3419
00000b0: 0bb6 011f 9a00 2c2a 190b 04b8 00d3 3a0c
00000c0: 1909 190b b601 20b9 0075 0200 c000 d5b9
00000d0: 00d9 0100 c000 d219 0cb6 0069 57a7 0013
00000e0: 2a19 0b03 b800 d33a 0c2d 190c b600 6957
00000f0: a7ff a12b b601 21b9 0055 0100 3a0a 190a
0000100: b900 5601 0099 0022 190a b900 5701 00c0
0000110: 0067 3a0b 2a19 0bb8 0068 3a0c 1904 190c
0000120: b600 6957 a7ff da2b b601 22b9 0055 0100
0000130: 3a0a 190a b900 5601 0099 0021 190a b900
0000140: 5701 00c0 006b 3a0b 190b b800 6c3a 0c19
0000150: 0419 0cb6 0069 57a7 ffdb 2bb6 0123 b900
0000160: 5501 003a 0a19 0ab9 0056 0100 9900 2119
0000170: 0ab9 0057 0100 c001 243a 0b19 0bb8 0125
0000180: 3a0c 1905 190c b600 6957 a7ff db2b b601
0000190: 26b9 0127 0100 3a0a 190a b900 5601 0099
00001a0: 002d 190a b900 5701 00c0 0076 3a0b bb01
00001b0: 2859 b200 4412 d819 0bb8 0129 b701 2a3a
00001c0: 0c19 0519 0cb6 0069 57a7 ffcf 2bb6 012b
00001d0: b900 5501 003a 0a19 0ab9 0056 0100 9900
00001e0: 2119 0ab9 0057 0100 c001 2c3a 0b19 0bb8
00001f0: 012d 3a0c 1906 190c b600 6957 a7ff dbb8
0000200: 0065 3a0a 2bb6 012e b601 2f99 0025 bb00
0000210: 7b59 1301 30b2 0085 2bb6 012e b601 31b8
0000220: 0087 03b7 007f 3a0b 190a 190b b600 6957
0000230: 2bb6 012e b601 3299 0024 bb00 7b59 12a2
0000240: b200 852b b601 2eb6 0133 b800 8703 b700
0000250: 7f3a 0b19 0a19 0bb6 0069 572b b601 2eb6
0000260: 0134 9900 25bb 007b 5913 0135 b200 852b
0000270: b601 2eb6 0136 b800 8703 b700 7f3a 0b19
0000280: 0a19 0bb6 0069 572b b601 2eb6 0137 9900
0000290: 172b b601 2eb6 0138 3a0b 190a 190b b800
00002a0: beb6 0069 572b b601 2eb2 0139 b601 3a99
00002b0: 0029 2bb6 012e b201 39b6 013b c000 c23a
00002c0: 0b13 013c 190b b800 c43a 0c19 0cc6 000b
00002d0: 190a 190c b600 6957 190a 2bb6 012e b800
00002e0: c5b6 00c6 572a 2bb6 013d b800 c83a 0bbb
00002f0: 013e 59b2 0044 2c12 d819 04b6 00ca 190a
0000300: b600 ca19 05b6 00ca 2db6 00ca 1909 b900
0000310: ee01 0019 08ba 013f 0000 b900 f002 00ba
0000320: 0140 0000 b900 dd02 00b8 00e0 b900 1702
0000330: 00c0 00e1 1906 b600 cab8 0004 190b b600
0000340: cab7 0141 b0
Stackmap Table:
full_frame(@65,{Object[#1419],Object[#1507],Object[#1300],Object[#1418],Object[#1418],Object[#1418],Object[#1418],Object[#1508],Object[#1508],Object[#1366]},{})
chop_frame(@120,1)
append_frame(@145,Object[#1301],Object[#1366])
append_frame(@224,Object[#1509])
chop_frame(@240,1)
chop_frame(@243,1)
append_frame(@254,Object[#1366])
chop_frame(@295,1)
append_frame(@306,Object[#1366])
chop_frame(@346,1)
append_frame(@357,Object[#1366])
chop_frame(@397,1)
append_frame(@408,Object[#1366])
chop_frame(@460,1)
append_frame(@471,Object[#1366])
chop_frame(@511,1)
append_frame(@560,Object[#1418])
same_frame(@603)
same_frame(@647)
same_frame(@677)
same_frame(@728)
at io.confluent.kafka.schemaregistry.protobuf.ProtobufSchemaProvider.parseSchemaOrElseThrow(ProtobufSchemaProvider.java:38)
at io.confluent.kafka.schemaregistry.SchemaProvider.parseSchema(SchemaProvider.java:75)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.parseSchema(CachedSchemaRegistryClient.java:301)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaByIdFromRegistry(CachedSchemaRegistryClient.java:347)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaBySubjectAndId(CachedSchemaRegistryClient.java:472)
at io.deephaven.kafka.ProtobufImpl.descriptor(ProtobufImpl.java:230)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.setDescriptor(ProtobufImpl.java:117)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.getDeserializer(ProtobufImpl.java:101)
at io.deephaven.kafka.KafkaTools.getConsumeStruct(KafkaTools.java:1257)
at io.deephaven.kafka.KafkaTools.consume(KafkaTools.java:1347)
at io.deephaven.kafka.KafkaTools.consumeToTable(KafkaTools.java:1020)
|
|
tests/test_kafka_consumer.py.test_protobuf_spec [include /ts /sub/*]:
tests/test_kafka_consumer/KafkaConsumerTestCase#L1
failed to consume a Kafka stream. : RuntimeError: java.lang.VerifyError: Bad type on operand stack
Traceback (most recent call last):
File "/python/deephaven/stream/kafka/consumer.py", line 258, in _consume
j_table=_JKafkaTools.consumeToTable(
RuntimeError: java.lang.VerifyError: Bad type on operand stack
Exception Details:
Location:
io/confluent/kafka/schemaregistry/protobuf/ProtobufSchema.toMessage(Lcom/google/protobuf/DescriptorProtos$FileDescriptorProto;Lcom/google/protobuf/DescriptorProtos$DescriptorProto;)Lcom/squareup/wire/schema/internal/parser/MessageElement; @734: invokestatic
Reason:
Type 'com/google/protobuf/DescriptorProtos$MessageOptions' (current frame, stack[1]) is not assignable to 'com/google/protobuf/GeneratedMessageV3$ExtendableMessage'
Current Frame:
bci: @734
flags: { }
locals: { 'com/google/protobuf/DescriptorProtos$FileDescriptorProto', 'com/google/protobuf/DescriptorProtos$DescriptorProto', 'java/lang/String', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'com/google/common/collect/ImmutableList$Builder', 'java/util/LinkedHashMap', 'java/util/LinkedHashMap', 'java/util/List', 'com/google/common/collect/ImmutableList$Builder' }
stack: { 'com/google/common/collect/ImmutableList$Builder', 'com/google/protobuf/DescriptorProtos$MessageOptions' }
Bytecode:
0000000: 2bb6 0112 4db2 001e 1301 132c b901 1403
0000010: 00b8 0065 4eb8 0065 3a04 b800 653a 05b8
0000020: 0065 3a06 bb00 cc59 b700 cd3a 07bb 00cc
0000030: 59b7 00cd 3a08 2bb6 0115 b900 5501 003a
0000040: 0919 09b9 0056 0100 9900 3019 09b9 0057
0000050: 0100 c001 163a 0a19 0719 0ab6 0117 b800
0000060: 65b6 0118 5719 0819 0ab6 0117 190a b601
0000070: 19b6 0118 57a7 ffcc bb01 1a59 1907 b601
0000080: 1bb7 011c 3a09 2bb6 011d b900 5501 003a
0000090: 0a19 0ab9 0056 0100 9900 5b19 0ab9 0057
00000a0: 0100 c000 ce3a 0b19 0bb6 011e 9900 3419
00000b0: 0bb6 011f 9a00 2c2a 190b 04b8 00d3 3a0c
00000c0: 1909 190b b601 20b9 0075 0200 c000 d5b9
00000d0: 00d9 0100 c000 d219 0cb6 0069 57a7 0013
00000e0: 2a19 0b03 b800 d33a 0c2d 190c b600 6957
00000f0: a7ff a12b b601 21b9 0055 0100 3a0a 190a
0000100: b900 5601 0099 0022 190a b900 5701 00c0
0000110: 0067 3a0b 2a19 0bb8 0068 3a0c 1904 190c
0000120: b600 6957 a7ff da2b b601 22b9 0055 0100
0000130: 3a0a 190a b900 5601 0099 0021 190a b900
0000140: 5701 00c0 006b 3a0b 190b b800 6c3a 0c19
0000150: 0419 0cb6 0069 57a7 ffdb 2bb6 0123 b900
0000160: 5501 003a 0a19 0ab9 0056 0100 9900 2119
0000170: 0ab9 0057 0100 c001 243a 0b19 0bb8 0125
0000180: 3a0c 1905 190c b600 6957 a7ff db2b b601
0000190: 26b9 0127 0100 3a0a 190a b900 5601 0099
00001a0: 002d 190a b900 5701 00c0 0076 3a0b bb01
00001b0: 2859 b200 4412 d819 0bb8 0129 b701 2a3a
00001c0: 0c19 0519 0cb6 0069 57a7 ffcf 2bb6 012b
00001d0: b900 5501 003a 0a19 0ab9 0056 0100 9900
00001e0: 2119 0ab9 0057 0100 c001 2c3a 0b19 0bb8
00001f0: 012d 3a0c 1906 190c b600 6957 a7ff dbb8
0000200: 0065 3a0a 2bb6 012e b601 2f99 0025 bb00
0000210: 7b59 1301 30b2 0085 2bb6 012e b601 31b8
0000220: 0087 03b7 007f 3a0b 190a 190b b600 6957
0000230: 2bb6 012e b601 3299 0024 bb00 7b59 12a2
0000240: b200 852b b601 2eb6 0133 b800 8703 b700
0000250: 7f3a 0b19 0a19 0bb6 0069 572b b601 2eb6
0000260: 0134 9900 25bb 007b 5913 0135 b200 852b
0000270: b601 2eb6 0136 b800 8703 b700 7f3a 0b19
0000280: 0a19 0bb6 0069 572b b601 2eb6 0137 9900
0000290: 172b b601 2eb6 0138 3a0b 190a 190b b800
00002a0: beb6 0069 572b b601 2eb2 0139 b601 3a99
00002b0: 0029 2bb6 012e b201 39b6 013b c000 c23a
00002c0: 0b13 013c 190b b800 c43a 0c19 0cc6 000b
00002d0: 190a 190c b600 6957 190a 2bb6 012e b800
00002e0: c5b6 00c6 572a 2bb6 013d b800 c83a 0bbb
00002f0: 013e 59b2 0044 2c12 d819 04b6 00ca 190a
0000300: b600 ca19 05b6 00ca 2db6 00ca 1909 b900
0000310: ee01 0019 08ba 013f 0000 b900 f002 00ba
0000320: 0140 0000 b900 dd02 00b8 00e0 b900 1702
0000330: 00c0 00e1 1906 b600 cab8 0004 190b b600
0000340: cab7 0141 b0
Stackmap Table:
full_frame(@65,{Object[#1419],Object[#1507],Object[#1300],Object[#1418],Object[#1418],Object[#1418],Object[#1418],Object[#1508],Object[#1508],Object[#1366]},{})
chop_frame(@120,1)
append_frame(@145,Object[#1301],Object[#1366])
append_frame(@224,Object[#1509])
chop_frame(@240,1)
chop_frame(@243,1)
append_frame(@254,Object[#1366])
chop_frame(@295,1)
append_frame(@306,Object[#1366])
chop_frame(@346,1)
append_frame(@357,Object[#1366])
chop_frame(@397,1)
append_frame(@408,Object[#1366])
chop_frame(@460,1)
append_frame(@471,Object[#1366])
chop_frame(@511,1)
append_frame(@560,Object[#1418])
same_frame(@603)
same_frame(@647)
same_frame(@677)
same_frame(@728)
at io.confluent.kafka.schemaregistry.protobuf.ProtobufSchemaProvider.parseSchemaOrElseThrow(ProtobufSchemaProvider.java:38)
at io.confluent.kafka.schemaregistry.SchemaProvider.parseSchema(SchemaProvider.java:75)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.parseSchema(CachedSchemaRegistryClient.java:301)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaByIdFromRegistry(CachedSchemaRegistryClient.java:347)
at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaBySubjectAndId(CachedSchemaRegistryClient.java:472)
at io.deephaven.kafka.ProtobufImpl.descriptor(ProtobufImpl.java:230)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.setDescriptor(ProtobufImpl.java:117)
at io.deephaven.kafka.ProtobufImpl$ProtobufConsumeImpl.getDeserializer(ProtobufImpl.java:101)
at io.deephaven.kafka.KafkaTools.getConsumeStruct(KafkaTools.java:1257)
at io.deephaven.kafka.KafkaTools.consume(KafkaTools.java:1347)
at io.deephaven.kafka.KafkaTools.consumeToTable(KafkaTools.java:1020)
|