Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore(gradle): bump com.google.protobuf:protobuf-java from 3.25.4 to 4.29.3 #20

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

chore(gradle): bump com.google.protobuf:protobuf-java

851e4d4
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Open

chore(gradle): bump com.google.protobuf:protobuf-java from 3.25.4 to 4.29.3 #20

chore(gradle): bump com.google.protobuf:protobuf-java
851e4d4
Select commit
Loading
Failed to load commit list.
GitHub Actions / check-ci test report failed Jan 22, 2025 in 0s

10251 tests run, 46 skipped, 3 failed.

Annotations

Check failure on line 1 in tests/test_kafka_consumer/KafkaConsumerTestCase

See this annotation in the file changed.

@github-actions github-actions / check-ci test report

tests/test_kafka_consumer.py.test_protobuf_spec [regular]

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)
Raw output
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)


The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/python/tests/test_kafka_consumer.py", line 163, in test_protobuf_spec
    t = consume(
  File "/python/tests/test_kafka_consumer.py", line 151, in consume
    return ck.consume(
  File "/python/deephaven/stream/kafka/consumer.py", line 172, in consume
    return _consume(kafka_config, topic, partitions, offsets, key_spec, value_spec, table_type, to_partitioned=False)
  File "/python/deephaven/stream/kafka/consumer.py", line 279, in _consume
    raise DHError(e, "failed to consume a Kafka stream.") from e
deephaven.dherror.DHError: 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)

Check failure on line 1 in tests/test_kafka_consumer/KafkaConsumerTestCase

See this annotation in the file changed.

@github-actions github-actions / check-ci test report

tests/test_kafka_consumer.py.test_protobuf_spec [include /foo /bar]

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)
Raw output
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)


The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/python/tests/test_kafka_consumer.py", line 187, in test_protobuf_spec
    t = consume(
  File "/python/tests/test_kafka_consumer.py", line 151, in consume
    return ck.consume(
  File "/python/deephaven/stream/kafka/consumer.py", line 172, in consume
    return _consume(kafka_config, topic, partitions, offsets, key_spec, value_spec, table_type, to_partitioned=False)
  File "/python/deephaven/stream/kafka/consumer.py", line 279, in _consume
    raise DHError(e, "failed to consume a Kafka stream.") from e
deephaven.dherror.DHError: 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)

Check failure on line 1 in tests/test_kafka_consumer/KafkaConsumerTestCase

See this annotation in the file changed.

@github-actions github-actions / check-ci test report

tests/test_kafka_consumer.py.test_protobuf_spec [include /ts /sub/*]

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)
Raw output
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)


The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/python/tests/test_kafka_consumer.py", line 205, in test_protobuf_spec
    t = consume(
  File "/python/tests/test_kafka_consumer.py", line 151, in consume
    return ck.consume(
  File "/python/deephaven/stream/kafka/consumer.py", line 172, in consume
    return _consume(kafka_config, topic, partitions, offsets, key_spec, value_spec, table_type, to_partitioned=False)
  File "/python/deephaven/stream/kafka/consumer.py", line 279, in _consume
    raise DHError(e, "failed to consume a Kafka stream.") from e
deephaven.dherror.DHError: 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)