def test_simple_spec(self):
    '\n        Check a simple Kafka subscription creates the right table.\n        '
    t = ck.consume({'bootstrap.servers': 'redpanda:29092'}, 'orders', key_spec=KeyValueSpec.IGNORE, value_spec=ck.simple_spec('Price', dtypes.double))
    cols = t.columns
    self.assertEqual(4, len(cols))
    self._assert_common_cols(cols)
    self.assertEqual('Price', cols[3].name)
    self.assertEqual(dtypes.double, cols[3].data_type)
Check a simple Kafka subscription creates the right table.
def test_simple_spec(self):
    '\n        \n        '
    t = ck.consume({'bootstrap.servers': 'redpanda:29092'}, 'orders', key_spec=KeyValueSpec.IGNORE, value_spec=ck.simple_spec('Price', dtypes.double))
    cols = t.columns
    self.assertEqual(4, len(cols))
    self._assert_common_cols(cols)
    self.assertEqual('Price', cols[3].name)
    self.assertEqual(dtypes.double, cols[3].data_type)